diff --git a/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java b/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java
index da0b4517c33f..186c4176de4a 100644
--- a/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java
+++ b/core/trino-main/src/main/java/io/trino/server/remotetask/HttpRemoteTask.java
@@ -248,7 +248,7 @@ public HttpRemoteTask(
             long pendingSourceSplitsWeight = 0;
             for (PlanNodeId planNodeId : planFragment.getPartitionedSources()) {
                 Collection<Split> tableScanSplits = initialSplits.get(planNodeId);
-                if (tableScanSplits != null && !tableScanSplits.isEmpty()) {
+                if (!tableScanSplits.isEmpty()) {
                     pendingSourceSplitCount += tableScanSplits.size();
                     pendingSourceSplitsWeight = addExact(pendingSourceSplitsWeight, SplitWeight.rawValueSum(tableScanSplits, Split::getSplitWeight));
                 }