You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ma...@apache.org on 2022/02/16 08:45:42 UTC

[flink] branch master updated (70ee694 -> 540d876)

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

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


    from 70ee694  [FLINK-26174][kinesis] Add Internal annotation to KinesisDataStreamsSink#restore
     add 5575c9a  [FLINK-25973][runtime] Renamed ArchivedExecutionGraph.createFromInitializingJob into createSparseArchivedExecutionGraph
     add f1e7d12  [FLINK-25978][runtime] Removes obsolete cleanup tests from DispatcherTest
     add 540d876  [FLINK-26017][runtime] Adds log message to when a job is marked as dirty

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/dispatcher/Dispatcher.java       |  5 +-
 .../cleanup/CheckpointResourcesCleanupRunner.java  |  2 +-
 .../executiongraph/ArchivedExecutionGraph.java     |  6 +-
 .../DefaultJobMasterServiceProcessFactory.java     |  2 +-
 .../scheduler/adaptive/AdaptiveScheduler.java      |  2 +-
 .../dispatcher/DispatcherResourceCleanupTest.java  |  2 +-
 .../flink/runtime/dispatcher/DispatcherTest.java   | 85 +---------------------
 .../executiongraph/ArchivedExecutionGraphTest.java |  4 +-
 .../DefaultJobMasterServiceProcessTest.java        |  2 +-
 .../JobMasterServiceLeadershipRunnerTest.java      |  2 +-
 .../runtime/jobmaster/TestingJobManagerRunner.java |  2 +-
 .../TestingJobMasterServiceProcessFactory.java     |  2 +-
 .../TestingJobMasterServiceProcessFactoryOld.java  |  2 +-
 .../runtime/scheduler/ExecutionGraphInfoTest.java  |  2 +-
 .../runtime/scheduler/adaptive/CreatedTest.java    |  2 +-
 .../adaptive/CreatingExecutionGraphTest.java       |  2 +-
 16 files changed, 23 insertions(+), 101 deletions(-)