[PR] [INLONG-10091][Agent] Delete useless code [inlong]

2024-05-12 Thread via GitHub
justinwwhuang opened a new pull request, #10192: URL: https://github.com/apache/inlong/pull/10192 Fixes #10091 ### Motivation The agent does not listen to the port, and the relevant code is useless ### Modifications Delete useless code ### Verifying this change

Re: [PR] [INLONG-10091][Agent] Delete useless code [inlong]

2024-05-12 Thread via GitHub
dockerzhang commented on PR #10192: URL: https://github.com/apache/inlong/pull/10192#issuecomment-2106226797 please remove https://github.com/apache/inlong/blob/master/docker/docker-compose/docker-compose.yml#L102-L103 and https://github.com/apache/inlong/blob/master/inlong-agent/agent-doc

Re: [PR] [INLONG-10183][Sort] MongoDB connector support audit ID. [inlong]

2024-05-12 Thread via GitHub
XiaoYou201 commented on code in PR #10186: URL: https://github.com/apache/inlong/pull/10186#discussion_r1597625433 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBTableSource.java: ## @@ -0,0 +1,331 @@ +/

Re: [PR] [INLONG-10183][Sort] MongoDB connector support audit ID. [inlong]

2024-05-12 Thread via GitHub
XiaoYou201 commented on code in PR #10186: URL: https://github.com/apache/inlong/pull/10186#discussion_r1597625433 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBTableSource.java: ## @@ -0,0 +1,331 @@ +/

