You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/05/14 07:57:18 UTC

[flink] branch master updated (6889550 -> ab86a3c)

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 6889550  [FLINK-17655] Remove assignTimestamps from documentation
     add dcbd665  [FLINK-17654][core] Move Clock classes to flink-core to make them usable outside runtime
     add 1fb819a  [FLINK-17654][core] Minor cleanups in clock classes
     add ab86a3c  [FLINK-17654] Make Clock interfaces in flink-core PublicEvolving

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink}/util/clock/Clock.java   | 37 ++++++++++++++++------
 .../org/apache/flink}/util/clock/ManualClock.java  | 22 +++++++++++--
 .../org/apache/flink}/util/clock/SystemClock.java  | 11 ++++---
 .../runtime/checkpoint/CheckpointCoordinator.java  |  4 +--
 .../checkpoint/CheckpointRequestDecider.java       |  2 +-
 .../FailureRateRestartBackoffTimeStrategy.java     |  4 +--
 .../jobmaster/slotpool/DefaultSlotPoolFactory.java |  4 +--
 .../runtime/jobmaster/slotpool/SlotPoolImpl.java   |  2 +-
 .../checkpoint/CheckpointRequestDeciderTest.java   |  2 +-
 .../FailureRateRestartBackoffTimeStrategyTest.java |  2 +-
 .../slotpool/SlotPoolBatchSlotRequestTest.java     |  2 +-
 .../jobmaster/slotpool/SlotPoolBuilder.java        |  4 +--
 .../jobmaster/slotpool/SlotPoolImplTest.java       |  2 +-
 .../slotpool/SlotPoolInteractionsTest.java         |  4 +--
 .../jobmaster/slotpool/TestingSlotPoolImpl.java    |  4 +--
 15 files changed, 71 insertions(+), 35 deletions(-)
 rename {flink-runtime/src/main/java/org/apache/flink/runtime => flink-core/src/main/java/org/apache/flink}/util/clock/Clock.java (57%)
 rename {flink-runtime/src/test/java/org/apache/flink/runtime => flink-core/src/main/java/org/apache/flink}/util/clock/ManualClock.java (66%)
 rename {flink-runtime/src/main/java/org/apache/flink/runtime => flink-core/src/main/java/org/apache/flink}/util/clock/SystemClock.java (91%)