lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3442]Duplicate code calls for 'FlinkOptions.flatOptions' (#4832)

Browse Source
This commit is contained in:
zhangxiang17
2022-02-17 11:04:09 +08:00
committed by GitHub
parent ba0afe1426
commit 433c2573ef
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java
View File

@@ -23,7 +23,6 @@ import org.apache.hudi.common.model.HoodieKey;
import org.apache.hudi.common.model.HoodieOperation; import org.apache.hudi.common.model.HoodieOperation;
import org.apache.hudi.common.model.HoodieRecord; import org.apache.hudi.common.model.HoodieRecord;
import org.apache.hudi.common.model.HoodieRecordPayload; import org.apache.hudi.common.model.HoodieRecordPayload;
import org.apache.hudi.configuration.FlinkOptions;
import org.apache.hudi.keygen.KeyGenerator; import org.apache.hudi.keygen.KeyGenerator;
import org.apache.hudi.keygen.factory.HoodieAvroKeyGeneratorFactory; import org.apache.hudi.keygen.factory.HoodieAvroKeyGeneratorFactory;
import org.apache.hudi.sink.utils.PayloadCreation; import org.apache.hudi.sink.utils.PayloadCreation;
@@ -88,7 +87,7 @@ public class RowDataToHoodieFunction<I extends RowData, O extends HoodieRecord>
this.converter = RowDataToAvroConverters.createConverter(this.rowType); this.converter = RowDataToAvroConverters.createConverter(this.rowType);
this.keyGenerator = this.keyGenerator =
HoodieAvroKeyGeneratorFactory HoodieAvroKeyGeneratorFactory
.createKeyGenerator(flinkConf2TypedProperties(FlinkOptions.flatOptions(this.config))); .createKeyGenerator(flinkConf2TypedProperties(this.config));
this.payloadCreation = PayloadCreation.instance(config); this.payloadCreation = PayloadCreation.instance(config);
} }