[BugFix] Fix routine load task info null pointer exception (StarRocks…

…#29793)
wyb · Sep 5, 2023 · fc39fdc · fc39fdc
1 parent 0d85353
commit fc39fdc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/load/routineload/KafkaTaskInfo.java b/fe/fe-core/src/main/java/com/starrocks/load/routineload/KafkaTaskInfo.java
@@ -176,7 +176,7 @@ public TRoutineLoadTask createRoutineLoadTask() throws UserException {
         tRoutineLoadTask.setType(TLoadSourceType.KAFKA);
         tRoutineLoadTask.setParams(plan(routineLoadJob));
         // When the transaction times out, we reduce the consumption time to lower the BE load.
-        if (msg.contains(DatabaseTransactionMgr.TXN_TIMEOUT_BY_MANAGER)) {
+        if (msg != null && msg.contains(DatabaseTransactionMgr.TXN_TIMEOUT_BY_MANAGER)) {
             tRoutineLoadTask.setMax_interval_s(routineLoadJob.getTaskConsumeSecond() / 2);
         } else {
             tRoutineLoadTask.setMax_interval_s(routineLoadJob.getTaskConsumeSecond());