elon-X

[FLINK-35064] Update Pulsar dependency to solve the conflict of com.f…

3

This PR fixes the conflict of com.fasterxml.jackson.annotation.JsonFormat$Value ## Purpose of the change fixes the conflict of com.fasterxml.jackson.annotation.JsonFormat$Value ## Brief change log update pom.xml to relocate the 'com.fasterxml' classes to 'org.apache.pulsar.shade.com.fasterxml'...

[FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish

2

## What is the purpose of the change Sources with watermark alignment get stuck once some subtasks finish, this PR solves this problem. ## Brief change log while some subtasks...

[FLINK-35632] Fix the example provided in the kafkaSource documentation for topic regex subscription

1

Fix the example provided in the kafkaSource documentation for topic regex subscription see the issue: https://issues.apache.org/jira/browse/FLINK-35632

In this subtask of FLIP-288, FLINK-32020, it can be seen that automatic partition discovery is supposed to be enabled by default, but it actually isn't. For details, see issue: FLINK-35631.