[GitHub] [inlong] leezng opened a new pull request, #5902: [INLONG-5901][Dashboard] Unified sinks type definition

leezng opened a new pull request, #5902: URL: https://github.com/apache/inlong/pull/5902 - Fixes #5901 -- 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] dockerzhang commented on a diff in pull request #5852: [INLONG-5851][TubeMQ] Optimize while-sleep to ScheduledExecutorService

dockerzhang commented on code in PR #5852: URL: https://github.com/apache/inlong/pull/5852#discussion_r971740319 ## inlong-tubemq/tubemq-manager/pom.xml: ## @@ -176,6 +176,11 @@ jakarta.validation jakarta.validation-api + +io.net

[GitHub] [inlong] dockerzhang commented on pull request #5852: [INLONG-5851][TubeMQ] Optimize while-sleep to ScheduledExecutorService

dockerzhang commented on PR #5852: URL: https://github.com/apache/inlong/pull/5852#issuecomment-1247829521 please remove the LICENSE-netty.txt and NOTICE-netty.txt file. for apache license dependency, you can add it to LICENSE file directly. you can refer to the [netty-common](https://gi

[GitHub] [inlong] dockerzhang merged pull request #5902: [INLONG-5901][Dashboard] Unified sinks type definition

dockerzhang merged PR #5902: URL: https://github.com/apache/inlong/pull/5902 -- 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] ly100120 commented on issue #5110: [Bug][DataProxy] DataProxy is not sending data to Pulsar

ly100120 commented on issue #5110: URL: https://github.com/apache/inlong/issues/5110#issuecomment-1248013888 这个问题你是否已经解决？我碰到了同样的问题，束手无策。1.4.0版本 -- 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] haifxu opened a new pull request, #5905: [INLONG-5904][Manager] Add manager client packages into lib directory

haifxu opened a new pull request, #5905: URL: https://github.com/apache/inlong/pull/5905 ### Prepare a Pull Request - Fixes #5904 ### Motivation  ### Mo

[GitHub] [inlong] thesumery opened a new pull request, #5906: [INLONG-5903][Sort] Make InLong metric constructs factory more cohesive

thesumery opened a new pull request, #5906: URL: https://github.com/apache/inlong/pull/5906 ### Prepare a Pull Request *(Change the title refer to the following example)* *[INLONG-5903][Sort] Make InLong metric constructs factory more cohesive* *(The following *XYZ* should be

[GitHub] [inlong] woofyzhao commented on pull request #5898: [INLONG-5897][Manager] Support query audit data by user role

woofyzhao commented on PR #5898: URL: https://github.com/apache/inlong/pull/5898#issuecomment-1248050074 > 1.Explain why users only pay attention to AUDIT_ID_DATAPROXY_RECEIVED and AUDIT_ID_SORT_OUTPUT? 2.It is suggested that querying audit views based on roles is only a default behavior. U

[GitHub] [inlong] healchow commented on a diff in pull request #5898: [INLONG-5897][Manager] Support query audit data by user role

healchow commented on code in PR #5898: URL: https://github.com/apache/inlong/pull/5898#discussion_r971968846 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java: ## @@ -70,12 +78,21 @@ public class AuditServiceImpl i

[GitHub] [inlong] liangyepianzhou opened a new pull request, #5908: [INLONG-5907][TubeMQ] Replace the while-sleep with ScheduledExecutorService for tube server loopProcess

liangyepianzhou opened a new pull request, #5908: URL: https://github.com/apache/inlong/pull/5908 ### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/5907 ### Motivation it is not recommended to execute a scheduled task by while-sleep. ### Modificat

[GitHub] [inlong-website] vernedeng opened a new issue, #560: [Feature][SortStandalone] Update SortStandalone docs

vernedeng opened a new issue, #560: URL: https://github.com/apache/inlong-website/issues/560 ### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct

[GitHub] [inlong-website] vernedeng opened a new pull request, #561: [INLONG-560][Doc] Update sort-standalone docs

vernedeng opened a new pull request, #561: URL: https://github.com/apache/inlong-website/pull/561 ### 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

[GitHub] [inlong] GanfengTan opened a new pull request, #5910: [INLONG-5909][Agent] Fix WatchService is no effect in the k8s

GanfengTan opened a new pull request, #5910: URL: https://github.com/apache/inlong/pull/5910 Fix WatchService is no effect in the k8s. - Fixes #5909 ### Motivation Trigger a new task when Data changes, for example: add data. ### Modifications Validate the

[GitHub] [inlong] dockerzhang merged pull request #5900: [INLONG-5899][DataProxy] Optimize Http's SimpleMessageHandler class

