Re: [PR] [INLONG-9259][Manager] Optimize Elasticsearch sink and datanode [inlong]

fuweng11 commented on code in PR #9276: URL: https://github.com/apache/inlong/pull/9276#discussion_r1390702896 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchDataNodeDTO.java: ## @@ -73,6 +73,18 @@ public class ElasticsearchDataN

[PR] [INLONG-9259][Manager] Optimize Elasticsearch sink and datanode [inlong]

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

(inlong) branch master updated (bdf63d50e1 -> b88685bb08)

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 bdf63d50e1 [INLONG-9269][Manager] Fix get sort standalone cluster config empty (#9270) add b88685bb08 [INL

Re: [PR] [INLONG-9246][Sort] Pulsar source support audit when the deserialized type is not InlongMsg [inlong]

dockerzhang merged PR #9255: URL: https://github.com/apache/inlong/pull/9255 -- 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.

[PR] [INLONG-9271] [Manager]When creating 'StreamField', 'isMetaField' must be initialized [inlong]

LiJie20190102 opened a new pull request, #9272: URL: https://github.com/apache/inlong/pull/9272 When creating 'StreamField', 'isMetaField' must be initialized ### Prepare a Pull Request *(Change the title refer to the following example)* - [INLONG-9271] [Manager]When creating

(inlong) branch master updated: [INLONG-9269][Manager] Fix get sort standalone cluster config empty (#9270)

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 bdf63d50e1 [INLONG-9269][Manager] Fix get

Re: [PR] [INLONG-9269][Manager] Fix get sort standalone cluster config empty [inlong]

dockerzhang merged PR #9270: URL: https://github.com/apache/inlong/pull/9270 -- 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-9247][Sort] TubeMQ source support audit when the deserialized type is not InlongMsg (#9258)

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 ca0abf2438 [INLONG-9247][Sort] TubeMQ sourc

Re: [PR] [INLONG-9247][Sort] TubeMQ source support audit when the deserialized type is not InlongMsg [inlong]

dockerzhang merged PR #9258: URL: https://github.com/apache/inlong/pull/9258 -- 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-9246][Sort] Pulsar source support audit when the deserialized type is not InlongMsg [inlong]

vernedeng commented on code in PR #9255: URL: https://github.com/apache/inlong/pull/9255#discussion_r1390575928 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java: ## @@ -109,8

[PR] [INLONG-9260][Manager] Fix get sort standalone cluster config empty [inlong]

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

Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]

haibo-duan commented on code in PR #8941: URL: https://github.com/apache/inlong/pull/8941#discussion_r1390570482 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java: ## @@ -39,54 +66,921 @@ public class PulsarU

Re: [PR] [INLONG-9246][Sort] Pulsar source support audit when the deserialized type is not InlongMsg [inlong]

EMsnap commented on code in PR #9255: URL: https://github.com/apache/inlong/pull/9255#discussion_r1390564512 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableDeserializationSchema.java: ## @@ -109,8 +1

Re: [PR] [INLONG-9222][Manager] Support sortstandalone get cluster config with multiple cluster tag [inlong]

vernedeng commented on code in PR #9262: URL: https://github.com/apache/inlong/pull/9262#discussion_r1390559182 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java: ## @@ -315,10 +316,10 @@ private Map parseCache