Re: [PR] [INLONG-10944][SDK] Support Inlong Transform parser annotation [inlong]

2024-08-29 Thread via GitHub
emptyOVO commented on code in PR #10945: URL: https://github.com/apache/inlong/pull/10945#discussion_r1735672712 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ParserTools.java: ## @@ -0,0 +1,64 @@ +package org.apache.inlong.sdk.transfor

Re: [PR] [INLONG-10944][SDK] Support Inlong Transform parser annotation [inlong]

2024-08-29 Thread via GitHub
vernedeng commented on code in PR #10945: URL: https://github.com/apache/inlong/pull/10945#discussion_r1735695332 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/TransformParser.java: ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Sof

[PR] [INLONG-10947][Dashboard] Modify field description missing for English locale [inlong]

2024-08-29 Thread via GitHub
wohainilaodou opened a new pull request, #10948: URL: https://github.com/apache/inlong/pull/10948 Fixes #10947 ### Motivation Modify field description missing for English locale ### Modifications Modify field description missing for English locale #

Re: [PR] [INLONG-10931][Manager] Data preview supports data containing escape characters [inlong]

2024-08-29 Thread via GitHub
aloyszhang merged PR #10932: URL: https://github.com/apache/inlong/pull/10932 -- 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 (4cf7ccba60 -> 6ba319369e)

2024-08-29 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 4cf7ccba60 [INLONG-10847][Dashboard] Agent type cluster node management adds restart、reinstall, install log 、hear

Re: [PR] [INLONG-10944][SDK] Support Inlong Transform parser annotation [inlong]

2024-08-29 Thread via GitHub
emptyOVO commented on code in PR #10945: URL: https://github.com/apache/inlong/pull/10945#discussion_r1735712254 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/TransformParser.java: ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Soft

[PR] [INLONG-10946][SDK] Transform SQL supports SPACE function [inlong]

2024-08-29 Thread via GitHub
Zkplo opened a new pull request, #10949: URL: https://github.com/apache/inlong/pull/10949 Fixes #10946 ### Motivation Add one function classe: SpaceFunction. Also, add the corresponding unit test codes. ### Modifications ### Verifying this

[PR] [INLONG-10940][SDK] Transform SQL support arithmetic functions(Including cot, tanh, cosh, asin, atan and atan2) [inlong]

2024-08-29 Thread via GitHub
MOONSakura0614 opened a new pull request, #10950: URL: https://github.com/apache/inlong/pull/10950 Fixes #10940 ### Motivation Add six arithmetic function classes: CotFunction, TanhFunction, CoshFunction, AsinFunction, AtanFunction and Atan2Function. Also, add the

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-29 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1735782184 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,169 @@ package org.apache.inlong.agent.plugin

[PR] [INLONG-10934][SDK] Transform support LocalDate function [inlong]

2024-08-29 Thread via GitHub
ying-hua opened a new pull request, #10951: URL: https://github.com/apache/inlong/pull/10951 Fixes #10934 ### Motivation - Add a function class: LocalDateFunction and its unit tests. - LocalDate([string1]) Returns the local date in the time zone string1

Re: [PR] [INLONG-10947][Dashboard] Modify field description missing for English locale [inlong]

2024-08-29 Thread via GitHub
aloyszhang merged PR #10948: URL: https://github.com/apache/inlong/pull/10948 -- 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-10947][Dashboard] Modify field description missing for English locale (#10948)

2024-08-29 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang 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 1b62fdd49e [INLONG-10947][Dashboard] Modify

Re: [PR] [INLONG-10883][SDK] Transform SQL support InitCap function [inlong]

2024-08-29 Thread via GitHub
dockerzhang commented on PR #10892: URL: https://github.com/apache/inlong/pull/10892#issuecomment-2317051155 @MOONSakura0614 please fix the conflicts and failed workflows. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [INLONG-10893][SDK] Transform SQL support FromBase64 function [inlong]

