[flink] branch release-1.10 updated (7667d43 -> 4b78a4e)

[tr...@apache.org]

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

trohrmann pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 7667d43  [FLINK-15576] remove isTemporary property from CatalogFunction API
     add 7181254  [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK
     add 7f27bb6  [FLINK-14091][tests] Tests ZooKeeperCheckpointIDCounter can be recoverd from connection loss
     add 7fcda36  [FLINK-14091][tests] Refactor ZooKeeperCheckpointIDCounter for a more testable codebase
     add 361de78  [hotfix] Fix checkstyle violations in ZooKeeperCheckpointIDCounter
     add 4b78a4e  [FLINK-14091] Harden ZKCheckpointIDCounterMultiServersTest

No new revisions were added by this update.

Summary of changes:
 .../DefaultLastStateConnectionStateListener.java}  |  24 +++--
 .../LastStateConnectionStateListener.java}         |  21 ++--
 .../checkpoint/ZooKeeperCheckpointIDCounter.java   |  59 ++++-------
 .../apache/flink/runtime/util/ZooKeeperUtils.java  |   3 +-
 .../checkpoint/CheckpointIDCounterTest.java        |   6 +-
 .../ZKCheckpointIDCounterMultiServersTest.java     | 118 +++++++++++++++++++++
 .../flink/runtime/zookeeper/ZooKeeperResource.java |   5 +
 .../zookeeper/ZooKeeperTestEnvironment.java        |  16 ++-
 8 files changed, 189 insertions(+), 63 deletions(-)
 copy flink-runtime/src/{test/java/org/apache/flink/runtime/checkpoint/NoOpFailJobCall.java => main/java/org/apache/flink/runtime/checkpoint/DefaultLastStateConnectionStateListener.java} (61%)
 copy flink-runtime/src/{test/java/org/apache/flink/runtime/checkpoint/NoOpFailJobCall.java => main/java/org/apache/flink/runtime/checkpoint/LastStateConnectionStateListener.java} (62%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZKCheckpointIDCounterMultiServersTest.java