[GitHub] [inlong] gosonzhang commented on a diff in pull request #7200: [INLONG-7199][Manager] Support save extension params for inlong cluster node

2023-01-09 Thread GitBox
gosonzhang commented on code in PR #7200: URL: https://github.com/apache/inlong/pull/7200#discussion_r1065439499 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeOperator.java: ## @@ -0,0 +1,89 @@ +/* + * Licensed to

[GitHub] [inlong] EMsnap opened a new pull request, #7203: [INLONG-7202][Sort] Fix Unit Tests ( including PostgreSql \ Hbase \ Elasticsearch ) in sort-core

2023-01-09 Thread GitBox
EMsnap opened a new pull request, #7203: URL: https://github.com/apache/inlong/pull/7203 ### Prepare a Pull Request - Fixes #7202 ### Motivation Fix Unit Tests ( including PostgreSql \ Hbase \ Elasticsearch ) in sort-core ### Modifications Relocate classes that

[GitHub] [inlong] woofyzhao commented on a diff in pull request #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7195: URL: https://github.com/apache/inlong/pull/7195#discussion_r1065439273 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java: ## @@ -268,4 +308,40 @@ public void processSen

[inlong] branch master updated (501cecb0b -> d6696aff7)

2023-01-09 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 501cecb0b [INLONG-7198][Sort] Support audit of Apache Hudi (#7181) add d6696aff7 [INLONG-7191][DataProxy] Re

[GitHub] [inlong] dockerzhang merged pull request #7192: [INLONG-7191][DataProxy] Remove unused code

2023-01-09 Thread GitBox
dockerzhang merged PR #7192: URL: https://github.com/apache/inlong/pull/7192 -- 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] woofyzhao commented on a diff in pull request #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7195: URL: https://github.com/apache/inlong/pull/7195#discussion_r1065436683 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java: ## @@ -268,4 +308,40 @@ public void processSen

[GitHub] [inlong] woofyzhao commented on a diff in pull request #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7195: URL: https://github.com/apache/inlong/pull/7195#discussion_r1065433543 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java: ## @@ -52,6 +68,10 @@ public class MessageQueu

[inlong] branch master updated: [INLONG-7198][Sort] Support audit of Apache Hudi (#7181)

2023-01-09 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 501cecb0b [INLONG-7198][Sort] Support audit

[GitHub] [inlong] dockerzhang merged pull request #7181: [INLONG-7198][Sort] Support audit of Apache Hudi

2023-01-09 Thread GitBox
dockerzhang merged PR #7181: URL: https://github.com/apache/inlong/pull/7181 -- 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] luchunliang commented on a diff in pull request #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
luchunliang commented on code in PR #7195: URL: https://github.com/apache/inlong/pull/7195#discussion_r1065419493 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java: ## @@ -268,4 +308,40 @@ public void processS

[GitHub] [inlong] luchunliang commented on a diff in pull request #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
luchunliang commented on code in PR #7195: URL: https://github.com/apache/inlong/pull/7195#discussion_r1065414401 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java: ## @@ -268,4 +308,40 @@ public void processS

[GitHub] [inlong] pocozh commented on a diff in pull request #7193: [INLONG-7175][Agent] Support PostgreSQL Source

2023-01-09 Thread GitBox
pocozh commented on code in PR #7193: URL: https://github.com/apache/inlong/pull/7193#discussion_r1065294236 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/PostgresJob.java: ## @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[GitHub] [inlong] healchow commented on a diff in pull request #7200: [INLONG-7199][Manager] Support save extension params for inlong cluster node

2023-01-09 Thread GitBox
healchow commented on code in PR #7200: URL: https://github.com/apache/inlong/pull/7200#discussion_r1065292562 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeResponse.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apa

[GitHub] [inlong-website] bluewang opened a new issue, #669: [Improve][Doc] Documentation screenshot update

2023-01-09 Thread GitBox
bluewang opened a new issue, #669: URL: https://github.com/apache/inlong-website/issues/669 ### Description _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Co

[GitHub] [inlong] fuweng11 opened a new pull request, #7200: [INLONG-7199][Manager] Support save extension params for inlong cluster node

2023-01-09 Thread GitBox
fuweng11 opened a new pull request, #7200: URL: https://github.com/apache/inlong/pull/7200 ### Prepare a Pull Request - Fixes #7199 ### Motivation Support save extension params for inlong cluster node ### Modifications Support save extension params for

[inlong] 02/07: [INLONG-7182][TubeMQ] Replace ParamCheckResult with ProcessResult (#7183)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit f06a60a40c43ab8e9dbc4b6def0b89089a708b41 Author: Goson Zhang <4675...@qq.com> AuthorDate: Sat Jan 7 23:05:16 202

[inlong] 03/07: [INLONG-7184][TubeMQ] Replace CertifiedResult with ProcessResult (#7185)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 6cc584bbc8941814ba2b4f95329a2443ba043a7d Author: Goson Zhang <4675...@qq.com> AuthorDate: Sun Jan 8 20:31:23 202

[inlong] 04/07: [INLONG-5776][Manager] Add tenant param to InlongGroup that uses Pulsar (#7171)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 61ce6e296a0fce5cec2fc4c4adc9b7761340e1ef Author: healchow AuthorDate: Sun Jan 8 22:28:56 2023 +0800 [INLON

[inlong] 06/07: [INLONG-7186][Sort] Fix time zone incorrect (#7187)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 3652e39734c226cb8f079a4bf8c69228b1a1cb17 Author: emhui <111486498+e-m...@users.noreply.github.com> AuthorDate: M

[inlong] 01/07: [INLONG-7178][Manager] Optimize parameter checks for InlongGroup, and simplify the exception and log info (#7180)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit d2ef5877872016e40da8b836451cc6134ce1029f Author: Goson Zhang <4675...@qq.com> AuthorDate: Sat Jan 7 13:14:19 202

[inlong] 07/07: [INLONG-7190][Dashboard] New data subscription optimization (#7196)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit b5f562144652509512fd6bfef95006ae1c417364 Author: Lizhen <88174078+bluew...@users.noreply.github.com> AuthorDate:

[inlong] branch branch-1.5 updated (e719c62b5 -> b5f562144)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git from e719c62b5 [INLONG-7163][Dashboard] Data subscription addition and details page optimization (#7179) ne

[inlong] 05/07: [INLONG-7188][Doc] Change the project Copyright to 2019-2023 (#7189)

2023-01-09 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 7d69c0e4ca5b474f1fdb3da6538c69977858b05a Author: Goson Zhang <4675...@qq.com> AuthorDate: Mon Jan 9 09:43:46 202

[inlong] branch master updated: [INLONG-7190][Dashboard] New data subscription optimization (#7196)

2023-01-09 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 bbfae1c76 [INLONG-7190][Dashboard] New data

[GitHub] [inlong] dockerzhang merged pull request #7196: [INLONG-7190][Dashboard] New data subscription optimization

2023-01-09 Thread GitBox
dockerzhang merged PR #7196: URL: https://github.com/apache/inlong/pull/7196 -- 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] leezng commented on a diff in pull request #7196: [INLONG-7190][Dashboard] New data subscription optimization

2023-01-09 Thread GitBox
leezng commented on code in PR #7196: URL: https://github.com/apache/inlong/pull/7196#discussion_r1064500548 ## inlong-dashboard/src/metas/consumes/common/ConsumeDefaultInfo.ts: ## @@ -73,6 +73,7 @@ export class ConsumeDefaultInfo implements DataWithBackend, RenderRow, RenderLi

[GitHub] [inlong] leezng commented on a diff in pull request #7196: [INLONG-7190][Dashboard] New data subscription optimization

2023-01-09 Thread GitBox
leezng commented on code in PR #7196: URL: https://github.com/apache/inlong/pull/7196#discussion_r1064500548 ## inlong-dashboard/src/metas/consumes/common/ConsumeDefaultInfo.ts: ## @@ -73,6 +73,7 @@ export class ConsumeDefaultInfo implements DataWithBackend, RenderRow, RenderLi

[GitHub] [inlong] bluewang opened a new pull request, #7196: [INLONG-7190][Dashboard] New data subscription optimization

2023-01-09 Thread GitBox
bluewang opened a new pull request, #7196: URL: https://github.com/apache/inlong/pull/7196 ### 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 replace

[GitHub] [inlong] woofyzhao opened a new pull request, #7195: [INLONG-7194][DataProxy] Add index log statistics for MQ sink

2023-01-09 Thread GitBox
woofyzhao opened a new pull request, #7195: URL: https://github.com/apache/inlong/pull/7195 #Fix7194 ### Motivation Missing old index log statistics for simple events. Migrate the old logic from pulsar sink and tube sink. -- This is an automated message from the Apache Git S

[GitHub] [inlong] haifxu opened a new pull request, #7193: [INLONG-7175][Agent] Support PostgreSQL Source

2023-01-09 Thread GitBox
haifxu opened a new pull request, #7193: URL: https://github.com/apache/inlong/pull/7193 ### Prepare a Pull Request - Fixes #7174 ### Motivation Support converting DataConfig to TriggerProfile for PostgreSQL. ### Modifications Add `PostgresJob` and `POSTGRE

[GitHub] [inlong] woofyzhao commented on a diff in pull request #7192: [INLONG-7191][DataProxy] Remove unused code

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7192: URL: https://github.com/apache/inlong/pull/7192#discussion_r1064373794 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/EventStat.java: ## @@ -1,81 +0,0 @@ -/* - * Licensed to the Apache Software Foundat

[GitHub] [inlong] woofyzhao commented on a diff in pull request #7192: [INLONG-7191][DataProxy] Remove unused code

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7192: URL: https://github.com/apache/inlong/pull/7192#discussion_r1064373794 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/EventStat.java: ## @@ -1,81 +0,0 @@ -/* - * Licensed to the Apache Software Foundat

[GitHub] [inlong] woofyzhao commented on a diff in pull request #7192: [INLONG-7191][DataProxy] Remove unused code

2023-01-09 Thread GitBox
woofyzhao commented on code in PR #7192: URL: https://github.com/apache/inlong/pull/7192#discussion_r1064373794 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/EventStat.java: ## @@ -1,81 +0,0 @@ -/* - * Licensed to the Apache Software Foundat

[GitHub] [inlong] healchow commented on a diff in pull request #7192: [INLONG-7191][DataProxy] Remove unused code

2023-01-09 Thread GitBox
healchow commented on code in PR #7192: URL: https://github.com/apache/inlong/pull/7192#discussion_r1064370219 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/EventStat.java: ## @@ -1,81 +0,0 @@ -/* - * Licensed to the Apache Software Foundati