2024-08-29 Thread via GitHub
dockerzhang commented on PR #10896: URL: https://github.com/apache/inlong/pull/10896#issuecomment-2317050159 @MOONSakura0614 please fix the conflicts and failed workflows. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [INLONG-10940][SDK] Transform SQL support arithmetic functions(Including cot, tanh, cosh, asin, atan and atan2) [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on code in PR #10950: URL: https://github.com/apache/inlong/pull/10950#discussion_r1735884683 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/CotFunction.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache Soft

[I] [Bug][Doc] Wrong referring to StarRocks [inlong-website]

2024-08-29 Thread via GitHub
aloyszhang opened a new issue, #970: URL: https://github.com/apache/inlong-website/issues/970 ### What happened mysql_starrocks_example page is referring to StarRocks as Apache StarRocks incorrectly. ### What you expected to happen StarRocks instead of Apache St

[PR] [INLONG-970][Doc] fix the wrong referring to StarRocks [inlong-website]

2024-08-29 Thread via GitHub
aloyszhang opened a new pull request, #971: URL: https://github.com/apache/inlong-website/pull/971 Fixes #970 ### Motivation ### Modifications current `Apache starrocks` to `Starrocks` ### Verifying this change - [ ] Make sure that the change pa

Re: [I] [Improve][Doc] Add excalidraw raw file directory [inlong-website]

2024-08-29 Thread via GitHub
aloyszhang closed issue #968: [Improve][Doc] Add excalidraw raw file directory URL: https://github.com/apache/inlong-website/issues/968 -- 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 co

