Re: [PR] [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' [inlong]

2023-11-27 Thread via GitHub
EMsnap commented on code in PR #9334: URL: https://github.com/apache/inlong/pull/9334#discussion_r1405771175 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java: ## @@ -142,15 +143,17 @@ public Map tableOptions() {

Re: [PR] [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' [inlong]

2023-11-27 Thread via GitHub
EMsnap commented on code in PR #9334: URL: https://github.com/apache/inlong/pull/9334#discussion_r1405771175 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java: ## @@ -142,15 +143,17 @@ public Map tableOptions() {

Re: [PR] [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' [inlong]

2023-11-27 Thread via GitHub
EMsnap commented on code in PR #9334: URL: https://github.com/apache/inlong/pull/9334#discussion_r1405776513 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java: ## @@ -142,15 +143,17 @@ public Map tableOptions() {

Re: [PR] [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' [inlong]

2023-11-27 Thread via GitHub
LiJie20190102 commented on code in PR #9334: URL: https://github.com/apache/inlong/pull/9334#discussion_r1405781386 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/HudiExtractNode.java: ## @@ -142,15 +143,17 @@ public Map tableOptions() {

Re: [PR] [INLONG-9299][Sort] Iceberg support all migrate and auto create table [inlong]

2023-11-27 Thread via GitHub
EMsnap merged PR #9306: URL: https://github.com/apache/inlong/pull/9306 -- 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.apach

(inlong) branch master updated: [INLONG-9299][Sort] Iceberg support all migrate and auto create table (#9306)

2023-11-27 Thread zirui
This is an automated email from the ASF dual-hosted git repository. zirui 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 0d7826760b [INLONG-9299][Sort] Iceberg support al

Re: [PR] [INLONG-9338][Agent] Real time file collection uses the current time as the data time [inlong]

2023-11-27 Thread via GitHub
dockerzhang merged PR #9339: URL: https://github.com/apache/inlong/pull/9339 -- 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-9338][Agent] Real time file collection uses the current time as the data time (#9339)

2023-11-27 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 cf663fcfec [INLONG-9338][Agent] Real time f

Re: [PR] [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' [inlong]

2023-11-27 Thread via GitHub
dockerzhang merged PR #9334: URL: https://github.com/apache/inlong/pull/9334 -- 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-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' (#9334)

2023-11-27 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 5ff109f6d1 [INLONG-9333][Sort] Related prob

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
hnrainll commented on code in PR #9331: URL: https://github.com/apache/inlong/pull/9331#discussion_r1405916183 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/starrocks/StarRocksDataNodeOperator.java: ## @@ -88,7 +89,7 @@ protected void set

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
healchow commented on code in PR #9331: URL: https://github.com/apache/inlong/pull/9331#discussion_r1405935639 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/starrocks/StarRocksDataNodeOperator.java: ## @@ -88,7 +89,7 @@ protected void set

Re: [PR] [INLONG-8433][Agent] Improve the TaskTypeEnum file [inlong]

2023-11-27 Thread via GitHub
healchow merged PR #9332: URL: https://github.com/apache/inlong/pull/9332 -- 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 (5ff109f6d1 -> 9fc6248a3b)

2023-11-27 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 5ff109f6d1 [INLONG-9333][Sort] Related problem with attribute exceptions when creating 'hudiSink' (#9334) add

Re: [PR] [INLONG-9225][Audit] Automatically create audit topic after service startup [inlong]

2023-11-27 Thread via GitHub
aloyszhang commented on code in PR #9226: URL: https://github.com/apache/inlong/pull/9226#discussion_r1405984248 ## inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/KafkaSink.java: ## @@ -282,6 +310,43 @@ private void initTopicProducer(String topic) {

Re: [PR] [INLONG-8358][Sort] Add kafka connector on flink 1.15 [inlong]

2023-11-27 Thread via GitHub
EMsnap commented on PR #8713: URL: https://github.com/apache/inlong/pull/8713#issuecomment-1827717251 Sorry but there should be It for this feature, any problem with implementing it ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [INLONG-9225][Audit] Automatically create audit topic after service startup [inlong]

2023-11-27 Thread via GitHub
LiJie20190102 commented on code in PR #9226: URL: https://github.com/apache/inlong/pull/9226#discussion_r1406216164 ## inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/KafkaSink.java: ## @@ -282,6 +310,43 @@ private void initTopicProducer(String topic) {

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
vernedeng commented on code in PR #9331: URL: https://github.com/apache/inlong/pull/9331#discussion_r1406978043 ## inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/JdbcSensitiveUrlUtils.java: ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache So

[PR] [INLONG-9343][Manager] Support configuring timeZone related parameters for fileSource [inlong]

2023-11-27 Thread via GitHub
fuweng11 opened a new pull request, #9344: URL: https://github.com/apache/inlong/pull/9344 ### Prepare a Pull Request - Fixes #9343 ### Motivation Support configuring timeZone related parameters for fileSource. ### Modifications Support configuring time

Re: [PR] [INLONG-9297][Manager] Support configuring multiple sink types of tasks under a single stream [inlong]

2023-11-27 Thread via GitHub
healchow commented on code in PR #9298: URL: https://github.com/apache/inlong/pull/9298#discussion_r1406988936 ## inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java: ## @@ -17,9 +17,17 @@ package org.apache.inlong.manager.common.

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
luchunliang commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406992541 ## inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml: ## @@ -48,25 +51,52 @@ from operation_log where id = #{id,jd

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
fuweng11 commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406994276 ## inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml: ## @@ -48,25 +51,52 @@ from operation_log where id = #{id,jdbcT

Re: [PR] [INLONG-9341][SDK] Optimize obtaining local IP information [inlong]

2023-11-27 Thread via GitHub
luchunliang merged PR #9342: URL: https://github.com/apache/inlong/pull/9342 -- 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-9341][SDK] Optimize obtaining local IP information (#9342)

2023-11-27 Thread luchunliang
This is an automated email from the ASF dual-hosted git repository. luchunliang 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 fad216ff9a [INLONG-9341][SDK] Optimize obta

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
luchunliang commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406996502 ## inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml: ## @@ -48,25 +51,52 @@ from operation_log where id = #{id,jd

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
fuweng11 commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406997364 ## inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml: ## @@ -48,25 +51,52 @@ from operation_log where id = #{id,jdbcT

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
fuweng11 commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406999335 ## inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml: ## @@ -48,25 +51,52 @@ from operation_log where id = #{id,jdbcT

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
luchunliang commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1406999848 ## inlong-manager/manager-web/sql/changes-1.10.0.sql: ## @@ -36,4 +36,15 @@ VALUES ('audit_sort_mysql_binlog_input', 'MYSQL_BINLOG', 0, '29'), ('audit_sort_

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
hnrainll commented on code in PR #9331: URL: https://github.com/apache/inlong/pull/9331#discussion_r1407002727 ## inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/JdbcSensitiveUrlUtils.java: ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache Sof

Re: [PR] [INLONG-9337][Manager] Support querying operation records [inlong]

2023-11-27 Thread via GitHub
fuweng11 commented on code in PR #9340: URL: https://github.com/apache/inlong/pull/9340#discussion_r1407002877 ## inlong-manager/manager-web/sql/changes-1.10.0.sql: ## @@ -36,4 +36,15 @@ VALUES ('audit_sort_mysql_binlog_input', 'MYSQL_BINLOG', 0, '29'), ('audit_sort_tub

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
healchow commented on code in PR #9331: URL: https://github.com/apache/inlong/pull/9331#discussion_r1407005669 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/util/MySQLSensitiveUrlUtils.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache Softwa

(inlong) branch master updated: [INLONG-9225][Audit] Automatically create audit topic after service startup (#9226)

2023-11-27 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 c4f820bf30 [INLONG-9225][Audit] Automatical

Re: [PR] [INLONG-9225][Audit] Automatically create audit topic after service startup [inlong]

2023-11-27 Thread via GitHub
dockerzhang merged PR #9226: URL: https://github.com/apache/inlong/pull/9226 -- 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-9343][Manager] Support configuring timeZone related parameters for fileSource (#9344)

2023-11-27 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 9449fcaf50 [INLONG-9343][Manager] Support c

Re: [PR] [INLONG-9343][Manager] Support configuring timeZone related parameters for fileSource [inlong]

2023-11-27 Thread via GitHub
dockerzhang merged PR #9344: URL: https://github.com/apache/inlong/pull/9344 -- 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.

Re: [PR] [INLONG-9330][Manager] Add encoding check to the StarRocks JDBC URL [inlong]

2023-11-27 Thread via GitHub
dockerzhang merged PR #9331: URL: https://github.com/apache/inlong/pull/9331 -- 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-9330][Manager] Add encoding check to the StarRocks JDBC URL (#9331)

2023-11-27 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 d674bfe284 [INLONG-9330][Manager] Add encod

[PR] [INLONG-9345][SDK] Fix DataProxy SDK throws java.lang.NoClassDefFoundErrorException [inlong]

2023-11-27 Thread via GitHub
castorqin opened a new pull request, #9346: URL: https://github.com/apache/inlong/pull/9346 ### 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 replac