This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.4
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7b34a03 [FLINK-10172] [table] Fix Table.orderBy(String) by adding asc
& desc to ExpressionParser.
add 9ad1e4a [hotfix] Fix checkstyle violations in
ZooKeeperStateHandleStore
add 04cfe3d [hotfix] Fix checkstyle violations in
ZooKeeperCompletedCheckpointStore
add b91ae88 [FLINK-10185] Make
ZooKeeperStateHandleStore#releaseAndTryRemove synchronous
add fe8ddc5 [hotfix] Fix checkstyle violations in ZooKeeperUtils
add d2a828c [FLINK-10011] Introduce SubmittedJobGraphStore#releaseJobGraph
new 07ab3d9 [FLINK-10011] Release JobGraph after losing leadership in
JobManager
The 1 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 +-
.../ZooKeeperCompletedCheckpointStore.java | 95 +++----
.../zookeeper/ZooKeeperHaServices.java | 2 +-
.../StandaloneSubmittedJobGraphStore.java | 13 +-
.../runtime/jobmanager/SubmittedJobGraphStore.java | 12 +
.../ZooKeeperSubmittedJobGraphStore.java | 31 ++-
.../apache/flink/runtime/util/ZooKeeperUtils.java | 56 ++--
.../zookeeper/ZooKeeperStateHandleStore.java | 172 ++-----------
.../runtime/zookeeper/ZooKeeperUtilityFactory.java | 14 +-
.../flink/runtime/jobmanager/JobManager.scala | 39 +--
.../checkpoint/CompletedCheckpointStoreTest.java | 9 +-
...KeeperCompletedCheckpointStoreMockitoTest.java} | 19 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 286 +++++++--------------
.../jobmanager/JobManagerHARecoveryTest.java | 5 +
.../jobmanager/ZooKeeperHAJobManagerTest.java | 203 +++++++++++++++
.../ZooKeeperSubmittedJobGraphsStoreITCase.java | 14 +-
.../flink/runtime/zookeeper/ZooKeeperResource.java | 72 ++++++
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 115 +++------
.../testingUtils/TestingJobManagerLike.scala | 8 +
.../testingUtils/TestingJobManagerMessages.scala | 3 +
20 files changed, 599 insertions(+), 572 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/{ZooKeeperCompletedCheckpointStoreTest.java
=> ZooKeeperCompletedCheckpointStoreMockitoTest.java} (95%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/ZooKeeperHAJobManagerTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperResource.java