dockerzhang merged PR #5900: URL: https://github.com/apache/inlong/pull/5900 -- 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-5899][DataProxy] Optimize Http's SimpleMessageHandler class (#5900)

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 c5b9319a8 [INLONG-5899][DataProxy] Optimize

[GitHub] [inlong] woofyzhao commented on a diff in pull request #5898: [INLONG-5897][Manager] Support query audit data by user role

woofyzhao commented on code in PR #5898: URL: https://github.com/apache/inlong/pull/5898#discussion_r972549615 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java: ## @@ -70,12 +78,21 @@ public class AuditServiceImpl

[GitHub] [inlong] leezng opened a new pull request, #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

leezng opened a new pull request, #5912: URL: https://github.com/apache/inlong/pull/5912 - Fixes #5911 -- 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] vernedeng opened a new issue, #562: [Feature][Doc] Add more source and sink examples of sort-standalone

vernedeng opened a new issue, #562: URL: https://github.com/apache/inlong-website/issues/562 ### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct

[GitHub] [inlong] GanfengTan commented on a diff in pull request #5780: [INLONG-5722][Agent] Support Redis Source

GanfengTan commented on code in PR #5780: URL: https://github.com/apache/inlong/pull/5780#discussion_r972564411 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/RedisReader.java: ## @@ -0,0 +1,445 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [inlong] vernedeng commented on a diff in pull request #5802: [INLONG-5495][SDK] Support multi-topic manager

vernedeng commented on code in PR #5802: URL: https://github.com/apache/inlong/pull/5802#discussion_r972565660 ## inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java: ## @@ -0,0 +1,289 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [inlong-website] dockerzhang commented on a diff in pull request #559: [INLONG-551][Doc] Update release doc and fix bugs

dockerzhang commented on code in PR #559: URL: https://github.com/apache/inlong-website/pull/559#discussion_r972571927 ## i18n/zh-CN/docusaurus-plugin-content-docs-community/current/how-to-release.md: ## @@ -405,7 +405,8 @@ svn delete https://dist.apache.org/repos/dist/release/

[GitHub] [inlong] gong commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

gong commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972572495 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/InfluxDBLoadNode.java: ## @@ -0,0 +1,111 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5906: [INLONG-5903][Sort] Make InLong metric constructs factory more cohesive

yunqingmoswu commented on code in PR #5906: URL: https://github.com/apache/inlong/pull/5906#discussion_r972569971 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java: ## @@ -55,21 +56,40 @@ public class SinkMetricData implemen

[GitHub] [inlong] dockerzhang commented on a diff in pull request #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

dockerzhang commented on code in PR #5912: URL: https://github.com/apache/inlong/pull/5912#discussion_r972579420 ## inlong-dashboard/src/locales/cn.json: ## @@ -196,16 +196,16 @@ "meta.Group.MessageMiddleware": "消息中间件", "meta.Group.AccessSize": "按天接入大小", "meta.Group.GB/

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

yunqingmoswu commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972577506 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java: ## @@ -72,7 +73,8 @@ @JsonSubTypes.Type(value = OracleLoadNode.

[GitHub] [inlong] yunqingmoswu commented on pull request #5864: [INLONG-5863][Manager] Extend Redis extract node

yunqingmoswu commented on PR #5864: URL: https://github.com/apache/inlong/pull/5864#issuecomment-1248880798 > If you want to use redis extract node in sort, you must implement the protocol of sort with redis, see `org.apache.inlong.manager.pojo.sort.util.ExtractNodeUtils` -- This is an a

[GitHub] [inlong] yunqingmoswu commented on pull request #5864: [INLONG-5863][Manager] Extend Redis extract node

yunqingmoswu commented on PR #5864: URL: https://github.com/apache/inlong/pull/5864#issuecomment-1248881910 > > Maybe miss the part that interacts with the sort protocol？ > > I follow the [extend ExtractNode](https://inlong.apache.org/zh-CN/docs/design_and_concept/how_to_extend_data_n

[GitHub] [inlong-website] bluewang commented on pull request #387: [INLONG-1831][Website] Add official website content search button

bluewang commented on PR #387: URL: https://github.com/apache/inlong-website/pull/387#issuecomment-1248886800 > @dockerzhang @bluewang @leezng I found the search engine seems do not to work. Let me check it. Is there any progress on this situation? -- This is an automated message f

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5774: [INLONG-5133][Sort] Support Apache InfluxDB source

yunqingmoswu commented on code in PR #5774: URL: https://github.com/apache/inlong/pull/5774#discussion_r972586581 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/ExtractNode.java: ## @@ -62,7 +63,8 @@ @JsonSubTypes.Type(value = TubeMQExtrac

