OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
rawOperatorState = nullrawOpStatePerSubtasks = new ArrayList<>(parallelism)nullnew ArrayList<>(parallelism)flinkbdb776035f7266916e9debc7a0d4e7cc5cb1dfd3org.apache.flink.runtime.checkpoint.StateAssignmentOperation
_1368
_2371
_1rawOperatorState
_2rawOpStatePerSubtasks
xyznull
  • java.util.ArrayList
xyznew ArrayList<>(parallelism)
AssignedToFalse
managedOperatorState = nullmanagedOpStatePerSubtasks = new ArrayList<>(parallelism)nullnew ArrayList<>(parallelism)flinkbdb776035f7266916e9debc7a0d4e7cc5cb1dfd3org.apache.flink.runtime.checkpoint.StateAssignmentOperation
_1367
_2370
_1managedOperatorState
_2managedOpStatePerSubtasks
xyznull
  • java.util.ArrayList
xyznew ArrayList<>(parallelism)
AssignedToFalse