Ensure retryPolicy isn't null in TaskInfoFetcher constructor

trinodb#20216 (comment)
dekimir · Dec 26, 2023 · 304b331 · 304b331
1 parent dee38a2
commit 304b331
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/trino-main/src/main/java/io/trino/server/remotetask/TaskInfoFetcher.java b/core/trino-main/src/main/java/io/trino/server/remotetask/TaskInfoFetcher.java
@@ -131,7 +131,7 @@ public TaskInfoFetcher(
         this.spanBuilderFactory = requireNonNull(spanBuilderFactory, "spanBuilderFactory is null");
         this.stats = requireNonNull(stats, "stats is null");
         this.estimatedMemory = requireNonNull(estimatedMemory, "estimatedMemory is null");
-        this.retryPolicy = retryPolicy;
+        this.retryPolicy = requireNonNull(retryPolicy, "retryPolicy is null");
     }
 
     public TaskInfo getTaskInfo()