[GitHub] [inlong] healchow commented on a diff in pull request #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

healchow commented on code in PR #5912: URL: https://github.com/apache/inlong/pull/5912#discussion_r972588612 ## inlong-dashboard/src/locales/cn.json: ## @@ -411,7 +411,7 @@ "pages.ConsumeDashboard.config.Total": "消费总数", "pages.ConsumeDashboard.config.Pending": "待审批", "

[GitHub] [inlong] dockerzhang commented on a diff in pull request #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

dockerzhang commented on code in PR #5912: URL: https://github.com/apache/inlong/pull/5912#discussion_r972588846 ## inlong-dashboard/src/locales/cn.json: ## @@ -411,7 +411,7 @@ "pages.ConsumeDashboard.config.Total": "消费总数", "pages.ConsumeDashboard.config.Pending": "待审批",

[GitHub] [inlong] liangyepianzhou commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

liangyepianzhou commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972589473 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java: ## @@ -72,7 +73,8 @@ @JsonSubTypes.Type(value = OracleLoadNo

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

yunqingmoswu commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972593293 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java: ## @@ -72,7 +73,8 @@ @JsonSubTypes.Type(value = OracleLoadNode.

[GitHub] [inlong] dockerzhang commented on a diff in pull request #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

dockerzhang commented on code in PR #5912: URL: https://github.com/apache/inlong/pull/5912#discussion_r972603846 ## inlong-dashboard/src/locales/cn.json: ## @@ -411,7 +411,7 @@ "pages.ConsumeDashboard.config.Total": "消费总数", "pages.ConsumeDashboard.config.Pending": "待审批",

[GitHub] [inlong] gosonzhang opened a new pull request, #5916: [INLONG-5915][DataProxy] Optimize source's ServerMessageHandler class

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

[GitHub] [inlong] dockerzhang merged pull request #5912: [INLONG-5911][Dashboard] Modify the data group name to the data stream group

dockerzhang merged PR #5912: URL: https://github.com/apache/inlong/pull/5912 -- 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-5911][Dashboard] Modify the data group name to the data stream group (#5912)

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 3e6a1c80f [INLONG-5911][Dashboard] Modify t

[GitHub] [inlong-website] Chever-John commented on pull request #387: [INLONG-1831][Website] Add official website content search button

Chever-John commented on PR #387: URL: https://github.com/apache/inlong-website/pull/387#issuecomment-1248950575 @bluewang Give me a few days, I'll give it a try. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [inlong] liangyepianzhou commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

liangyepianzhou commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972641320 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java: ## @@ -72,7 +73,8 @@ @JsonSubTypes.Type(value = OracleLoadNo

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

yunqingmoswu commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972651568 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java: ## @@ -72,7 +73,8 @@ @JsonSubTypes.Type(value = OracleLoadNode.

[GitHub] [inlong-website] bluewang commented on pull request #387: [INLONG-1831][Website] Add official website content search button

bluewang commented on PR #387: URL: https://github.com/apache/inlong-website/pull/387#issuecomment-1248966203 > @bluewang Give me a few days, I'll give it a try. @Chever-John OK. Waiting for your good news -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [inlong] EMsnap commented on a diff in pull request #5785: [INLONG-5784][Sort] Add metric state for PostgreSQL

EMsnap commented on code in PR #5785: URL: https://github.com/apache/inlong/pull/5785#discussion_r972656995 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/util/MetricStateUtils.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [inlong] iamsee123 commented on pull request #5864: [INLONG-5863][Manager] Extend Redis extract node

iamsee123 commented on PR #5864: URL: https://github.com/apache/inlong/pull/5864#issuecomment-1248968819 > > > Maybe miss the part that interacts with the sort protocol？ > > > > > > I follow the [extend ExtractNode](https://inlong.apache.org/zh-CN/docs/design_and_concept/how_to_ex

[GitHub] [inlong] luchunliang commented on a diff in pull request #5843: [INLONG-5842][Manager] Support maintenance of message queue cluster

luchunliang commented on code in PR #5843: URL: https://github.com/apache/inlong/pull/5843#discussion_r972667887 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/queue/MessageQueueServiceImpl.java: ## @@ -0,0 +1,555 @@ +/* + * Licensed to

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #5879: [INLONG-5133][Sort] Support influxDB sink for sort

yunqingmoswu commented on code in PR #5879: URL: https://github.com/apache/inlong/pull/5879#discussion_r972673256 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/InfluxDBLoadNode.java: ## @@ -0,0 +1,111 @@ +/* + * Licensed to the Apache Softwar