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(-)