[GitHub] [inlong] dockerzhang merged pull request #6739: [INLONG-6738][DataProxy] New sink architecture integration

2022-12-07 Thread GitBox
dockerzhang merged PR #6739: URL: https://github.com/apache/inlong/pull/6739 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.

[inlong] branch master updated: [INLONG-6738][DataProxy] New sink architecture integration (#6739)

2022-12-07 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 5d062bc93 [INLONG-6738][DataProxy] New sink

[GitHub] [inlong] liaorui closed pull request #6741: [INLONG-6740][Sort][Manager]StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
liaorui closed pull request #6741: [INLONG-6740][Sort][Manager]StarRocks connector supports transferring all tables for all schemas in one database URL: https://github.com/apache/inlong/pull/6741 -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [inlong] dockerzhang opened a new pull request, #6778: [INLONG-6777][CVE] Bump com.h2database.h2 to 2.1.214

2022-12-07 Thread GitBox
dockerzhang opened a new pull request, #6778: URL: https://github.com/apache/inlong/pull/6778 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be repl

[GitHub] [inlong] EMsnap commented on a diff in pull request #6748: [INLONG-6747][Sort] StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
EMsnap commented on code in PR #6748: URL: https://github.com/apache/inlong/pull/6748#discussion_r1042089775 ## inlong-sort/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/manager/StarRocksStreamLoadVisitor.java: ## @@ -0,0 +1,322 @@ +/* + * Licensed to

[GitHub] [inlong] Yizhou-Yang opened a new pull request, #6779: [INLONG-6730][Sort] Supports dirty data side-output for sqlserver sink

2022-12-07 Thread GitBox
Yizhou-Yang opened a new pull request, #6779: URL: https://github.com/apache/inlong/pull/6779 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be repl

[GitHub] [inlong] chyueyi commented on issue #6723: 官方文档Doris多表写入文档错误

2022-12-07 Thread GitBox
chyueyi commented on issue #6723: URL: https://github.com/apache/inlong/issues/6723#issuecomment-1340976755 > 这里是flink任务运行需要的Flink SQL。多表和整库同步的逻辑可以只关注多表部分,忽略单表的部分,可能会更容易理解。 > 多表的核心是: > 1.mysql按正则读多表 > 'database-name' = 'user_db', > 'table-name' = 'user_id_*' > (这部分文档中写的确实有问

[GitHub] [inlong] kuansix commented on issue #6723: 官方文档Doris多表写入文档错误

2022-12-07 Thread GitBox
kuansix commented on issue #6723: URL: https://github.com/apache/inlong/issues/6723#issuecomment-1340977158 来信已收到,谢谢! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To uns

[GitHub] [inlong] gong commented on pull request #6748: [INLONG-6747][Sort] StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
gong commented on PR #6748: URL: https://github.com/apache/inlong/pull/6748#issuecomment-1340981698 @liaorui Please add packaging config for this connector in `inlong-distribution/src/main/assemblies/sort-connectors.xml` -- This is an automated message from the Apache Git Service. To resp

[GitHub] [inlong] dockerzhang merged pull request #6778: [INLONG-6777][CVE] Bump com.h2database.h2 to 2.1.214

2022-12-07 Thread GitBox
dockerzhang merged PR #6778: URL: https://github.com/apache/inlong/pull/6778 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.

[inlong] branch master updated: [INLONG-6777][CVE] Bump com.h2database.h2 to 2.1.214 (#6778)

2022-12-07 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 05fa2f347 [INLONG-6777][CVE] Bump com.h2dat

[GitHub] [inlong] ZuoFengZhang opened a new pull request, #6783: [INLONG-6782][Sort] Introduce apache hudi sort connector

2022-12-07 Thread GitBox
ZuoFengZhang opened a new pull request, #6783: URL: https://github.com/apache/inlong/pull/6783 ### Prepare a Pull Request **Introduce apache hudi sort connector** - Fixes #6782 ### Motivation *Explain here the context, and why you're making that change. What is th

[GitHub] [inlong] dockerzhang merged pull request #6774: [INLONG-6773][Manager] Fix the problem of sink cannot jump from the configuration to successful configuration

2022-12-07 Thread GitBox
dockerzhang merged PR #6774: URL: https://github.com/apache/inlong/pull/6774 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.

[inlong] branch master updated: [INLONG-6773][Manager] Fix the problem of sink cannot jump from the configuration to successful configuration (#6774)

2022-12-07 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new db8a69dd6 [INLONG-6773][Manager] Fix the pr

[GitHub] [inlong] ZuoFengZhang opened a new pull request, #6789: [INLONG-6784][Sort] Support apache hudi LoadNode

2022-12-07 Thread GitBox
ZuoFengZhang opened a new pull request, #6789: URL: https://github.com/apache/inlong/pull/6789 ### Prepare a Pull Request *[INLONG-6784][Sort] Support apache hudi LoadNode* - Fixes #6784 ### Motivation *Explain here the context, and why you're making that change. What

[GitHub] [inlong] healchow commented on a diff in pull request #6677: [INLONG-6676][Manager] Support list all InlongTopicInfo under a given cluster tag

2022-12-07 Thread GitBox
healchow commented on code in PR #6677: URL: https://github.com/apache/inlong/pull/6677#discussion_r1042287801 ## inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongGroupController.java: ## @@ -95,6 +97,12 @@ public Response getTopic(@PathVar

[GitHub] [inlong] healchow commented on pull request #6741: [INLONG-6740][Sort][Manager]StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
healchow commented on PR #6741: URL: https://github.com/apache/inlong/pull/6741#issuecomment-1341069854 @liaorui Suggest after merging #6746, commit the changes of the Sort module to this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [inlong] healchow commented on a diff in pull request #6753: [INLONG-6734][Manager] Support non-InlongMessage format of Kafka and Pulsar

2022-12-07 Thread GitBox
healchow commented on code in PR #6753: URL: https://github.com/apache/inlong/pull/6753#discussion_r1042309796 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/kafka/KafkaSource.java: ## @@ -90,6 +90,8 @@ public class KafkaSource extends StreamS

[GitHub] [inlong] ZuoFengZhang opened a new pull request, #6790: [INLONG-6785][Manager] Support register and manage hudi sort

2022-12-07 Thread GitBox
ZuoFengZhang opened a new pull request, #6790: URL: https://github.com/apache/inlong/pull/6790 ### Prepare a Pull Request *[Manager] Support register and manage hudi sort* - Fixes #6785 ### Motivation *Explain here the context, and why you're making that chang

[GitHub] [inlong] ZuoFengZhang opened a new pull request, #6791: [INLONG-6786][Dashboard] Supoort Apache hudi in frontend

2022-12-07 Thread GitBox
ZuoFengZhang opened a new pull request, #6791: URL: https://github.com/apache/inlong/pull/6791 ### Prepare a Pull Request *[Dashboard] Supoort Apache hudi in frontend* - Fixes #6786 ### Motivation *Explain here the context, and why you're making that change. What is t

[GitHub] [inlong] ZuoFengZhang closed pull request #6645: [INLONG-6646][Sort] Support Apache Hudi connector

2022-12-07 Thread GitBox
ZuoFengZhang closed pull request #6645: [INLONG-6646][Sort] Support Apache Hudi connector URL: https://github.com/apache/inlong/pull/6645 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [inlong] healchow merged pull request #6753: [INLONG-6734][Manager] Support non-InlongMessage format of Kafka and Pulsar

2022-12-07 Thread GitBox
healchow merged PR #6753: URL: https://github.com/apache/inlong/pull/6753 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apa

[inlong] branch master updated (db8a69dd6 -> 01de2893b)

2022-12-07 Thread healchow
This is an automated email from the ASF dual-hosted git repository. healchow pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from db8a69dd6 [INLONG-6773][Manager] Fix the problem of sink cannot jump from the configuration to successful configura

[GitHub] [inlong] healchow commented on a diff in pull request #6790: [INLONG-6785][Manager] Support register and manage hudi sort

2022-12-07 Thread GitBox
healchow commented on code in PR #6790: URL: https://github.com/apache/inlong/pull/6790#discussion_r1042845015 ## inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/listener/RestartStreamListener.java: ## @@ -38,12 +43,6 @@ import org.apache.inlong.ma

[inlong] branch master updated: [INLONG-6765][Sort] Supports dirty data side-output for Iceberg sink (#6766)

2022-12-07 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 08db5ea09 [INLONG-6765][Sort] Supports dirt

[GitHub] [inlong] dockerzhang merged pull request #6766: [INLONG-6765][Sort] Supports dirty data side-output for Iceberg sink

2022-12-07 Thread GitBox
dockerzhang merged PR #6766: URL: https://github.com/apache/inlong/pull/6766 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.

[GitHub] [inlong] dockerzhang commented on pull request #6741: [INLONG-6740][Sort][Manager] StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
dockerzhang commented on PR #6741: URL: https://github.com/apache/inlong/pull/6741#issuecomment-1341863304 split to #6746 and #6748, close it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [inlong] dockerzhang closed pull request #6741: [INLONG-6740][Sort][Manager] StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
dockerzhang closed pull request #6741: [INLONG-6740][Sort][Manager] StarRocks connector supports transferring all tables for all schemas in one database URL: https://github.com/apache/inlong/pull/6741 -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [inlong] leezng commented on a diff in pull request #6791: [INLONG-6786][Dashboard] Supoort Apache Hudi sink management

2022-12-07 Thread GitBox
leezng commented on code in PR #6791: URL: https://github.com/apache/inlong/pull/6791#discussion_r1042857586 ## inlong-dashboard/src/locales/cn.json: ## @@ -177,6 +177,25 @@ "meta.Sinks.Iceberg.FieldDescription": "字段描述", "meta.Sinks.Iceberg.PartitionStrategy": "分区策略", "

[GitHub] [inlong] leosanqing commented on issue #6771: [Improve][Manager] Add login failure limit

2022-12-07 Thread GitBox
leosanqing commented on issue #6771: URL: https://github.com/apache/inlong/issues/6771#issuecomment-1341943519 I'll try to do, please assign it to me -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6793: [INLONG-6792][Sort] Supports dirty data side-output for hbase sink

2022-12-07 Thread GitBox
yunqingmoswu opened a new pull request, #6793: URL: https://github.com/apache/inlong/pull/6793 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title: [INLONG-6792][Sort] Supports dirty data side-output for hbase sink *(The following *XYZ* should b

[GitHub] [inlong] leosanqing commented on a diff in pull request #6790: [INLONG-6785][Manager] Support register and manage the resource of Apache Hudi

2022-12-07 Thread GitBox
leosanqing commented on code in PR #6790: URL: https://github.com/apache/inlong/pull/6790#discussion_r1042918024 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hudi/HudiSink.java: ## @@ -0,0 +1,91 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [inlong] ZuoFengZhang commented on a diff in pull request #6790: [INLONG-6785][Manager] Support register and manage the resource of Apache Hudi

2022-12-07 Thread GitBox
ZuoFengZhang commented on code in PR #6790: URL: https://github.com/apache/inlong/pull/6790#discussion_r1042946640 ## inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/listener/RestartStreamListener.java: ## @@ -38,12 +43,6 @@ import org.apache.inlon

[GitHub] [inlong] dockerzhang commented on a diff in pull request #6790: [INLONG-6785][Manager] Support register and manage the resource of Apache Hudi

2022-12-07 Thread GitBox
dockerzhang commented on code in PR #6790: URL: https://github.com/apache/inlong/pull/6790#discussion_r1042960165 ## inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/listener/RestartStreamListener.java: ## @@ -38,12 +43,6 @@ import org.apache.inlong

[GitHub] [inlong-website] allendang001 commented on issue #627: [Feature][Doc] Translate http report guide

2022-12-07 Thread GitBox
allendang001 commented on issue #627: URL: https://github.com/apache/inlong-website/issues/627#issuecomment-1342114366 please assign to me? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spe

[GitHub] [inlong] gong commented on pull request #6748: [INLONG-6747][Sort] StarRocks connector supports transferring all tables for all schemas in one database

2022-12-07 Thread GitBox
gong commented on PR #6748: URL: https://github.com/apache/inlong/pull/6748#issuecomment-1342115939 @liaorui Please add base shade in starrocks.pom, ref to iceberg pom. Because It can avoid modifying base lead classloader problem. ```

[GitHub] [inlong] EMsnap commented on a diff in pull request #6793: [INLONG-6792][Sort] Supports dirty data side-output for hbase sink

2022-12-07 Thread GitBox
EMsnap commented on code in PR #6793: URL: https://github.com/apache/inlong/pull/6793#discussion_r1042971675 ## inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/HbaseLoadFlinkSqlParseTest.java: ## @@ -71,14 +72,21 @@ private MySqlExtractNode buildMySQLExtractNod

[GitHub] [inlong-website] allendang001 opened a new pull request, #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
allendang001 opened a new pull request, #641: URL: https://github.com/apache/inlong-website/pull/641 [[INLONG-627] [Doc] Translate http report guide] translate http report guide -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [inlong-website] allendang001 commented on pull request #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
allendang001 commented on PR #641: URL: https://github.com/apache/inlong-website/pull/641#issuecomment-1342138438 cc @dockerzhang -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific com

[GitHub] [inlong] leezng opened a new pull request, #6794: [INLONG-6758][Dashboard] Unify the log function components of Group and Stream

2022-12-07 Thread GitBox
leezng opened a new pull request, #6794: URL: https://github.com/apache/inlong/pull/6794 - Fixes #6758 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mai

[GitHub] [inlong-website] dockerzhang commented on a diff in pull request #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
dockerzhang commented on code in PR #641: URL: https://github.com/apache/inlong-website/pull/641#discussion_r1043007916 ## docs/sdk/dataproxy-sdk/http.md: ## @@ -1,34 +1,34 @@ --- -title: HTTP 上报 +title: HTTP Report sidebar_position: 3 --- -## 新建实时同步任务 -在 Dashboard 或者通过命令行工

[GitHub] [inlong-website] dockerzhang commented on a diff in pull request #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
dockerzhang commented on code in PR #641: URL: https://github.com/apache/inlong-website/pull/641#discussion_r1043008313 ## docs/sdk/dataproxy-sdk/http.md: ## @@ -1,34 +1,34 @@ --- -title: HTTP 上报 +title: HTTP Report sidebar_position: 3 --- -## 新建实时同步任务 -在 Dashboard 或者通过命令行工

[GitHub] [inlong-website] allendang001 commented on a diff in pull request #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
allendang001 commented on code in PR #641: URL: https://github.com/apache/inlong-website/pull/641#discussion_r1043009756 ## docs/sdk/dataproxy-sdk/http.md: ## @@ -1,34 +1,34 @@ --- -title: HTTP 上报 +title: HTTP Report sidebar_position: 3 --- -## 新建实时同步任务 -在 Dashboard 或者通过命令行

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6796: [INLONG-6795][Sort] Supports dirty data side-output for hive sink

2022-12-07 Thread GitBox
yunqingmoswu opened a new pull request, #6796: URL: https://github.com/apache/inlong/pull/6796 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title: [INLONG-6795][Sort] Supports dirty data side-output for hive sink *(The following *XYZ* shoul

[GitHub] [inlong] bluewang opened a new pull request, #6798: [INLONG-6772][Dashboard] Support Clickhouse node management

2022-12-07 Thread GitBox
bluewang opened a new pull request, #6798: URL: https://github.com/apache/inlong/pull/6798 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be replace

[GitHub] [inlong-website] dockerzhang merged pull request #641: [INLONG-627] [Doc] Translate http report guide (#627)

2022-12-07 Thread GitBox
dockerzhang merged PR #641: URL: https://github.com/apache/inlong-website/pull/641 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@i

[GitHub] [inlong-website] dockerzhang closed issue #627: [Feature][Doc] Translate http report guide

2022-12-07 Thread GitBox
dockerzhang closed issue #627: [Feature][Doc] Translate http report guide URL: https://github.com/apache/inlong-website/issues/627 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[inlong-website] branch master updated (b7937278aa -> 908c99b574)

2022-12-07 Thread dockerzhang
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-website.git from b7937278aa [INLONG-625] [translation] Translate C++ SDK report guide (#625) (#639) add 908c99b574 [

[GitHub] [inlong-website] dockerzhang merged pull request #640: [INLONG-638][sort] Add support for elasticsearch-5

2022-12-07 Thread GitBox
dockerzhang merged PR #640: URL: https://github.com/apache/inlong-website/pull/640 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@i

[inlong-website] branch master updated: [INLONG-638] [sort] Add support for elasticsearch-5 (#640)

2022-12-07 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong-website.git The following commit(s) were added to refs/heads/master by this push: new 5cbabbacb3 [INLONG-638] [sort] Add

[GitHub] [inlong-website] dockerzhang closed issue #638: [Feature][Doc] Elasticsearch-6-inlong Connector is compatible with elasticsearch versions 5 and 6

2022-12-07 Thread GitBox
dockerzhang closed issue #638: [Feature][Doc] Elasticsearch-6-inlong Connector is compatible with elasticsearch versions 5 and 6 URL: https://github.com/apache/inlong-website/issues/638 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [inlong-website] dockerzhang commented on a diff in pull request #637: [INLONG-636][Doc] Postgresql cdc suggest setting replica identity to FULL

2022-12-07 Thread GitBox
dockerzhang commented on code in PR #637: URL: https://github.com/apache/inlong-website/pull/637#discussion_r1043027819 ## docs/data_node/extract_node/postgresql-cdc.md: ## @@ -69,6 +69,28 @@ shared_preload_libraries = 'decoderbufs' wal_level = logical ``` +### replica iden

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6799: [INLONG-6797][Sort] Supports dirty data side-output for filesystem sink

2022-12-07 Thread GitBox
yunqingmoswu opened a new pull request, #6799: URL: https://github.com/apache/inlong/pull/6799 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title: [INLONG-6797][Sort] Supports dirty data side-output for filesystem sink *(The following *XYZ

[GitHub] [inlong-website] dockerzhang commented on pull request #637: [INLONG-636][Doc] Postgresql cdc suggest setting replica identity to FULL

2022-12-07 Thread GitBox
dockerzhang commented on PR #637: URL: https://github.com/apache/inlong-website/pull/637#issuecomment-1342220953 @liaorui do we need a Chinese guide doc at the same time for this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [inlong] EMsnap commented on a diff in pull request #6793: [INLONG-6792][Sort] Supports dirty data side-output for hbase sink

2022-12-07 Thread GitBox
EMsnap commented on code in PR #6793: URL: https://github.com/apache/inlong/pull/6793#discussion_r1043031591 ## inlong-sort/sort-connectors/hbase/src/main/java/org/apache/inlong/sort/hbase/sink/HBaseSinkFunction.java: ## @@ -133,11 +144,13 @@ public HBaseSinkFunction( t