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
