add log

CalvinKirs · May 31, 2023 · a425044 · a425044
1 parent 47ba074
commit a425044
Showing 1 changed file with 0 additions and 4 deletions.
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
@@ -91,11 +91,7 @@ public TRoutineLoadTask createRoutineLoadTask() throws UserException {
             Table tbl = database.getTableOrMetaException(routineLoadJob.getTableId());
             tRoutineLoadTask.setTbl(tbl.getName());
             tRoutineLoadTask.setParams(rePlan(routineLoadJob));
-        } else {
-            //fixme
-            tRoutineLoadTask.setTbl("test_g");
         }
-
         tRoutineLoadTask.setMaxIntervalS(routineLoadJob.getMaxBatchIntervalS());
         tRoutineLoadTask.setMaxBatchRows(routineLoadJob.getMaxBatchRows());
         tRoutineLoadTask.setMaxBatchSize(routineLoadJob.getMaxBatchSizeBytes());