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