This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 1ec928953 [INLONG-7421][Manager] Add encoding check to the MySQL JDBC
URL in MySQLDataNode (#7422)
add b108b2089 [INLONG-7423][Sort] Pulsar connector with adminUrl support
audit metrics (#7425)
No new revisions were added by this update.
Summary of changes:
.../{withoutadmin => }/FlinkPulsarSource.java | 167 +++++++++++++--------
.../table/DynamicPulsarDeserializationSchema.java | 7 +-
.../pulsar/table/PulsarDynamicTableSource.java | 17 +--
licenses/inlong-sort-connectors/LICENSE | 1 +
4 files changed, 112 insertions(+), 80 deletions(-)
copy
inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/{withoutadmin
=> }/FlinkPulsarSource.java (89%)