(inlong-website) branch master updated: [INLONG-968][Doc] Add excalidraw raw file directories (#969)

2024-08-29 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang 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 07fdec66a2 [INLONG-968][Doc] Add exc

Re: [PR] [INLONG-968][Doc] Add excalidraw raw file directories [inlong-website]

2024-08-29 Thread via GitHub
aloyszhang merged PR #969: URL: https://github.com/apache/inlong-website/pull/969 -- 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...@in

Re: [PR] [INLONG-970][Doc] fix the wrong referring to StarRocks [inlong-website]

2024-08-29 Thread via GitHub
dockerzhang merged PR #971: URL: https://github.com/apache/inlong-website/pull/971 -- 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] [Bug][Doc] Wrong referring to StarRocks [inlong-website]

2024-08-29 Thread via GitHub
dockerzhang closed issue #970: [Bug][Doc] Wrong referring to StarRocks URL: https://github.com/apache/inlong-website/issues/970 -- 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.

(inlong-website) branch master updated: [INLONG-970][Doc] fix the wrong referring to StarRocks (#971)

2024-08-29 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 387b07f85f [INLONG-970][Doc] fix th

Re: [PR] [INLONG-10897][SDK] Transform support DATEDIFF function [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on code in PR #10925: URL: https://github.com/apache/inlong/pull/10925#discussion_r1735987352 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateDiffFunction.java: ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-10942][SDK] Add official function names for all Transform functions [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on PR #10943: URL: https://github.com/apache/inlong/pull/10943#issuecomment-2317316437 Where is the source of truth for "official function names", and any specifications for it? -- This is an automated message from the Apache Git Service. To respond to the message, pl

Re: [PR] [INLONG-10902][SDK] Transform support HEX(numeric or string) function [inlong]

2024-08-29 Thread via GitHub
vernedeng commented on code in PR #10904: URL: https://github.com/apache/inlong/pull/10904#discussion_r1736010161 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/HexFunction.java: ## @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Softw

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1736049185 ## inlong-manager/manager-plugins/base/src/main/resources/flink-sort-plugin.properties: ## @@ -35,3 +35,7 @@ flink.savepoint.directory=file:///data/inlong-sort/save

Re: [PR] [INLONG-10902][SDK] Transform support HEX(numeric or string) function [inlong]

2024-08-29 Thread via GitHub
emptyOVO commented on code in PR #10904: URL: https://github.com/apache/inlong/pull/10904#discussion_r1736065655 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/HexFunction.java: ## @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1736084213 ## inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/consts/OpenApiConstants.java: ## @@ -15,7 +15,7 @@ * limitations under the License. */ -pac

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1736084213 ## inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/consts/OpenApiConstants.java: ## @@ -15,7 +15,7 @@ * limitations under the License. */ -pac

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on PR #10916: URL: https://github.com/apache/inlong/pull/10916#issuecomment-2317478140 @fuweng11 There are some modifications in the manager module, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [INLONG-10946][SDK] Transform SQL supports SPACE function [inlong]

2024-08-29 Thread via GitHub
aloyszhang merged PR #10949: URL: https://github.com/apache/inlong/pull/10949 -- 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

Re: [PR] [INLONG-10934][SDK] Transform support LocalDate function [inlong]

2024-08-29 Thread via GitHub
aloyszhang merged PR #10951: URL: https://github.com/apache/inlong/pull/10951 -- 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-10934][SDK] Transform support LocalDate function (#10951)

2024-08-29 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang 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 f35ab6f619 [INLONG-10934][SDK] Transform sup

(inlong) branch master updated (1b62fdd49e -> a9719038f1)

2024-08-29 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 1b62fdd49e [INLONG-10947][Dashboard] Modify field description missing for English locale (#10948) add a97190

Re: [PR] [INLONG-10939][SDK] Transform SQL supports STRCMP function [inlong]

2024-08-29 Thread via GitHub
dockerzhang merged PR #10941: URL: https://github.com/apache/inlong/pull/10941 -- 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-10939][SDK] Transform SQL supports STRCMP function (#10941)

2024-08-29 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 7cfbf8a74b [INLONG-10939][SDK] Transform SQ

Re: [PR] [INLONG-10935][SDK] Transform support DAYNAME function [inlong]

2024-08-29 Thread via GitHub
aloyszhang commented on PR #10937: URL: https://github.com/apache/inlong/pull/10937#issuecomment-2319692262 @ying-hua please resolve the conflict. -- 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

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737670802 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737673199 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737676926 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737677041 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737678355 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737681783 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737681783 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on PR #10916: URL: https://github.com/apache/inlong/pull/10916#issuecomment-2319745536 When a group is a real-time synchronization task, there is no dataproxy present. How to handle this situation. -- This is an automated message from the Apache Git Service. To respond

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737708162 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737719535 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737738348 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to t

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on PR #10916: URL: https://github.com/apache/inlong/pull/10916#issuecomment-2319790130 > When a group is a real-time synchronization task, there is no dataproxy present. How to handle this situation.Is there a default value when dataproxy does not exist? When no au

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on PR #10916: URL: https://github.com/apache/inlong/pull/10916#issuecomment-2319808998 ![9e8f6992-bb82-40f3-99b1-1445cea9f45b](file:///D:/%E5%9B%BE%E7%89%87/Typedown/9e8f6992-bb82-40f3-99b1-1445cea9f45b.png) Effect of adjusting parallelism is shown in the picture. (Fail

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737778216 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java: ## @@ -213,6 +218,22 @@ private String submitJobBySavep

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
PeterZh6 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737802253 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java: ## @@ -213,6 +218,22 @@ private String submitJobBySavep

Re: [PR] [INLONG-7056][Sort] Adjust sort resources according to data scale [inlong]

2024-08-29 Thread via GitHub
fuweng11 commented on code in PR #10916: URL: https://github.com/apache/inlong/pull/10916#discussion_r1737830177 ## inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java: ## @@ -213,6 +218,22 @@ private String submitJobBySavep

Re: [PR] [INLONG-10935][SDK] Transform support DAYNAME function [inlong]

2024-08-29 Thread via GitHub
ying-hua commented on PR #10937: URL: https://github.com/apache/inlong/pull/10937#issuecomment-2320046925 > @ying-hua please resolve the conflict. done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab