You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/09/10 08:59:03 UTC
[flink] branch master updated (db378c1 -> bfc9218)
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(-)