This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0180284381b [FLINK-31487][table-planner] Add targetColumns to
DynamicTableSink#Context
add f0ee3e68569 [hotfix] Remove public class & method modifier for some
tests and migrate AdaptiveSchedulerTest to Juint5.
add dfba6cb91b4 [FLINK-31405][test] Introduce willNotCompleteWithin for
FlinkCompletableFutureAssert.
add d88f39c4486 [FLINK-31405][test] Refactor tests to git rid of timeout
of CompletableFuture assertions.
No new revisions were added by this update.
Summary of changes:
.../apache/flink/client/ClientHeartbeatTest.java | 8 +-
.../ApplicationDispatcherBootstrapTest.java | 7 +-
.../apache/flink/client/program/ClientTest.java | 5 +-
.../program/PerJobMiniClusterFactoryTest.java | 17 +--
.../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 11 +-
.../DefaultJobManagerRunnerRegistryTest.java | 47 +++---
.../CheckpointResourcesCleanupRunnerTest.java | 101 ++++++-------
.../cleanup/DefaultResourceCleanerTest.java | 40 +++--
.../runner/SessionDispatcherLeaderProcessTest.java | 78 +++++-----
.../partition/hybrid/HsMemoryDataManagerTest.java | 8 +-
.../partition/hybrid/HsMemoryDataSpillerTest.java | 6 +-
.../DefaultJobMasterServiceProcessTest.java | 40 +++--
.../JobMasterServiceLeadershipRunnerTest.java | 31 ++--
.../ZooKeeperLeaderElectionTest.java | 18 ++-
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 167 +++++++++++----------
.../taskexecutor/ThreadInfoSampleServiceTest.java | 18 +--
.../testframe/testsuites/SinkTestSuiteBase.java | 7 +-
.../testframe/testsuites/SourceTestSuiteBase.java | 5 +-
.../testutils/FlinkCompletableFutureAssert.java | 38 +++++
.../flink/core/testutils/FlinkAssertionsTest.java | 24 +++
20 files changed, 362 insertions(+), 314 deletions(-)
