From 433c2573ef5d1f25cba42f169679a4afe5ff2e24 Mon Sep 17 00:00:00 2001
From: zhangxiang17 <zhang_xiang_per@163.com>
Date: Thu, 17 Feb 2022 11:04:09 +0800
Subject: [PATCH] [HUDI-3442]Duplicate code calls for
 'FlinkOptions.flatOptions' (#4832)

---
 .../apache/hudi/sink/transform/RowDataToHoodieFunction.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java b/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java
index 31adcdf29..bfc7d7d62 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java
@@ -23,7 +23,6 @@ import org.apache.hudi.common.model.HoodieKey;
 import org.apache.hudi.common.model.HoodieOperation;
 import org.apache.hudi.common.model.HoodieRecord;
 import org.apache.hudi.common.model.HoodieRecordPayload;
-import org.apache.hudi.configuration.FlinkOptions;
 import org.apache.hudi.keygen.KeyGenerator;
 import org.apache.hudi.keygen.factory.HoodieAvroKeyGeneratorFactory;
 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.keyGenerator =
         HoodieAvroKeyGeneratorFactory
-            .createKeyGenerator(flinkConf2TypedProperties(FlinkOptions.flatOptions(this.config)));
+            .createKeyGenerator(flinkConf2TypedProperties(this.config));
     this.payloadCreation = PayloadCreation.instance(config);
   }