This is an automated email from the ASF dual-hosted git repository. mapohl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from ec83c08 [FLINK-25848][connectors/firehose] Separated unit style tests for the KDF Sink into KinesisFirehoseSinkTest add 7b9b21d [hotfix] Uses close instead of stop in ZooKeeperExtension post-test cleanup add 6431155 [hotfix] Aligns state check in ZooKeeperExtension add 55d62c2 [hotfix] Migrates ZooKeeperLeaderRetrievalConnectionHandlingTest to JUnit5/assertj add 8d86133 [FLINK-26121][runtime] Adds clearUnhandledEvents() method No new revisions were added by this update. Summary of changes: ...eeperLeaderRetrievalConnectionHandlingTest.java | 460 ++++++++++----------- .../runtime/zookeeper/ZooKeeperExtension.java | 74 +++- 2 files changed, 271 insertions(+), 263 deletions(-)