You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ar...@apache.org on 2021/11/11 10:13:19 UTC

[flink] branch master updated (e61ff88 -> 384af4a)

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from e61ff88  [FLINK-24765][tests] Use DockerImageVersions to reference Kafka docker image
     add 384af4a  [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

No new revisions were added by this update.

Summary of changes:
 .../split/PulsarOrderedPartitionSplitReader.java   |   7 +-
 .../split/PulsarPartitionSplitReaderBase.java      |   9 +-
 .../split/PulsarUnorderedPartitionSplitReader.java |  11 +-
 .../PulsarOrderedPartitionSplitReaderTest.java     |  31 ++--
 .../split/PulsarPartitionSplitReaderTestBase.java  | 188 +++++++++++++++++++++
 .../PulsarUnorderedPartitionSplitReaderTest.java}  |  32 ++--
 6 files changed, 231 insertions(+), 47 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/EmptyMessageParameters.java => flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarOrderedPartitionSplitReaderTest.java (53%)
 create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java
 copy flink-connectors/{flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserIN.java => flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarUnorderedPartitionSplitReaderTest.java} (53%)