[FLINK-33354][runtime][refactor] serializedJobInformation and taskInf…

…o are never null
apache · Oct 26, 2023 · f76dfc0 · f76dfc0
1 parent 75bcdf8
commit f76dfc0
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/...k-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java b/...k-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java
@@ -98,10 +98,10 @@ public Offloaded(PermanentBlobKey serializedValueKey) {
         }
     }
 
-    /** Serialized job information or <tt>null</tt> if offloaded. */
+    /** Serialized job information if non-offloaded or <tt>PermanentBlobKey</tt> if offloaded. */
     private MaybeOffloaded<JobInformation> serializedJobInformation;
 
-    /** Serialized task information or <tt>null</tt> if offloaded. */
+    /** Serialized task information if non-offloaded or <tt>PermanentBlobKey</tt> if offloaded. */
     private MaybeOffloaded<TaskInformation> serializedTaskInformation;
 
     /**
@@ -283,10 +283,6 @@ public void loadBigData(
             inputGate.tryLoadAndDeserializeShuffleDescriptors(
                     blobService, jobId, shuffleDescriptorsCache);
         }
-
-        // make sure that the serialized job and task information fields are filled
-        Preconditions.checkNotNull(serializedJobInformation);
-        Preconditions.checkNotNull(serializedTaskInformation);
     }
 
     @Override