[flink] branch master updated (5abef56 -> e20229c)

[rm...@apache.org]

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

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


    from 5abef56  [FLINK-19250][connectors] Fix error propagation in connector base (SplitFetcherManager).
     add 12967c8  [FLINK-19000] Forward initialization timestamp from Dispatcher to ExecutionGraph
     add e20229c  [hotfix] Consider INITIALIZING JobState also as scheduled in CliFrontend

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/client/cli/CliFrontend.java   |  2 +-
 .../dispatcher/DefaultJobManagerRunnerFactory.java |  6 ++--
 .../flink/runtime/dispatcher/Dispatcher.java       | 12 ++++---
 .../flink/runtime/dispatcher/DispatcherJob.java    | 10 +++---
 .../dispatcher/JobManagerRunnerFactory.java        |  3 +-
 .../runtime/executiongraph/ExecutionGraph.java     |  4 ++-
 .../executiongraph/ExecutionGraphBuilder.java      | 12 ++++---
 .../runtime/jobmaster/JobManagerRunnerImpl.java    |  5 +--
 .../apache/flink/runtime/jobmaster/JobMaster.java  | 12 +++++--
 .../apache/flink/runtime/jobmaster/JobResult.java  |  2 +-
 .../factories/DefaultJobMasterServiceFactory.java  |  6 ++--
 .../factories/JobMasterServiceFactory.java         |  3 +-
 .../rest/handler/job/JobDetailsHandler.java        |  2 +-
 .../flink/runtime/scheduler/DefaultScheduler.java  |  6 ++--
 .../runtime/scheduler/DefaultSchedulerFactory.java |  6 ++--
 .../flink/runtime/scheduler/SchedulerBase.java     | 16 ++++++----
 .../runtime/scheduler/SchedulerNGFactory.java      |  3 +-
 .../flink/runtime/webmonitor/WebMonitorUtils.java  |  2 +-
 .../CheckpointSettingsSerializableTest.java        |  3 +-
 .../runtime/dispatcher/DispatcherJobTest.java      |  2 +-
 .../dispatcher/DispatcherResourceCleanupTest.java  |  2 +-
 .../flink/runtime/dispatcher/DispatcherTest.java   | 37 +++++++++++++++++++---
 .../dispatcher/TestingJobManagerRunnerFactory.java |  3 +-
 .../ExecutionGraphDeploymentTest.java              |  3 +-
 .../ExecutionGraphPartitionReleaseTest.java        |  3 +-
 .../ExecutionGraphRescalingTest.java               | 12 ++++---
 .../ExecutionGraphSchedulingTest.java              |  3 +-
 .../ExecutionPartitionLifecycleTest.java           |  3 +-
 .../ExecutionVertexLocalityTest.java               |  3 +-
 .../TestingExecutionGraphBuilder.java              |  3 +-
 .../jobmaster/JobManagerRunnerImplTest.java        |  3 +-
 .../flink/runtime/jobmaster/JobMasterTest.java     |  6 ++--
 .../factories/TestingJobMasterServiceFactory.java  |  2 +-
 .../runtime/jobmaster/utils/JobMasterBuilder.java  |  3 +-
 .../runtime/scheduler/SchedulerTestingUtils.java   |  3 +-
 35 files changed, 142 insertions(+), 64 deletions(-)