You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/01/24 12:53:08 UTC
[flink] branch master updated (05bddfb -> e68c6c5)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 05bddfb [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default
add c5b49d9 [hotfix] Remove 'null if not allocated' from TaskSlot comments
add 2f9769d [hotfix] Segregate TaskSlotPayload interface from Task for TaskSlot and TaskSlotTable
add e68c6c5 [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/taskexecutor/TaskExecutor.java | 39 +-
.../runtime/taskexecutor/TaskManagerServices.java | 16 +-
.../flink/runtime/taskexecutor/slot/TaskSlot.java | 77 ++-
...otActiveException.java => TaskSlotPayload.java} | 24 +-
.../runtime/taskexecutor/slot/TaskSlotTable.java | 685 +--------------------
.../{TaskSlotTable.java => TaskSlotTableImpl.java} | 504 ++++++---------
.../org/apache/flink/runtime/taskmanager/Task.java | 7 +-
.../TaskExecutorPartitionLifecycleTest.java | 5 +-
.../taskexecutor/TaskExecutorSubmissionTest.java | 46 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 393 +++++-------
.../taskexecutor/TaskManagerServicesBuilder.java | 10 +-
.../TaskSubmissionTestEnvironment.java | 23 +-
.../taskexecutor/TestTaskManagerActions.java | 5 +-
.../taskexecutor/slot/TaskSlotTableTest.java | 193 ++++--
.../runtime/taskexecutor/slot/TaskSlotTest.java | 60 ++
.../runtime/taskexecutor/slot/TaskSlotUtils.java | 14 +-
.../taskexecutor/slot/TestingTaskSlotPayload.java | 78 +++
.../taskexecutor/slot/TestingTaskSlotTable.java | 246 ++++++++
.../flink/runtime/taskmanager/TestTaskBuilder.java | 23 +-
19 files changed, 1062 insertions(+), 1386 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/{SlotNotActiveException.java => TaskSlotPayload.java} (63%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/{TaskSlotTable.java => TaskSlotTableImpl.java} (53%)
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TestingTaskSlotPayload.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TestingTaskSlotTable.java