This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 636a526 [FLINK-10170] [table] Add string representation for all Table
& SQL API types
new 36129cd [hotfix] Fix checkstyle violations in
ZooKeeperStateHandleStore
new 4440b16 [hotfix] Fix checkstyle violations in
ZooKeeperCompletedCheckpointStore
new 73e3669 [FLINK-10185] Make
ZooKeeperStateHandleStore#releaseAndTryRemove synchronous
new f8d47b6 [hotfix] Fix checkstyle violations in ZooKeeperUtils
new fabd246 [FLINK-10011] Introduce SubmittedJobGraphStore#releaseJobGraph
new 5e62da0 [FLINK-10011] Release JobGraph after losing leadership in
JobManager
new d1dcb68 [hotfix][tests] Ensure that JobManagerRunners are stopped
when Dispatcher loses leadership
new 4d72047 [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} | 23 +-
.../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, 879 insertions(+), 634 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/rest/messages/JobIDPathParameter.java
=>
test/java/org/apache/flink/runtime/dispatcher/NoOpSubmittedJobGraphListener.java}
(64%)
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%)
