update

apache · Mar 21, 2024 · 75b189d · 75b189d
1 parent f2040f4
commit 75b189d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaTaskInfo.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaTaskInfo.java
@@ -49,7 +49,7 @@ public class KafkaTaskInfo extends RoutineLoadTaskInfo {
     public KafkaTaskInfo(UUID id, long jobId, String clusterName,
                         long timeoutMs, int timeoutBackOffCount,
                         Map<Integer, Long> partitionIdToOffset, boolean isMultiTable) {
-        super(id, jobId, timeoutMs, timeoutBackOffCount, isMultiTable);
+        super(id, jobId, clusterName, timeoutMs, timeoutBackOffCount, isMultiTable);
         this.partitionIdToOffset = partitionIdToOffset;
     }