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 7f802898c [INLONG-8021][Manager] Periodically delete sources with
inconsistent states (#8028)
add 432148167 [INLONG-8029][Sort] Use fixed subscription name when start a
pulsar reader (#8030)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +-
.../inlong/sort/pulsar/internal/FlinkPulsarSource.java | 7 +++++--
.../sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java | 1 +
.../apache/inlong/sort/pulsar/internal/PulsarFetcher.java | 10 ++++++++--
.../apache/inlong/sort/pulsar/internal/ReaderThread.java | 13 +++++++++----
5 files changed, 24 insertions(+), 9 deletions(-)
