This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from eb69863 [FLINK-26028][Connector/pulsar] add sink documentation;
change some pulsar source documentation.
add 7d85b27 [FLINK-26616][tests] Remove deadlines from CommonTestUtils
No new revisions were added by this update.
Summary of changes:
.../ApplicationDispatcherBootstrapITCase.java | 35 +++------
.../connectors/rabbitmq/RMQSourceITCase.java | 13 +---
.../util/flink/FlinkContainerTestEnvironment.java | 5 +-
.../fs/s3/common/HAJobRunOnMinioS3StoreITCase.java | 6 +-
.../KubernetesResourceManagerDriverTest.java | 9 +--
.../KubernetesCheckpointIDCounterTest.java | 4 +-
...HighAvailabilityRecoverFromSavepointITCase.java | 4 --
.../KubernetesHighAvailabilityTestBase.java | 2 +-
...KubernetesLeaderElectionAndRetrievalITCase.java | 6 +-
.../KubernetesLeaderElectionDriverTest.java | 10 +--
.../KubernetesLeaderRetrievalDriverTest.java | 7 +-
...sMultipleComponentLeaderElectionDriverTest.java | 2 +-
.../KubernetesStateHandleStoreITCase.java | 5 +-
.../KubernetesStateHandleStoreTest.java | 4 +-
.../resources/KubernetesLeaderElectorITCase.java | 10 ++-
.../resources/TestingLeaderCallbackHandler.java | 37 +++-------
.../flink/runtime/blob/BlobServerCleanupTest.java | 6 +-
.../flink/runtime/blob/PermanentBlobCacheTest.java | 7 +-
.../flink/runtime/blob/TransientBlobCacheTest.java | 6 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 8 +--
.../runtime/dispatcher/AbstractDispatcherTest.java | 5 +-
.../dispatcher/DispatcherCleanupITCase.java | 19 ++---
.../flink/runtime/dispatcher/DispatcherTest.java | 3 -
.../runtime/dispatcher/JobDispatcherITCase.java | 16 ++---
.../ZooKeeperDefaultDispatcherRunnerTest.java | 8 +--
.../ZooKeeperJobGraphStoreWatcherTest.java | 11 +--
.../flink/runtime/jobmaster/JobMasterTest.java | 14 +---
.../slotpool/SlotPoolInteractionsTest.java | 10 +--
.../DefaultLeaderElectionServiceTest.java | 18 +----
.../LeaderChangeClusterComponentsTest.java | 10 +--
.../StandaloneLeaderElectionTest.java | 4 +-
.../runtime/leaderelection/TestingLeaderBase.java | 40 +++--------
.../leaderelection/TestingRetrievalBase.java | 42 +++--------
.../ZooKeeperLeaderElectionTest.java | 37 ++++------
...rMultipleComponentLeaderElectionDriverTest.java | 6 +-
.../DefaultLeaderRetrievalServiceTest.java | 18 ++---
.../SettableLeaderRetrievalServiceTest.java | 7 +-
...eeperLeaderRetrievalConnectionHandlingTest.java | 4 +-
.../adaptive/AdaptiveSchedulerClusterITCase.java | 7 +-
.../adaptive/AdaptiveSchedulerSimpleITCase.java | 3 -
.../runtime/taskexecutor/TaskExecutorITCase.java | 7 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 2 -
.../flink/runtime/testutils/CommonTestUtils.java | 82 ++++------------------
.../runtime/testutils/MiniClusterResource.java | 27 ++-----
.../tasks/StreamTaskFinalCheckpointsTest.java | 5 +-
.../flink/table/client/cli/CliClientTest.java | 5 +-
.../table/client/cli/CliTableauResultViewTest.java | 10 +--
.../environment/MiniClusterTestEnvironment.java | 5 +-
.../testframe/testsuites/SinkTestSuiteBase.java | 29 ++------
.../testframe/testsuites/SourceTestSuiteBase.java | 43 +++---------
.../testframe/utils/ConnectorTestConstants.java | 1 -
.../JobMasterStopWithSavepointITCase.java | 2 -
.../test/checkpointing/ManualCheckpointITCase.java | 13 +---
.../flink/test/checkpointing/SavepointITCase.java | 3 +-
.../UnalignedCheckpointFailureHandlingITCase.java | 3 +-
.../test/recovery/ClusterEntrypointITCase.java | 8 +--
.../JobManagerHAProcessFailureRecoveryITCase.java | 2 +-
.../flink/test/recovery/LocalRecoveryITCase.java | 12 +---
.../test/recovery/TaskManagerRunnerITCase.java | 7 +-
.../DefaultSchedulerLocalRecoveryITCase.java | 6 +-
.../ZooKeeperLeaderElectionITCase.java | 23 ++----
.../test/scheduling/AdaptiveSchedulerITCase.java | 22 ++----
.../flink/test/scheduling/ReactiveModeITCase.java | 9 +--
.../flink/yarn/YARNHighAvailabilityITCase.java | 20 ++----
.../yarn/YARNSessionCapacitySchedulerITCase.java | 14 ++--
.../apache/flink/yarn/YARNSessionFIFOITCase.java | 17 +----
66 files changed, 202 insertions(+), 643 deletions(-)
