[GitHub] [inlong] dockerzhang merged pull request #5503: [INLONG-5041][Sort] Add Apache Doris load node for Sort

dockerzhang merged PR #5503: URL: https://github.com/apache/inlong/pull/5503 -- 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 (5deaa6570 -> 877adba38)

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 5deaa6570 [INLONG-5598][Manager][DataProxy] Mask sensitive data in logs (#5610) add 877adba38 [INLONG-5041]

[GitHub] [inlong] XuQianJin-Stars commented on pull request #5547: [INLONG-5460][Sort][Manager] Support Apache Hudi

XuQianJin-Stars commented on PR #5547: URL: https://github.com/apache/inlong/pull/5547#issuecomment-1221972942 hi @Jellal-HT A small suggested version upgrade to 0.12 for hudi. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [inlong] gong commented on a diff in pull request #5547: [INLONG-5460][Sort][Manager] Support Apache Hudi

gong commented on code in PR #5547: URL: https://github.com/apache/inlong/pull/5547#discussion_r951125586 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/HudiLoadNode.java: ## @@ -72,6 +79,7 @@ public Map tableOptions() { Map options =

[GitHub] [inlong] luchunliang opened a new pull request, #5619: [INLONG-5618][SortStandalone] Support sink runner of configurable backoff sleeping time to avoid that the flume channel is full when bac

luchunliang opened a new pull request, #5619: URL: https://github.com/apache/inlong/pull/5619 ### Prepare a Pull Request - Title : [INLONG-5618][SortStandalone] Support sink runner of configurable backoff sleeping time to avoid that the flume channel is full when backoff sleeping time is

[GitHub] [inlong] EMsnap commented on a diff in pull request #5614: [INLONG-5613][Sort] Add interval join support for FlinkSqlParser

EMsnap commented on code in PR #5614: URL: https://github.com/apache/inlong/pull/5614#discussion_r951139682 ## inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/IntervalJoinRelationSqlParseTest.java: ## @@ -0,0 +1,187 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5614: [INLONG-5613][Sort] Add interval join support for FlinkSqlParser

yunqingmoswu commented on code in PR #5614: URL: https://github.com/apache/inlong/pull/5614#discussion_r951146503 ## inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/IntervalJoinRelationSqlParseTest.java: ## @@ -0,0 +1,187 @@ +/* + * Licensed to the Apache Sof

[GitHub] [inlong] EMsnap merged pull request #5614: [INLONG-5613][Sort] Add interval join support for FlinkSqlParser

EMsnap merged PR #5614: URL: https://github.com/apache/inlong/pull/5614 -- 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-5613][Sort] Add interval join support for FlinkSqlParser (#5614)

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 58e15df09 [INLONG-5613][Sort] Add interval join s

[GitHub] [inlong] leezng opened a new pull request, #5622: [INLONG-5620][Dashboard] UserSelect uses HighSelect's built-in properties directly

leezng opened a new pull request, #5622: URL: https://github.com/apache/inlong/pull/5622 - Fixes #5620 -- 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] vernedeng opened a new pull request, #5625: [INLONG-5621][SDK] support multi-topic pulsar fetcher

vernedeng opened a new pull request, #5625: URL: https://github.com/apache/inlong/pull/5625 - Fixes #5621 ### Motivation *Explain here the context, and why you're making that change. What is the problem you're trying to solve?* ### Modifications 1. Defination

[GitHub] [inlong] thesumery opened a new pull request, #5627: [INLONG-4764][Sort] Import sort end2end unit test with group file input

thesumery opened a new pull request, #5627: URL: https://github.com/apache/inlong/pull/5627 ### Prepare a Pull Request *[INLONG-4764][Sort] Import sort end2end unit test with group file input* *(The following *XYZ* should be replaced by the actual [GitHub Issue](https://github.

[GitHub] [inlong] woofyzhao opened a new pull request, #5629: [INLONG-5615][Manager] Fix file source agent ip field

woofyzhao opened a new pull request, #5629: URL: https://github.com/apache/inlong/pull/5629 - Fixes #5626 -- 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 unsubsc

[GitHub] [inlong] luchunliang opened a new pull request, #5630: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue

luchunliang opened a new pull request, #5630: URL: https://github.com/apache/inlong/pull/5630 ### Prepare a Pull Request - Title: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue - Fixes #5628 ### Motivation *Explain here the context, and why you're making

[GitHub] [inlong] vernedeng commented on a diff in pull request #5630: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue

vernedeng commented on code in PR #5630: URL: https://github.com/apache/inlong/pull/5630#discussion_r951274166 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/SinkContext.java: ## @@ -37,19 +40,22 @@ public class SinkContext { public stat

[GitHub] [inlong] luchunliang commented on a diff in pull request #5630: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue

luchunliang commented on code in PR #5630: URL: https://github.com/apache/inlong/pull/5630#discussion_r951286188 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/SinkContext.java: ## @@ -37,19 +40,22 @@ public class SinkContext { public st

[GitHub] [inlong] dockerzhang merged pull request #5616: [INLONG-5615][Manager] Add template id and sub task status for file source

dockerzhang merged PR #5616: URL: https://github.com/apache/inlong/pull/5616 -- 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-5615][Manager] Add template id and sub task status for file source (#5616)

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 d51687fac [INLONG-5615][Manager] Add templa

[GitHub] [inlong] dockerzhang merged pull request #5629: [INLONG-5615][Dashboard] Fix file source agent ip field

dockerzhang merged PR #5629: URL: https://github.com/apache/inlong/pull/5629 -- 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-5615][Dashboard] Fix file source agent ip field (#5629)

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 eb296053f [INLONG-5615][Dashboard] Fix file

[GitHub] [inlong] EMsnap opened a new pull request, #5632: [INLONG-5631][Release] Add the 1.3.0 version option for the bug report

EMsnap opened a new pull request, #5632: URL: https://github.com/apache/inlong/pull/5632 - Fixes #5631 ### Motivation [INLONG-5631][Release] Add the 1.3.0 version option for the bug report ### Modifications [INLONG-5631][Release] Add the 1.3.0 version option for t

[GitHub] [inlong] dockerzhang commented on issue #5045: [Feature][Agent] Support collect data from MongoDB

dockerzhang commented on issue #5045: URL: https://github.com/apache/inlong/issues/5045#issuecomment-126416 @seedscoder do you still work on this issue? -- 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

[GitHub] [inlong] EMsnap opened a new pull request, #5635: [INLONG-5634][Release] Update changes log for the 1.3.0 version

EMsnap opened a new pull request, #5635: URL: https://github.com/apache/inlong/pull/5635 - Fixes #5634 ### Motivation [INLONG-5634][Release] Update changes log for the 1.3.0 version ### Modifications [INLONG-5634][Release] Update changes log for the 1.3.0 version

[GitHub] [inlong] dockerzhang merged pull request #5622: [INLONG-5620][Dashboard] UserSelect uses HighSelect's built-in properties directly

dockerzhang merged PR #5622: URL: https://github.com/apache/inlong/pull/5622 -- 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 (eb296053f -> 44e370eda)

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 eb296053f [INLONG-5615][Dashboard] Fix file source agent ip field (#5629) add 44e370eda [INLONG-5620][Dashb

[GitHub] [inlong] gosonzhang opened a new pull request, #5636: [INLONG-5633][Improve][DataProxy]Add statistical information to Http Source

gosonzhang opened a new pull request, #5636: URL: https://github.com/apache/inlong/pull/5636 - Fixes #5633 -- 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 unsubs

[inlong] branch master updated (44e370eda -> 732d3114c)

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 44e370eda [INLONG-5620][Dashboard] UserSelect uses HighSelect's built-in properties directly (#5622) add 73

[GitHub] [inlong] dockerzhang merged pull request #5632: [INLONG-5631][Release] Add the 1.3.0 version option for the bug report

dockerzhang merged PR #5632: URL: https://github.com/apache/inlong/pull/5632 -- 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] healchow commented on a diff in pull request #5635: [INLONG-5634][Release] Update changes log for the 1.3.0 version

healchow commented on code in PR #5635: URL: https://github.com/apache/inlong/pull/5635#discussion_r951436657 ## CHANGES.md: ## @@ -21,6 +21,385 @@ # of release header or remove the below marker. This file is generated. # DO NOT REMOVE THIS MARKER; FOR INTERPOLATING CHANGES!--

[GitHub] [inlong] yunqingmoswu opened a new pull request, #5638: [INLONG-5637][Sort] Fix kafka load node npe error

yunqingmoswu opened a new pull request, #5638: URL: https://github.com/apache/inlong/pull/5638 ### Prepare a Pull Request *(Change the title refer to the following example)* Title: [INLONG-5637][Sort] Fix kafka load node npe error *(The following *XYZ* should be replaced by t

[GitHub] [inlong] thesumery commented on a diff in pull request #5638: [INLONG-5637][Sort] Fix kafka load node npe error

thesumery commented on code in PR #5638: URL: https://github.com/apache/inlong/pull/5638#discussion_r952064773 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java: ## @@ -928,19 +928,15 @@ public void onCompletion(RecordMetadat

[GitHub] [inlong-website] Yizhou-Yang opened a new pull request, #519: [INLONG-4973][Manager] Supplement managerctl command line tools

Yizhou-Yang opened a new pull request, #519: URL: https://github.com/apache/inlong-website/pull/519 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-497][Component] Title of the pull request *(The following *XYZ* should b

[GitHub] [inlong-website] Yizhou-Yang opened a new issue, #520: [Improve] Supplement command line tools information for inlong manager

Yizhou-Yang opened a new issue, #520: URL: https://github.com/apache/inlong-website/issues/520 ### Description The command line tools improvement in inlong-manager-command-line-tools needs corresponding documentation ### Are you willing to submit PR? - [X] Yes, I am will

[GitHub] [inlong] EMsnap commented on a diff in pull request #5636: [INLONG-5633][DataProxy] Add statistical information to the HTTP source

EMsnap commented on code in PR #5636: URL: https://github.com/apache/inlong/pull/5636#discussion_r952072827 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/http/HttpBaseSource.java: ## @@ -48,64 +46,55 @@ public class HttpBaseSource extends Abstrac

[GitHub] [inlong] EMsnap commented on a diff in pull request #5627: [INLONG-4764][Sort] Import sort end2end unit test with group file input

EMsnap commented on code in PR #5627: URL: https://github.com/apache/inlong/pull/5627#discussion_r952082928 ## inlong-sort/sort-end-to-end-tests/src/test/java/org/apache/inlong/sort/tests/utils/PlaceholderResolver.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [inlong] EMsnap commented on a diff in pull request #5625: [INLONG-5621][SDK] Support multi-topic pulsar fetcher

EMsnap commented on code in PR #5625: URL: https://github.com/apache/inlong/pull/5625#discussion_r952089117 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarMultiTopicsFetcher.java: ## @@ -0,0 +1,427 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] dockerzhang commented on a diff in pull request #5635: [INLONG-5634][Release] Update changes log for the 1.3.0 version

dockerzhang commented on code in PR #5635: URL: https://github.com/apache/inlong/pull/5635#discussion_r952102843 ## CHANGES.md: ## @@ -21,6 +21,385 @@ # of release header or remove the below marker. This file is generated. # DO NOT REMOVE THIS MARKER; FOR INTERPOLATING CHANGES

[GitHub] [inlong] EMsnap commented on a diff in pull request #5635: [INLONG-5634][Release] Update changes log for the 1.3.0 version

EMsnap commented on code in PR #5635: URL: https://github.com/apache/inlong/pull/5635#discussion_r952103378 ## CHANGES.md: ## @@ -21,6 +21,385 @@ # of release header or remove the below marker. This file is generated. # DO NOT REMOVE THIS MARKER; FOR INTERPOLATING CHANGES!-->

[GitHub] [inlong] dockerzhang commented on pull request #5636: [INLONG-5633][DataProxy] Add statistical information to the HTTP source

dockerzhang commented on PR #5636: URL: https://github.com/apache/inlong/pull/5636#issuecomment-1223468800 @lucaspeng12138 PTAL, thanks. -- 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 specif

[GitHub] [inlong] gosonzhang commented on a diff in pull request #5636: [INLONG-5633][DataProxy] Add statistical information to the HTTP source

gosonzhang commented on code in PR #5636: URL: https://github.com/apache/inlong/pull/5636#discussion_r952114148 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/http/HttpBaseSource.java: ## @@ -48,64 +46,55 @@ public class HttpBaseSource extends Abs

[GitHub] [inlong] EMsnap merged pull request #5635: [INLONG-5634][Release] Update changes log for the 1.3.0 version

EMsnap merged PR #5635: URL: https://github.com/apache/inlong/pull/5635 -- 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-5634][Release] Update changes log for the 1.3.0 version (#5635)

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 775df46c5 [INLONG-5634][Release] Update changes l

[inlong] branch master updated (775df46c5 -> c0d807918)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 775df46c5 [INLONG-5634][Release] Update changes log for the 1.3.0 version (#5635) add c0d807918 [INLONG-5633

[GitHub] [inlong] gosonzhang merged pull request #5636: [INLONG-5633][DataProxy] Add statistical information to the HTTP source

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

[GitHub] [inlong] gong commented on a diff in pull request #5638: [INLONG-5637][Sort] Fix kafka load node npe error

gong commented on code in PR #5638: URL: https://github.com/apache/inlong/pull/5638#discussion_r952129197 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java: ## @@ -928,19 +928,15 @@ public void onCompletion(RecordMetadata met

[GitHub] [inlong] gong commented on a diff in pull request #5638: [INLONG-5637][Sort] Fix kafka load node npe error

gong commented on code in PR #5638: URL: https://github.com/apache/inlong/pull/5638#discussion_r952129550 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java: ## @@ -928,19 +928,15 @@ public void onCompletion(RecordMetadata met

[inlong] branch master updated: [INLONG-4764][Sort] Import sort end2end unit test with group file input (#5627)

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 99189beda [INLONG-4764][Sort] Import sort e

[GitHub] [inlong] dockerzhang merged pull request #5627: [INLONG-4764][Sort] Import sort end2end unit test with group file input

dockerzhang merged PR #5627: URL: https://github.com/apache/inlong/pull/5627 -- 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] EMsnap opened a new pull request, #5640: [INLONG-5639][Release] Bumped version to 1.4.0-incubating-SNAPSHOT

EMsnap opened a new pull request, #5640: URL: https://github.com/apache/inlong/pull/5640 - Fixes #5639 ### Motivation [INLONG-5639][Release] Bumped version to 1.4.0-incubating-SNAPSHOT ### Modifications [INLONG-5639][Release] Bumped version to 1.4.0-incubating-SNA

[GitHub] [inlong] vernedeng commented on issue #4964: [Feature][Sort] Sort Standalone support parse InLongMsg

vernedeng commented on issue #4964: URL: https://github.com/apache/inlong/issues/4964#issuecomment-1223631967 I will get it done, assign it to me plz -- 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