Update fe/src/main/java/org/apache/doris/load/routineload/KafkaRoutin…

…eLoadJob.java Co-Authored-By: Mingyu Chen <morningman@163.com>
apache · Aug 15, 2019 · c3f70cc · c3f70cc
1 parent 5caff6d
commit c3f70cc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java b/fe/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java
@@ -133,7 +133,7 @@ private void convertCustomProperties() throws DdlException {
             }
         }
         if (convertedCustomProperties.containsKey(KAFKA_DEFAULT_OFFSETS)) {
-            kafkaDefaultOffSet = convertedCustomProperties.get(KAFKA_DEFAULT_OFFSETS);
+            kafkaDefaultOffSet = convertedCustomProperties.remove(KAFKA_DEFAULT_OFFSETS);
         }
     }