This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch branch-1.6
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 15f949e7a [INLONG-7601][Release] Change the tag of Docker images to
1.6.0 (#7624)
new 553b92d04 [INLONG-7614][Sort] Fix sort pulsar connector loss data when
using admin url (#7623)
new 53f57f746 [INLONG-7625][Manager] Make data encoding type as a common
property of StreamSink (#7628)
new ee9aaf10d [INLONG-7619][Manager] Support update and retry MySQL
sources after updating MySQLDataNode (#7621)
new 1643d8230 [INLONG-7626][Docker] Optimize the docker push workflow
(#7627)
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci_docker.yml | 20 ++++++++
docker/build-docker-images.sh | 4 +-
docker/publish-by-arch.sh | 24 +++-------
.../inlong/manager/common/enums/GroupStatus.java | 8 ++++
.../dao/mapper/StreamSourceEntityMapper.java | 16 +++++++
.../resources/mappers/StreamSourceEntityMapper.xml | 42 ++++++++++++++++-
.../inlong/manager/pojo/sink/StreamSink.java | 4 ++
.../inlong/manager/pojo/sink/hive/HiveSink.java | 3 --
.../service/node/AbstractDataNodeOperator.java | 29 +++++++++++-
.../manager/service/node/DataNodeOperator.java | 4 +-
.../manager/service/node/DataNodeServiceImpl.java | 3 +-
.../service/node/mysql/MySQLDataNodeOperator.java | 15 ++++++
.../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 +++--
20 files changed, 260 insertions(+), 137 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