Re: [I] [Release] Add blog for the 1.12.0 release [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang closed issue #940: [Release] Add blog for the 1.12.0 release URL: https://github.com/apache/inlong-website/issues/940 -- 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.

Re: [PR] [INLONG-940][Release] Add blog for the 1.12.0 release [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang merged PR #953: URL: https://github.com/apache/inlong-website/pull/953 -- 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-940][Release] Add blog for the 1.12.0 release (#953)

2024-05-12 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 7f62c6aa25 [INLONG-940][Release] Ad

Re: [PR] [INLONG-10091][Agent] Delete the useless code related to 8008 listen port [inlong]

2024-05-12 Thread via GitHub
justinwwhuang commented on PR #10192: URL: https://github.com/apache/inlong/pull/10192#issuecomment-2106488841 > please remove https://github.com/apache/inlong/blob/master/docker/docker-compose/docker-compose.yml#L102-L103 and https://github.com/apache/inlong/blob/master/inlong-agent/agent

Re: [PR] [INLONG-10189][Agent] Handling SDK initialization exceptions [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10190: URL: https://github.com/apache/inlong/pull/10190#discussion_r1597787677 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java: ## @@ -240,6 +241,10 @@ private void traverseMemoryTasksToDb()

Re: [PR] [INLONG-10187][Agent] Handle situations where time offset is empty [inlong]

2024-05-12 Thread via GitHub
dockerzhang merged PR #10188: URL: https://github.com/apache/inlong/pull/10188 -- 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...@inlon

(inlong) branch master updated: [INLONG-10187][Agent] Handle situations where time offset is empty (#10188)

2024-05-12 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 632aa88e44 [INLONG-10187][Agent] Handle sit

Re: [PR] [INLONG-10189][Agent] Handling SDK initialization exceptions [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10190: URL: https://github.com/apache/inlong/pull/10190#discussion_r1597787677 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java: ## @@ -240,6 +241,10 @@ private void traverseMemoryTasksToDb()

Re: [PR] [INLONG-10189][Agent] Handling SDK initialization exceptions [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10190: URL: https://github.com/apache/inlong/pull/10190#discussion_r1597787677 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java: ## @@ -240,6 +241,10 @@ private void traverseMemoryTasksToDb()

Re: [PR] [INLONG-10091][Agent] Delete the useless code related to 8008 listen port [inlong]

2024-05-12 Thread via GitHub
EMsnap commented on PR #10192: URL: https://github.com/apache/inlong/pull/10192#issuecomment-2106540575 public static final String AGENT_ENABLE_HTTP = "agent.http.enable"; public static final boolean DEFAULT_AGENT_ENABLE_HTTP = false; these codes should also be deleted -- This is an a

Re: [PR] [INLONG-10091][Agent] Delete the useless code related to 8008 listen port [inlong]

2024-05-12 Thread via GitHub
EMsnap commented on PR #10192: URL: https://github.com/apache/inlong/pull/10192#issuecomment-2106540773 Please update https://inlong.apache.org/docs/next/modules/agent/configure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[PR] [INLONG-10197][Manager] Support OpenAPI for querying audit data [inlong]

2024-05-12 Thread via GitHub
fuweng11 opened a new pull request, #10199: URL: https://github.com/apache/inlong/pull/10199 - Fixes #10197 ### Motivation Support OpenAPI for querying audit data. ### Modifications Support OpenAPI for querying audit data. -- This is an

Re: [I] [Feature][Sort] Sqlserver connector support audit ID [inlong]

2024-05-12 Thread via GitHub
XiaoYou201 commented on issue #10194: URL: https://github.com/apache/inlong/issues/10194#issuecomment-2106557833 Schnapps has implement this function in DebeziumSourceFunction. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[I] [Improve][Doc] Update the deployment and configuration guides for the latest version [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang opened a new issue, #954: URL: https://github.com/apache/inlong-website/issues/954 ### Description Update the deployment and configuration guides for the latest version ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code o

[PR] [INLONG-954][Doc] Update the deployment and configuration guides for the latest version [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang opened a new pull request, #955: URL: https://github.com/apache/inlong-website/pull/955 Fixes #954 ### Motivation ### Modifications Update the deployment and configuration guides for the latest version ### Verifying this change

Re: [PR] [INLONG-10091][Agent] Delete the useless code related to 8008 listen port [inlong]

2024-05-12 Thread via GitHub
dockerzhang commented on PR #10192: URL: https://github.com/apache/inlong/pull/10192#issuecomment-2106567792 > Please update https://inlong.apache.org/docs/next/modules/agent/configure updated in https://github.com/apache/inlong-website/pull/955 -- This is an automated message from

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
EMsnap commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597832125 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java: ## @@ -0,0 +1,

Re: [PR] [INLONG-954][Doc] Update the deployment and configuration guides for the latest version [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang merged PR #955: URL: https://github.com/apache/inlong-website/pull/955 -- 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

Re: [I] [Improve][Doc] Update the deployment and configuration guides for the latest version [inlong-website]

2024-05-12 Thread via GitHub
dockerzhang closed issue #954: [Improve][Doc] Update the deployment and configuration guides for the latest version URL: https://github.com/apache/inlong-website/issues/954 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

(inlong-website) branch master updated: [INLONG-954][Doc] Update the deployment and configuration guides for the latest version (#955)

2024-05-12 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 555424614a [INLONG-954][Doc] Update

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
EMsnap commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597833511 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaRecordSerializationSchema.java: ## @@ -0,0

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
EMsnap commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597833511 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaRecordSerializationSchema.java: ## @@ -0,0

[PR] [INLONG-10201][Audit] Renamed configuration variables for clarity [inlong]

2024-05-12 Thread via GitHub
haifxu opened a new pull request, #10202: URL: https://github.com/apache/inlong/pull/10202 Fixes #10201 ### Motivation Renamed configuration variables for clarity ### Modifications - Rename configuration variables - Rename audit docker variables ### Veri

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597836391 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java: ## @@ -0,0

[PR] [INLONG-10200][Manager] Define module type mapping relationships [inlong]

2024-05-12 Thread via GitHub
fuweng11 opened a new pull request, #10203: URL: https://github.com/apache/inlong/pull/10203 - Fixes #10200 ### Motivation Define module type mapping relationships. ### Modifications Define module type mapping relationships. -- This is an

Re: [PR] [INLONG-10201][Audit] Renamed configuration variables for clarity [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10202: URL: https://github.com/apache/inlong/pull/10202#discussion_r1597849375 ## inlong-audit/conf/application.properties: ## @@ -16,15 +16,17 @@ # specific language governing permissions and limitations # under the License. # -# proxy.typ

Re: [PR] [INLONG-10091][Agent] Delete the useless code related to 8008 listen port [inlong]

2024-05-12 Thread via GitHub
justinwwhuang merged PR #10192: URL: https://github.com/apache/inlong/pull/10192 -- 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...@inl

(inlong) branch master updated: [INLONG-10091][Agent] Delete the useless code related to 8008 listen port (#10192)

2024-05-12 Thread wenweihuang
This is an automated email from the ASF dual-hosted git repository. wenweihuang 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 808cf799c8 [INLONG-10091][Agent] Delete the

Re: [PR] [INLONG-10183][Sort] MongoDB connector support audit ID. [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10186: URL: https://github.com/apache/inlong/pull/10186#discussion_r1597417232 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBTableSource.java: ## @@ -0,0 +1,331 @@ +/

Re: [PR] [INLONG-10197][Manager] Support OpenAPI for querying audit data [inlong]

2024-05-12 Thread via GitHub
dockerzhang merged PR #10199: URL: https://github.com/apache/inlong/pull/10199 -- 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...@inlon

(inlong) branch master updated (808cf799c8 -> bbd29d961e)

2024-05-12 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.git from 808cf799c8 [INLONG-10091][Agent] Delete the useless code related to 8008 listen port (#10192) add bbd29d961

[PR] [INLONG-10205][Script] Add the metrics.audit.proxy.hosts for standalone deployment [inlong]

2024-05-12 Thread via GitHub
dockerzhang opened a new pull request, #10206: URL: https://github.com/apache/inlong/pull/10206 Fixes #10205 ### Motivation Add the metrics.audit.proxy.hosts for standalone deployment, and make the configuration to the right value. ### Modifications

Re: [PR] [INLONG-10193][Sort] Postgres connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10198: URL: https://github.com/apache/inlong/pull/10198#discussion_r1597869794 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/RowDataDebeziumDeserializeSchema.java: ## @@ -0

Re: [PR] [INLONG-10193][Sort] Postgres connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10198: URL: https://github.com/apache/inlong/pull/10198#discussion_r1597869794 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/RowDataDebeziumDeserializeSchema.java: ## @@ -0

Re: [PR] [INLONG-10193][Sort] Postgres connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10198: URL: https://github.com/apache/inlong/pull/10198#discussion_r1597870481 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/PostgresValueValidator.java: ## @@ -0,0 +1,51 @

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597870862 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java: ## @@ -0,0 +1,635 @@ +/*

Re: [PR] [INLONG-10159][Sort] Kafka connector support audit ID [inlong]

2024-05-12 Thread via GitHub
aloyszhang commented on code in PR #10180: URL: https://github.com/apache/inlong/pull/10180#discussion_r1597883322 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSink.java: ## @@ -0,0 +1,494 @@ +/* +

Re: [PR] [INLONG-10200][Manager] Define module type mapping relationships [inlong]

2024-05-12 Thread via GitHub
dockerzhang merged PR #10203: URL: https://github.com/apache/inlong/pull/10203 -- 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...@inlon

(inlong) branch master updated (bbd29d961e -> cdf81cd791)

2024-05-12 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.git from bbd29d961e [INLONG-10197][Manager] Support OpenAPI for querying audit data (#10199) add cdf81cd791 [INLONG-

Re: [PR] [INLONG-10205][Script] Add the metrics.audit.proxy.hosts for standalone deployment [inlong]

2024-05-12 Thread via GitHub
dockerzhang merged PR #10206: URL: https://github.com/apache/inlong/pull/10206 -- 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...@inlon

(inlong) branch master updated: [INLONG-10205][Script] Add the metrics.audit.proxy.hosts for standalone deployment (#10206)

2024-05-12 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 50fc3024b6 [INLONG-10205][Script] Add the m

[PR] [INLONG-10204][Manager]Kafka sink supports automatic allocation of sort standalone cluster [inlong]

2024-05-12 Thread via GitHub
castorqin opened a new pull request, #10207: URL: https://github.com/apache/inlong/pull/10207 ### 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

Re: [PR] [INLONG-10204][Manager]Kafka sink supports automatic allocation of sort standalone cluster [inlong]

2024-05-12 Thread via GitHub
fuweng11 commented on code in PR #10207: URL: https://github.com/apache/inlong/pull/10207#discussion_r1597960797 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/kafka/KafkaResourceOperator.java: ## @@ -76,7 +76,7 @@ public void cre