From 9e61dad59764abb5acb35adb3399439000b8c774 Mon Sep 17 00:00:00 2001
From: wangxianghu <wangxianghu@apache.org>
Date: Mon, 28 Jun 2021 17:11:32 +0800
Subject: [PATCH] [MINOR] Drop duplicate keygenerator class configuration
 setting (#3167)

---
 .../main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java b/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
index 59534cf15..65ba33923 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
@@ -155,7 +155,6 @@ public class FlinkStreamerConfig extends Configuration {
     conf.setBoolean(FlinkOptions.IGNORE_FAILED, config.commitOnErrors);
     conf.setString(FlinkOptions.RECORD_KEY_FIELD, config.recordKeyField);
     conf.setString(FlinkOptions.PARTITION_PATH_FIELD, config.partitionPathField);
-    conf.setString(FlinkOptions.KEYGEN_CLASS, config.keygenClass);
     if (!StringUtils.isNullOrEmpty(config.keygenClass)) {
       conf.setString(FlinkOptions.KEYGEN_CLASS, config.keygenClass);
     } else {