aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734086343
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734084791
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java:
##
@@ -69,13 +70,20 @@ public class FlinkService {
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734080384
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734078087
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734077509
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkParallelismOptimizer.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734075358
##
inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/consts/OpenApiConstants.java:
##
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-pac
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734072686
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/enums/Constants.java:
##
@@ -43,6 +43,10 @@ public class Constants {
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734072686
##
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/enums/Constants.java:
##
@@ -43,6 +43,10 @@ public class Constants {
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734071646
##
inlong-manager/manager-plugins/base/src/main/resources/flink-sort-plugin.properties:
##
@@ -35,3 +35,7 @@ flink.savepoint.directory=file:///data/inlong-sort/save
aloyszhang commented on code in PR #10916:
URL: https://github.com/apache/inlong/pull/10916#discussion_r1734070903
##
inlong-manager/manager-plugins/base/src/main/resources/flink-sort-plugin.properties:
##
@@ -35,3 +35,7 @@ flink.savepoint.directory=file:///data/inlong-sort/save
yfsn666 commented on code in PR #10928:
URL: https://github.com/apache/inlong/pull/10928#discussion_r1734057548
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RpadFunction.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Softwa
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 389b41d81b [INLONG-10879][SDK] Transform sup
aloyszhang merged PR #10880:
URL: https://github.com/apache/inlong/pull/10880
--
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
aloyszhang merged PR #10885:
URL: https://github.com/apache/inlong/pull/10885
--
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
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 ffd5f1b43b [INLONG-10872][SDK] Add a More Co
Zkplo commented on code in PR #10925:
URL: https://github.com/apache/inlong/pull/10925#discussion_r1734005023
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateDiffFunction.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Soft
Zkplo opened a new pull request, #10928:
URL: https://github.com/apache/inlong/pull/10928
Fixes #10927
### Motivation
Add two function classes: RpadFunction and LpadFunction. Also, add the
corresponding unit test codes.
### Modifications
#
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 fab6756556 [INLONG-10906][SDK] Transform supports the truncation of
left and right strings (#10923)
add 268a
aloyszhang merged PR #10924:
URL: https://github.com/apache/inlong/pull/10924
--
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
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 fab6756556 [INLONG-10906][SDK] Transform sup
aloyszhang merged PR #10923:
URL: https://github.com/apache/inlong/pull/10923
--
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
yfsn666 commented on code in PR #10925:
URL: https://github.com/apache/inlong/pull/10925#discussion_r1733910325
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateDiffFunction.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache So
wohainilaodou opened a new pull request, #10926:
URL: https://github.com/apache/inlong/pull/10926
Fixes #10847
### Motivation
Agent type cluster node management adds restart、reinstall, install log
、heartbeat detection and unLoad operations
### Modifications
aloyszhang commented on code in PR #10891:
URL: https://github.com/apache/inlong/pull/10891#discussion_r1733815922
##
inlong-agent/bin/agent-env.sh:
##
@@ -45,17 +46,19 @@ else
fi
if [ -z "$AGENT_JVM_HEAP_OPTS" ]; then
- HEAP_OPTS="-Xmx512m -Xss512k"
+ HEAP_OPTS=" -Xmx2048
Zkplo opened a new pull request, #10925:
URL: https://github.com/apache/inlong/pull/10925
Fixes #10897
### Motivation
Add one function classe: DateDiffFunction. Also, add the corresponding unit
test codes.
### Verifying this change
*(Please pi
aloyszhang commented on issue #10866:
URL: https://github.com/apache/inlong/issues/10866#issuecomment-2313937118
Hi, @Zkplo
FYI, if there is something wrong with your branch, you can rebase the master
again and force push to your branch. It does not need to open a brand-new pull
request.
github-actions[bot] commented on issue #10464:
URL: https://github.com/apache/inlong/issues/10464#issuecomment-2313936032
This issue is stale because it has been open for 60 days with no activity.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
lianghuan-xatu commented on code in PR #10863:
URL: https://github.com/apache/inlong/pull/10863#discussion_r1733171966
##
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformStringFunctionsProcessor.java:
##
@@ -200,4 +200,31 @@ public voi
lianghuan-xatu commented on code in PR #10863:
URL: https://github.com/apache/inlong/pull/10863#discussion_r1733172577
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TranslateFunction.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the A
Zkplo commented on code in PR #10865:
URL: https://github.com/apache/inlong/pull/10865#discussion_r1732892078
##
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformArithmeticFunctionsProcessor.java:
##
@@ -55,6 +55,39 @@ public class Test
Zkplo opened a new pull request, #10924:
URL: https://github.com/apache/inlong/pull/10924
Fixes #10866
### Motivation
Add one arithmetic function classe: SignFunction. Also, add the
corresponding unit test codes.
### Modifications
### Veri
Zkplo commented on code in PR #10865:
URL: https://github.com/apache/inlong/pull/10865#discussion_r1732879700
##
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformArithmeticFunctionsProcessor.java:
##
@@ -55,6 +55,39 @@ public class Test
Zkplo commented on code in PR #10865:
URL: https://github.com/apache/inlong/pull/10865#discussion_r1732878905
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/Md5Function.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software
Zkplo closed pull request #10868: [INLONG-10866][SDK] Transform SQL support
sign function
URL: https://github.com/apache/inlong/pull/10868
--
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 specifi
aloyszhang commented on PR #10868:
URL: https://github.com/apache/inlong/pull/10868#issuecomment-2312402333
I'm afraid there is something wrong when rebasing the master, please do it
the right way.
Zkplo opened a new pull request, #10923:
URL: https://github.com/apache/inlong/pull/10923
Fixes #10906
### Motivation
Add two function classes: LeftFunction and RightFunction. Also, add the
corresponding unit test codes.
### Modifications
This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a commit to branch release-1.11.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/release-1.11.0 by this push:
new a71e5e81c1 [INLONG-9706][Man
aloyszhang merged PR #10852:
URL: https://github.com/apache/inlong/pull/10852
--
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
aloyszhang commented on issue #9706:
URL: https://github.com/apache/inlong/issues/9706#issuecomment-2312345979
backport to branch-1.10 in https://github.com/apache/inlong/pull/10852
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
This is an automated email from the ASF dual-hosted git repository.
luchunliang 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 de1189f732 [INLONG-10869][SDK] Transform SQ
luchunliang merged PR #10922:
URL: https://github.com/apache/inlong/pull/10922
--
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
luchunliang merged PR #10878:
URL: https://github.com/apache/inlong/pull/10878
--
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
This is an automated email from the ASF dual-hosted git repository.
luchunliang 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 916e6c1532 [INLONG-10920][SDK] Transform su
This is an automated email from the ASF dual-hosted git repository.
luchunliang 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 d5a4ebadce [INLONG-10876][SDK] Transform su
luchunliang merged PR #10877:
URL: https://github.com/apache/inlong/pull/10877
--
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
Zkplo closed pull request #10914: [INLONG-10906][SDK] Transform supports the
truncation of left and right strings
URL: https://github.com/apache/inlong/pull/10914
--
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
yfsn666 commented on code in PR #10865:
URL: https://github.com/apache/inlong/pull/10865#discussion_r1732504182
##
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformArithmeticFunctionsProcessor.java:
##
@@ -55,6 +55,39 @@ public class Te
ying-hua opened a new pull request, #10922:
URL: https://github.com/apache/inlong/pull/10922
Fixes #10920
### Motivation
- Add a function class: LocalTimeFunction and its unit test.
- LocalTime([string1])
Returns the local time (format: HH:mm:ss) in th
emptyOVO commented on code in PR #10801:
URL: https://github.com/apache/inlong/pull/10801#discussion_r1732403961
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +182,96 @@ public boolean sourceFinish() {
@Ov
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 89f43c62db [INLONG-10918][Manager] The corr
dockerzhang merged PR #10919:
URL: https://github.com/apache/inlong/pull/10919
--
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
This is an automated email from the ASF dual-hosted git repository.
luchunliang 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 171eb76a1c [INLONG-10913][SDK] Optimize the
luchunliang merged PR #10917:
URL: https://github.com/apache/inlong/pull/10917
--
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
This is an automated email from the ASF dual-hosted git repository.
luchunliang 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 ced348d9fc [INLONG-10886][SDK] Transform su
luchunliang merged PR #10888:
URL: https://github.com/apache/inlong/pull/10888
--
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
emptyOVO commented on code in PR #10904:
URL: https://github.com/apache/inlong/pull/10904#discussion_r1732275748
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/HexFunction.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Softwa
emptyOVO commented on code in PR #10904:
URL: https://github.com/apache/inlong/pull/10904#discussion_r1732275748
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/HexFunction.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Softwa
57 matches
Mail list logo
