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/08/17 08:23:18 UTC
[flink] branch master updated (ff94e8b -> b2e1c02)
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 ff94e8b [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator
add b2e1c02 [FLINK-17295] Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber
No new revisions were added by this update.
Summary of changes:
.../state/api/runtime/SavepointEnvironment.java | 3 +-
.../ScheduledDropwizardReporterTest.java | 4 +-
.../PrometheusReporterTaskScopeTest.java | 6 +--
.../flink/metrics/statsd/StatsDReporterTest.java | 4 +-
.../flink/runtime/executiongraph/Execution.java | 2 +-
.../runtime/executiongraph/ExecutionAttemptID.java | 63 ++++++++++++++++++----
.../runtime/io/network/netty/NettyMessage.java | 4 +-
.../apache/flink/runtime/jobgraph/JobVertexID.java | 13 +++++
.../metrics/groups/TaskManagerJobMetricGroup.java | 5 +-
.../runtime/metrics/groups/TaskMetricGroup.java | 7 +--
.../metrics/groups/UnregisteredMetricGroups.java | 2 +-
.../runtime/metrics/scope/TaskScopeFormat.java | 3 +-
.../scheduler/strategy/ExecutionVertexID.java | 13 +++++
.../flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
.../apache/flink/runtime/topology/VertexID.java | 2 +-
.../CheckpointCoordinatorTestingUtils.java | 3 ++
.../executiongraph/ExecutionGraphTestUtils.java | 6 +++
.../flink/runtime/jobmaster/JobMasterTest.java | 4 +-
.../runtime/metrics/groups/MetricGroupTest.java | 4 +-
.../runtime/metrics/groups/OperatorGroupTest.java | 9 ++--
.../metrics/groups/TaskMetricGroupTest.java | 14 ++---
.../chaining/ChainedOperatorsMetricTest.java | 3 +-
.../operators/testutils/MockEnvironment.java | 6 ++-
.../runtime/state/TaskStateManagerImplTest.java | 2 +-
.../streaming/state/RocksDBAsyncSnapshotTest.java | 2 +-
.../StreamTaskStateInitializerImplTest.java | 2 +-
.../runtime/tasks/StreamMockEnvironment.java | 2 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 4 +-
.../runtime/tasks/StreamTaskTestHarness.java | 2 +-
29 files changed, 141 insertions(+), 55 deletions(-)