Name already in use

…nector-pulsar v4.0.0

This closes #22627

…r used in flink-python to v4.0.0, which is compatible with Flink 1.17.x and upwards

This closes #22571.

This closes #22352

Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io>

…Registry

…o improve test stability

Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io>

…in runtime.batch.sql to JUnit5

Using generics will throw exception when 'pipeline.generic-types' is disabled

Close #22609

…eaderContender)

This change adds a clear separation of the driver lifecycle and the LeaderContender
registration to DefaultLeaderElectionService.

Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io>

Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io>

…ntegration tests

…ending slots registered.

…HiveCatalog

This closes #22607.

This reverts commit 8c3637b.

Close #22533

…labeling

* Introduce async task failure labeling as part of ExecutionFailureHandler#handleFailure (both for local and global failures)
* Introduce two fields to ExceptionHistoryEntry: a transient CompletableFuture<Map<String, String>> failureLabelsFuture as well as a Map<String, String> failureLabels -- the failureLabels are set as soon as failureLabelsFuture is completed
* Extend ExceptionHistoryEntry, FailureHandlingResult, FailureHandlingResultSnapshot to expose labels as part of ExceptionHistory
* Extend existing tests (e.g., DefaultSchedulerTest, FailureHandlingResultTest) to validate functionality

… Chinese document

…l columns (#22525)

This closes #20986

…tation

This closes ##22450

…ateSupportTest

…river

Close #22532

#22556)

…ble and other modules to JUnit5

…are of @testtemplate