(inlong) 03/04: [INLONG-9822][Manager] Support flink job runtime execution mode configuration (#9823)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 045e04b7683fc6823e6c8debd59e657538bb9bd8 Author: AloysZhang AuthorDate: Fri Mar 15 15:12:53 2024 +0800 [INLONG-

(inlong) 04/04: [INLONG-9862][Manager] Support submit flink job for offline sync (#9865)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 05c04c80c93e882362c9b08ceea582ce61d4c23d Author: AloysZhang AuthorDate: Fri Mar 22 18:24:26 2024 +0800 [INLONG-

(inlong) branch dev-offline-sync updated (dadc2d194e -> 2932887cb5)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git discard dadc2d194e [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) discard ddc72ed417

(inlong) 02/05: [INLONG-9813][Manager] Support offline data sync management (#9814)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 06a84650c7c5eceb86183f35b24a9486c9a5ca60 Author: AloysZhang AuthorDate: Wed Mar 13 16:18:04 2024 +0800

(inlong) 05/05: Support scheudle infomartion management

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 2932887cb5a5da63b2498b4bb0f97513d05f5aa9 Author: aloyszhang AuthorDate: Thu May 16 16:37:56 2024 +0800

(inlong) branch rebase created (now 05c04c80c9)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git at 05c04c80c9 [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) This branch includes the fol

(inlong) 02/04: [INLONG-9813][Manager] Support offline data sync management (#9814)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit ce64702219a9bb840496da58a2e0ce6fa5492d7e Author: AloysZhang AuthorDate: Wed Mar 13 16:18:04 2024 +0800 [INLONG-

(inlong) 01/04: [INLONG-9781][Manager] Add offline sync task type definition (#9787)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 84511f056fa66a0f3ca008d9621587c80231f582 Author: AloysZhang AuthorDate: Thu Mar 7 11:44:20 2024 +0800 [INLONG-9

(inlong) 03/05: [INLONG-9822][Manager] Support flink job runtime execution mode configuration (#9823)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 9024c1b58d521c6aabda9df937d2c15d7f5c6c23 Author: AloysZhang AuthorDate: Fri Mar 15 15:12:53 2024 +0800

(inlong) 01/05: [INLONG-9781][Manager] Add offline sync task type definition (#9787)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 57d7f733c7b113091fd59e9364e4577631d05055 Author: AloysZhang AuthorDate: Thu Mar 7 11:44:20 2024 +0800

(inlong) 04/05: [INLONG-9862][Manager] Support submit flink job for offline sync (#9865)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 6996891c69316e07bc75faa545e1f49bb06f8892 Author: AloysZhang AuthorDate: Fri Mar 22 18:24:26 2024 +0800

(inlong) 02/04: [INLONG-9813][Manager] Support offline data sync management (#9814)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit dfb22f4d8e1016de28a4818dd5739827f152b844 Author: AloysZhang AuthorDate: Wed Mar 13 16:18:04 2024 +0800 [INLONG-

(inlong) 03/04: [INLONG-9822][Manager] Support flink job runtime execution mode configuration (#9823)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit ff3c351401b2bf0c349792915e733c18ffd01386 Author: AloysZhang AuthorDate: Fri Mar 15 15:12:53 2024 +0800 [INLONG-

(inlong) branch rebase updated (05c04c80c9 -> 65d3a928ea)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git discard 05c04c80c9 [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) discard 045e04b768 [INLONG-9

(inlong) 04/04: [INLONG-9862][Manager] Support submit flink job for offline sync (#9865)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 65d3a928ea702b41613a60b917bab1d59152f23a Author: AloysZhang AuthorDate: Fri Mar 22 18:24:26 2024 +0800 [INLONG-

(inlong) 01/04: [INLONG-9781][Manager] Add offline sync task type definition (#9787)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 1e0fddc0a8d6ab9134f7b6dd7dfafb3d08fd3a91 Author: AloysZhang AuthorDate: Thu Mar 7 11:44:20 2024 +0800 [INLONG-9

(inlong) branch rebase deleted (was 65d3a928ea)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git was 65d3a928ea [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) This change permanently disc

(inlong) branch dev-offline-sync deleted (was 2932887cb5)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git was 2932887cb5 Support scheudle infomartion management This change permanently discards the following revis

(inlong) 02/04: [INLONG-9813][Manager] Support offline data sync management (#9814)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit dfb22f4d8e1016de28a4818dd5739827f152b844 Author: AloysZhang AuthorDate: Wed Mar 13 16:18:04 2024 +0800 [INLONG-

(inlong) 01/04: [INLONG-9781][Manager] Add offline sync task type definition (#9787)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 1e0fddc0a8d6ab9134f7b6dd7dfafb3d08fd3a91 Author: AloysZhang AuthorDate: Thu Mar 7 11:44:20 2024 +0800 [INLONG-9

(inlong) branch rebase created (now 65d3a928ea)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git at 65d3a928ea [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) This branch includes the fol

(inlong) 03/04: [INLONG-9822][Manager] Support flink job runtime execution mode configuration (#9823)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit ff3c351401b2bf0c349792915e733c18ffd01386 Author: AloysZhang AuthorDate: Fri Mar 15 15:12:53 2024 +0800 [INLONG-

(inlong) 04/04: [INLONG-9862][Manager] Support submit flink job for offline sync (#9865)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git commit 65d3a928ea702b41613a60b917bab1d59152f23a Author: AloysZhang AuthorDate: Fri Mar 22 18:24:26 2024 +0800 [INLONG-

(inlong) branch dev-offline-sync created (now 2932887cb5)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git at 2932887cb5 Support scheudle infomartion management This branch includes the following new commits:

(inlong) 05/05: Support scheudle infomartion management

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 2932887cb5a5da63b2498b4bb0f97513d05f5aa9 Author: aloyszhang AuthorDate: Thu May 16 16:37:56 2024 +0800

(inlong) 03/05: [INLONG-9822][Manager] Support flink job runtime execution mode configuration (#9823)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 9024c1b58d521c6aabda9df937d2c15d7f5c6c23 Author: AloysZhang AuthorDate: Fri Mar 15 15:12:53 2024 +0800

(inlong) 01/05: [INLONG-9781][Manager] Add offline sync task type definition (#9787)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 57d7f733c7b113091fd59e9364e4577631d05055 Author: AloysZhang AuthorDate: Thu Mar 7 11:44:20 2024 +0800

(inlong) 04/05: [INLONG-9862][Manager] Support submit flink job for offline sync (#9865)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 6996891c69316e07bc75faa545e1f49bb06f8892 Author: AloysZhang AuthorDate: Fri Mar 22 18:24:26 2024 +0800

(inlong) 02/05: [INLONG-9813][Manager] Support offline data sync management (#9814)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git commit 06a84650c7c5eceb86183f35b24a9486c9a5ca60 Author: AloysZhang AuthorDate: Wed Mar 13 16:18:04 2024 +0800

(inlong) branch rebase deleted (was 65d3a928ea)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch rebase in repository https://gitbox.apache.org/repos/asf/inlong.git was 65d3a928ea [INLONG-9862][Manager] Support submit flink job for offline sync (#9865) The revisions that were on t

(inlong) branch dev-offline-sync updated (2932887cb5 -> 65d3a928ea)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch dev-offline-sync in repository https://gitbox.apache.org/repos/asf/inlong.git discard 2932887cb5 Support scheudle infomartion management discard 6996891c69 [INLONG-9862][Manager] Support su

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603052374 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603082249 ## inlong-audit/audit-sdk/README.md: ## @@ -11,7 +11,7 @@ The Audit Sdk uses log production time as the audit standard, which can ensure that each module is recon

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603113592 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603113938 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603114413 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) unde

Re: [PR] [INLONG-10195][Sort] Hudi connector support audit ID. [inlong]

aloyszhang commented on code in PR #10231: URL: https://github.com/apache/inlong/pull/10231#discussion_r1603126663 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/utils/Pipelines.java: ## @@ -0,0 +1,468 @@ +/* + * Li

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

aloyszhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603138935 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java: ## @@ -502,4 +501,22 @@ private void checkFlushTime() { }

Re: [PR] [INLONG-10195][Sort] Hudi connector support audit ID. [inlong]

XiaoYou201 commented on code in PR #10231: URL: https://github.com/apache/inlong/pull/10231#discussion_r1603203762 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/utils/Pipelines.java: ## @@ -0,0 +1,468 @@ +/* + * Li

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603276503 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java: ## @@ -502,4 +501,22 @@ private void checkFlushTime() { }

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603276503 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java: ## @@ -502,4 +501,22 @@ private void checkFlushTime() { }

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603295220 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603295593 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603295992 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java: ## @@ -0,0 +1,87 @@ +/* + * Licensed to the Apache Software Foundation (AS

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603296657 ## inlong-audit/audit-sdk/README.md: ## @@ -11,7 +11,7 @@ The Audit Sdk uses log production time as the audit standard, which can ensure that each module is reconcile

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603299869 ## inlong-audit/audit-sdk/README.md: ## @@ -68,4 +76,20 @@ In order to ensure the accuracy of auditing, each operator needs to create an au |--|--|

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

doleyzi commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1603300243 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java: ## @@ -56,8 +57,10 @@ public class AuditReporterImpl implements Serializable {

[PR] [INLONG-10233][Manager] Report heartbeat removal port restriction [inlong]

fuweng11 opened a new pull request, #10234: URL: https://github.com/apache/inlong/pull/10234 - Fixes #10233 ### Motivation Report heartbeat removal port restriction. ### Modifications Report heartbeat removal port restriction. -- This is

[PR] [INLONG-10230][Sort] KafkaSink support unified configuration [inlong]

vernedeng opened a new pull request, #10235: URL: https://github.com/apache/inlong/pull/10235 Fixes #10230 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

[PR] [INLONG-10228][Sort] PulsarSink support unified configuration [inlong]

vernedeng opened a new pull request, #10236: URL: https://github.com/apache/inlong/pull/10236 Fixes #10228 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

[PR] [INLONG-10229][Sort] EsSink support unified configuration [inlong]

vernedeng opened a new pull request, #10237: URL: https://github.com/apache/inlong/pull/10237 Fixes #10229 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

aloyszhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1604242980 ## inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java: ## @@ -502,4 +501,22 @@ private void checkFlushTime() { }

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang commented on code in PR #10232: URL: https://github.com/apache/inlong/pull/10232#discussion_r1604245498 ## inlong-audit/audit-sdk/README.md: ## @@ -22,38 +22,46 @@ If the AuditProxy changes in real time, then the business program needs to call AuditOperator.get

[PR] [INLONG-10238][Sort] Mysql connector support audit ID. [inlong]

XiaoYou201 opened a new pull request, #10239: URL: https://github.com/apache/inlong/pull/10239 ### Prepare a Pull Request - [INLONG-10238][Sort] Mysql connectors support audit ID - Fixes https://github.com/apache/inlong/issues/10238 - parent issue: https://github.com/apache/i

Re: [PR] [INLONG-10230][Sort] KafkaSink support unified configuration [inlong]

fuweng11 commented on code in PR #10235: URL: https://github.com/apache/inlong/pull/10235#discussion_r1604302559 ## inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaIdConfig.java: ## @@ -62,112 +57,16 @@ public KafkaId

(inlong) branch master updated (b9c9688fc5 -> 03c2160411)

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 b9c9688fc5 [INLONG-10159][Sort] Kafka connector support audit ID (#10180) add 03c2160411 [INLONG-10225][Aud

Re: [PR] [INLONG-10225][Audit] Audit SDK provides the ability to automatically assign and manage Audit ID [inlong]

dockerzhang merged PR #10232: URL: https://github.com/apache/inlong/pull/10232 -- 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

Re: [PR] [INLONG-10230][Sort] KafkaSink support unified configuration [inlong]

vernedeng commented on code in PR #10235: URL: https://github.com/apache/inlong/pull/10235#discussion_r1604348585 ## inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaIdConfig.java: ## @@ -62,112 +57,16 @@ public KafkaI