[PR] [INLONG-11496][Dashboard] File source adds a new judgment on spaces in the file path [inlong]

2024-11-12 Thread via GitHub
wohainilaodou opened a new pull request, #11497: URL: https://github.com/apache/inlong/pull/11497 Fixes #11496 ### Motivation File source adds a new judgment on spaces in the file path ### Modifications File source adds a new judgment on spaces in the file

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
vernedeng commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839531984 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/airflow/DAGCollection.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache S

(inlong) branch master updated: [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in MetricSendCallBack class (#11492)

2024-11-12 Thread gosonzhang
This is an automated email from the ASF dual-hosted git repository. gosonzhang 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 ddaff247fb [INLONG-11491][SDK] Fix the judgm

Re: [PR] [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in MetricSendCallBack class [inlong]

2024-11-12 Thread via GitHub
gosonzhang merged PR #11492: URL: https://github.com/apache/inlong/pull/11492 -- 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-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
vernedeng commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839334995 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/airflow/ConnectionCollection.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the A

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
vernedeng commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839333731 ## inlong-manager/manager-schedule/src/test/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngineTest.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
vernedeng commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839334995 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/airflow/ConnectionCollection.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the A

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
vernedeng commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839334831 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/airflow/Connection.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Soft

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
fuweng11 commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839317112 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the A

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
fuweng11 commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839316523 ## inlong-manager/manager-schedule/src/test/java/org/apache/inlong/manager/schedule/airflow/AirflowContainerEnv.java: ## @@ -0,0 +1,124 @@ +/* + * Licensed to the Apa

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
fuweng11 commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1839300349 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowServerClient.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apac

[PR] [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in MetricSendCallBack class [inlong]

2024-11-12 Thread via GitHub
gosonzhang opened a new pull request, #11492: URL: https://github.com/apache/inlong/pull/11492 Fixes #11491 -- 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.

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1838112473 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,233 @@ +/* + * Licensed to the Apac

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1838113034 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,233 @@ +/* + * Licensed to the Apac

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1838112167 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,233 @@ +/* + * Licensed to the Apac

Re: [PR] [INLONG-11489][Audit] Use Throwable instead of Exception to capture Java package conflicts [inlong]

2024-11-12 Thread via GitHub
doleyzi merged PR #11490: URL: https://github.com/apache/inlong/pull/11490 -- 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.ap

(inlong) branch master updated: [INLONG-11489][Audit] Use Throwable instead of Exception to capture Java package conflicts (#11490)

2024-11-12 Thread doleyzi
This is an automated email from the ASF dual-hosted git repository. doleyzi 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 28c3c6ba88 [INLONG-11489][Audit] Use Throwable

[PR] [INLONG-11489][Audit] Use Throwable instead of Exception to capture Java package conflicts [inlong]

2024-11-12 Thread via GitHub
doleyzi opened a new pull request, #11490: URL: https://github.com/apache/inlong/pull/11490 - Fixes #11489 ### Motivation Use Throwable instead of Exception to capture Java package conflicts. ### Modifications Use Throwable instead of Exception to capture Java pack

[PR] [INLONG-11487][Manager] Support adding data add tasks based on the source ID [inlong]

2024-11-12 Thread via GitHub
fuweng11 opened a new pull request, #11488: URL: https://github.com/apache/inlong/pull/11488 Fixes #11487 ### Motivation Support adding data add tasks based on the source ID. Modify the cp command. ### Modifications 1.Support adding data add

Re: [PR] [INLONG-11401][Manager] Support Dolphinscheduler schedule engine [inlong]

2024-11-12 Thread via GitHub
fuweng11 commented on code in PR #11468: URL: https://github.com/apache/inlong/pull/11468#discussion_r1837825449 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/dolphinscheduler/DolphinScheduleEngine.java: ## @@ -0,0 +1,263 @@ +/* + * Licensed

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
fuweng11 commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1837814575 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,233 @@ +/* + * Licensed to the A

Re: [PR] [INLONG-11483][Manager] Support multiple scedule engine selection [inlong]

2024-11-12 Thread via GitHub
dockerzhang merged PR #11484: URL: https://github.com/apache/inlong/pull/11484 -- 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

Re: [PR] [INLONG-11485][Dashboard] Support multiple scheduling enginessearch [inlong]

2024-11-12 Thread via GitHub
dockerzhang merged PR #11486: URL: https://github.com/apache/inlong/pull/11486 -- 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-11483][Manager] Support multiple scedule engine selection (#11484)

2024-11-12 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 eb55831cf0 [INLONG-11483][Manager] Support

(inlong) branch master updated: [INLONG-11485][Dashboard] Support multiple scheduling enginessearch (#11486)

2024-11-12 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 2a8b23322d [INLONG-11485][Dashboard] Suppor

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1837684008 ## inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java: ## @@ -0,0 +1,225 @@ +/* + * Licensed to the Apac

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1837683334 ## inlong-manager/manager-schedule/src/test/java/org/apache/inlong/manager/schedule/airflow/AirflowContainerEnv.java: ## @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1837682987 ## inlong-manager/manager-schedule/src/test/java/org/apache/inlong/manager/schedule/airflow/AirflowContainerEnv.java: ## @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-11400][Manager] Support Airflow schedule engine [inlong]

2024-11-12 Thread via GitHub
Zkplo commented on code in PR #11479: URL: https://github.com/apache/inlong/pull/11479#discussion_r1837682642 ## inlong-manager/manager-schedule/src/test/java/org/apache/inlong/manager/schedule/airflow/AirflowContainerEnv.java: ## @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache