Fix cast exception when running peon tasks(#16271)

apache · Apr 16, 2024 · 09b1930 · 09b1930
1 parent b0c5184
commit 09b1930
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java
@@ -24,6 +24,7 @@
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Joiner;
 import com.google.common.base.Optional;
+import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
@@ -316,7 +317,7 @@ public TaskStatus call()
                             if (propName.startsWith(CHILD_PROPERTY_PREFIX)) {
                               command.addSystemProperty(
                                   propName.substring(CHILD_PROPERTY_PREFIX.length()),
-                                  task.getContextValue(propName)
+                                  Preconditions.checkNotNull(task.getContextValue(propName), propName).toString()
                               );
                             }
                           }