From fc39fdc1fe5f93d387e1c862ecf0367b1300abd5 Mon Sep 17 00:00:00 2001 From: zaorangyang Date: Tue, 5 Sep 2023 20:42:38 +0800 Subject: [PATCH] [BugFix] Fix routine load task info null pointer exception (#29793) --- .../main/java/com/starrocks/load/routineload/KafkaTaskInfo.java | 2 +- 1 file changed, 1 insertion(+), 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 index fa1b1b9981a125..f4613d81455915 100644 --- 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());