This is an automated email from the ASF dual-hosted git repository.
pacinogong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 2c6de2ac9 [INLONG-7401][Manager] Fix that cannot create Pulsar
partitions based on numPartitions param (#7402)
add 60e86a942 [INLONG-7391][Sort] Support CSV format and dirty data
collecting for StarRocks connector all db migrating (#7394)
No new revisions were added by this update.
Summary of changes:
.../inlong/sort/base/dirty/DirtySinkHelper.java | 163 ++++++++-------------
.../sort/base/metric/sub/SinkTableMetricData.java | 94 +++++++++++-
.../inlong/sort/base/dirty/RegexReplaceTest.java | 3 +-
.../internal/JdbcMultiBatchingOutputFormat.java | 12 +-
.../sort/starrocks/manager/SinkBufferEntity.java | 73 +++++++++
.../starrocks/manager/StarRocksSinkManager.java | 149 +++++++++++++++----
.../manager/StarRocksStreamLoadVisitor.java | 6 +-
.../table/sink/StarRocksDynamicSinkFunction.java | 46 +++---
8 files changed, 382 insertions(+), 164 deletions(-)
create mode 100644
inlong-sort/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/manager/SinkBufferEntity.java
