This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c87b943 [FLINK-10281] [table] Fix string literal escaping throughout
Table & SQL API
new 4cd3311 [hotfix] Fix checkstyle violations in
ZooKeeperStateHandleStore
new 0a345eb [hotfix] Fix checkstyle violations in
ZooKeeperCompletedCheckpointStore
new a0b6685 [FLINK-10185] Make
ZooKeeperStateHandleStore#releaseAndTryRemove synchronous
new 7ee79d9 [hotfix] Fix checkstyle violations in ZooKeeperUtils
new cb69af1 [FLINK-10011] Introduce SubmittedJobGraphStore#releaseJobGraph
new c395e89 [FLINK-10011] Release JobGraph after losing leadership in
JobManager
new 05b11f9 [hotfix][tests] Ensure that JobManagerRunners are stopped
when Dispatcher loses leadership
new a933d87 [FLINK-10011] Release JobGraph from SubmittedJobGraphStore in
Dispatcher
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../services/ZooKeeperMesosServices.java | 3 +-
.../org/apache/flink/runtime/akka/ActorUtils.java | 10 +
.../ZooKeeperCompletedCheckpointStore.java | 103 +++-----
.../flink/runtime/dispatcher/Dispatcher.java | 59 +++--
.../SingleJobSubmittedJobGraphStore.java | 9 +-
.../zookeeper/ZooKeeperHaServices.java | 2 +-
.../StandaloneSubmittedJobGraphStore.java | 13 +-
.../runtime/jobmanager/SubmittedJobGraphStore.java | 12 +
.../ZooKeeperSubmittedJobGraphStore.java | 31 ++-
.../apache/flink/runtime/util/ZooKeeperUtils.java | 17 +-
.../zookeeper/ZooKeeperStateHandleStore.java | 172 ++----------
.../runtime/zookeeper/ZooKeeperUtilityFactory.java | 14 +-
.../flink/runtime/jobmanager/JobManager.scala | 39 +--
.../checkpoint/CompletedCheckpointStoreTest.java | 9 +-
...KeeperCompletedCheckpointStoreMockitoTest.java} | 19 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 288 +++++++--------------
.../flink/runtime/dispatcher/DispatcherHATest.java | 89 ++++++-
.../dispatcher/NoOpSubmittedJobGraphListener.java} | 24 +-
.../runtime/dispatcher/TestingDispatcher.java | 13 +
.../dispatcher/ZooKeeperHADispatcherTest.java | 203 +++++++++++++++
.../flink/runtime/jobmanager/JobManagerTest.java | 3 +-
.../jobmanager/ZooKeeperHAJobManagerTest.java | 180 +++++++++++++
.../ZooKeeperSubmittedJobGraphsStoreITCase.java | 14 +-
.../testutils/InMemorySubmittedJobGraphStore.java | 5 +
.../ZooKeeperResource.java} | 57 ++--
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 115 +++-----
.../testingUtils/TestingJobManagerLike.scala | 8 +
.../testingUtils/TestingJobManagerMessages.scala | 3 +
28 files changed, 881 insertions(+), 633 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/{ZooKeeperCompletedCheckpointStoreTest.java
=> ZooKeeperCompletedCheckpointStoreMockitoTest.java} (95%)
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/dispatcher/DispatcherException.java
=>
test/java/org/apache/flink/runtime/dispatcher/NoOpSubmittedJobGraphListener.java}
(63%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/ZooKeeperHADispatcherTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/{util/BlobServerResource.java
=> zookeeper/ZooKeeperResource.java} (50%)
