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