This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from db378c1 [FLINK-18823][format] Support serialization for debezium-json format add dfa026f [hotfix][runtime] Add missing Nullable annotations to vertex colocation group add 455ab3d [FLINK-14870][runtime] Ensure JobVertex slot sharing group to be non-null when created from a StreamNode add bfc6292 [hotfix][runtime] Close SlotPool in main thread add c8024b3 [hotfix][runtime] Always invoke SlotPool#releaseTaskManager() with a non-null error add 8a87364 [FLINK-14870][runtime] Drop the nullable assumption of JobVertex slot sharing group add aa5f1bf [FLINK-14870][runtime] Drop the nullable assumption of slot sharing group in scheduler components add bfc9218 [FLINK-14870][runtime] Drop the nullable assumption of slot sharing group in ScheduledUnit and remove the consequently unused methods in SchedulerImpl No new revisions were added by this update. Summary of changes: .../flink/runtime/executiongraph/Execution.java | 8 +- .../runtime/executiongraph/ExecutionJobVertex.java | 12 ++- .../apache/flink/runtime/jobgraph/JobVertex.java | 21 ++++-- .../jobmanager/scheduler/ScheduledUnit.java | 12 ++- .../runtime/jobmaster/slotpool/SchedulerImpl.java | 59 ++------------- .../ExecutionVertexSchedulingRequirements.java | 6 +- ...xecutionVertexSchedulingRequirementsMapper.java | 6 +- .../executiongraph/VertexSlotSharingTest.java | 8 +- .../jobmanager/scheduler/DummyScheduledUnit.java | 3 +- .../scheduler/SchedulerIsolatedTasksTest.java | 3 +- .../jobmanager/scheduler/SchedulerTestBase.java | 5 +- .../jobmaster/slotpool/SchedulerImplTest.java | 85 +++++++++++----------- .../jobmaster/slotpool/SlotPoolImplTest.java | 4 +- .../slotpool/SlotPoolSlotSpreadOutTest.java | 2 +- .../AbstractExecutionSlotAllocatorTest.java | 44 +++++------ .../scheduler/ExecutionSlotAllocatorTestUtils.java | 8 +- .../OneSlotPerExecutionSlotAllocatorTest.java | 1 + .../SlotSharingExecutionSlotAllocatorTest.java | 2 + .../api/graph/StreamingJobGraphGenerator.java | 9 ++- 19 files changed, 128 insertions(+), 170 deletions(-)