You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2023/03/16 08:19:55 UTC

[inlong] branch master updated (3d288bb9c -> 294362b8e)

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

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


    from 3d288bb9c [INLONG-7599][Release] Bumped master branch version to 1.7.0-SNAPSHOT (#7620)
     add 294362b8e [INLONG-7614][Sort] Fix sort pulsar connector loss data when using admin url (#7623)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/{ => internal}/FlinkPulsarSource.java   | 16 +++----
 .../FlinkPulsarSourceWithoutAdmin.java}            | 34 +++++--------
 .../{withoutadmin => internal}/PulsarFetcher.java  | 55 +++++++++++++++++++++-
 .../PulsarMetadataReader.java                      | 50 +++++++++++++-------
 .../{withoutadmin => internal}/ReaderThread.java   |  2 +-
 .../pulsar/table/PulsarDynamicTableSource.java     | 10 ++--
 .../pulsar/withoutadmin/CallbackCollector.java     | 47 ------------------
 licenses/inlong-sort-connectors/LICENSE            | 11 +++--
 8 files changed, 117 insertions(+), 108 deletions(-)
 rename inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{ => internal}/FlinkPulsarSource.java (98%)
 rename inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{withoutadmin/FlinkPulsarSource.java => internal/FlinkPulsarSourceWithoutAdmin.java} (97%)
 rename inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{withoutadmin => internal}/PulsarFetcher.java (94%)
 rename inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{withoutadmin => internal}/PulsarMetadataReader.java (84%)
 rename inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{withoutadmin => internal}/ReaderThread.java (99%)
 delete mode 100644 inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/withoutadmin/CallbackCollector.java