[GitHub] [inlong] fuweng11 opened a new pull request, #7142: [INLONG-7138][Manager] Support the connection test for kafka, tube, starrocks, etc

2023-01-04 Thread GitBox
fuweng11 opened a new pull request, #7142: URL: https://github.com/apache/inlong/pull/7142 ### Prepare a Pull Request - Fixes #7138 ### Motivation Support the connection test for kafka, tube, starrocks, mysql, clickhouse. ### Modifications Support th

[GitHub] [inlong] gong merged pull request #7118: [INLONG-7073][Sort] Support table level metrics for Apache Iceberg connector

2023-01-04 Thread GitBox
gong merged PR #7118: URL: https://github.com/apache/inlong/pull/7118 -- 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.apache.

[inlong] branch master updated: [INLONG-7073][Sort] Support table level metrics for Apache Iceberg connector (#7118)

2023-01-04 Thread pacinogong
This is an automated email from the ASF dual-hosted git repository. pacinogong 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 e305ae869 [INLONG-7073][Sort] Support table

[GitHub] [inlong] dockerzhang merged pull request #7141: [INLONG-7140][Sort] Sort mysql cdc connector mysql snapshot split exit catch exception

2023-01-04 Thread GitBox
dockerzhang merged PR #7141: URL: https://github.com/apache/inlong/pull/7141 -- 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-7140][Sort] Sort mysql cdc connector mysql snapshot split exit catch exception (#7141)

2023-01-04 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 6545e4f9e [INLONG-7140][Sort] Sort mysql cd

[GitHub] [inlong] bluewang commented on issue #7143: [Improve][Dashboard] Kafka sink optimization

2023-01-04 Thread GitBox
bluewang commented on issue #7143: URL: https://github.com/apache/inlong/issues/7143#issuecomment-1370680049 unnecessary -- 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

[GitHub] [inlong] bluewang opened a new pull request, #7145: [INLONG-7139][Dashboard] The cluster supports connection testing

2023-01-04 Thread GitBox
bluewang opened a new pull request, #7145: URL: https://github.com/apache/inlong/pull/7145 ### 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] dockerzhang merged pull request #7142: [INLONG-7138][Manager] Support the connection test for kafka, tube, starrocks, etc

2023-01-04 Thread GitBox
dockerzhang merged PR #7142: URL: https://github.com/apache/inlong/pull/7142 -- 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-7138][Manager] Support the connection test for kafka, tube, starrocks, etc (#7142)

2023-01-04 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 ca06b6ac1 [INLONG-7138][Manager] Support th

[GitHub] [inlong] healchow commented on a diff in pull request #7107: [INLONG-7103][Sort] Support InLongMsg format in Kafka

2023-01-04 Thread GitBox
healchow commented on code in PR #7107: URL: https://github.com/apache/inlong/pull/7107#discussion_r1061359464 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/KafkaExtractNode.java: ## @@ -142,7 +145,13 @@ public Map tableOptions() {

[GitHub] [inlong] gosonzhang opened a new pull request, #7147: [INLONG-7144][Manager] Add interface field limit

2023-01-04 Thread GitBox
gosonzhang opened a new pull request, #7147: URL: https://github.com/apache/inlong/pull/7147 - Fixes #7144 -- 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 unsubs

[GitHub] [inlong] Yizhou-Yang opened a new pull request, #7148: [INLONG-7146] [Sort] adjust dirty data doris dynamic error handling strategy

2023-01-04 Thread GitBox
Yizhou-Yang opened a new pull request, #7148: URL: https://github.com/apache/inlong/pull/7148 ### Prepare a Pull Request - Fixes [[Improve] [Sort] adjust dirty data doris dynamic error handling strategy #7146 ] (https://github.com/apache/inlong/issues/7082) ### Motivation

[GitHub] [inlong] leezng commented on a diff in pull request #7145: [INLONG-7139][Dashboard] Cluster and node support for connectivity testing

2023-01-04 Thread GitBox
leezng commented on code in PR #7145: URL: https://github.com/apache/inlong/pull/7145#discussion_r1061388933 ## inlong-dashboard/src/pages/Clusters/CreateModal.tsx: ## @@ -101,7 +121,17 @@ const Comp: React.FC = ({ id, defaultType, ...modalProps }) => { {i18n.t('basic.Canc

[GitHub] [inlong] leezng commented on a diff in pull request #7145: [INLONG-7139][Dashboard] Cluster and node support for connectivity testing

2023-01-04 Thread GitBox
leezng commented on code in PR #7145: URL: https://github.com/apache/inlong/pull/7145#discussion_r1061391010 ## inlong-dashboard/src/pages/Clusters/CreateModal.tsx: ## @@ -101,7 +121,17 @@ const Comp: React.FC = ({ id, defaultType, ...modalProps }) => { {i18n.t('basic.Canc

[GitHub] [inlong] fuweng11 opened a new pull request, #7150: [INLONG-7149][Manager] Replace tableName in ClickHouseLoadNode with databaseName.tableName

2023-01-04 Thread GitBox
fuweng11 opened a new pull request, #7150: URL: https://github.com/apache/inlong/pull/7150 ### Prepare a Pull Request - Fixes #7149 ### Motivation Fix the problem of tableName parameter in ClickHouseLoadNode is incorrect. ### Modifications Replace tableName

[inlong] 03/04: [INLONG-7140][Sort] Sort mysql cdc connector mysql snapshot split exit catch exception (#7141)

2023-01-04 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 6e6cadb9aca56869f27e2f5efd9cb9d054655d31 Author: Schnapps AuthorDate: Wed Jan 4 17:24:03 2023 +0800 [INLON

[inlong] branch branch-1.5 updated (5c37f1efa -> c7af0fcc0)

2023-01-04 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 5c37f1efa [INLONG-7126][Sort] Support multiple dirty sink archive helper (#7127) new f2fcf934a [INLONG-

[inlong] 01/04: [INLONG-7133][Dashboard] The sink's data node supports jumping to the node page (#7137)

2023-01-04 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 f2fcf934a0dbfcadafc9020dbb65dcd080489f7b Author: Lizhen <88174078+bluew...@users.noreply.github.com> AuthorDate:

[inlong] 04/04: [INLONG-7138][Manager] Support the connection test for kafka, tube, starrocks, etc (#7142)

2023-01-04 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 c7af0fcc0790d10ba0d4180c342aae8715a13f32 Author: fuweng11 <76141879+fuwen...@users.noreply.github.com> AuthorDat

[inlong] 02/04: [INLONG-7073][Sort] Support table level metrics for Apache Iceberg connector (#7118)

2023-01-04 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 e5351f5c00f28e730b178a2d64b6e99b4d449866 Author: thesumery <107393625+thesum...@users.noreply.github.com> Author

[GitHub] [inlong] haifxu opened a new pull request, #7152: [INLONG-7151][Manager] Fix failure to create node when init sort

2023-01-04 Thread GitBox
haifxu opened a new pull request, #7152: URL: https://github.com/apache/inlong/pull/7152 ### Prepare a Pull Request - Fixes #7151 ### Motivation 1. Create Kafka extract node failed 2. Create Mysql load node failed ### Modifications 1. Get info from the d

[GitHub] [inlong-website] gong opened a new issue, #665: [Improve][Sort] Update clickhouse connector doc

2023-01-04 Thread GitBox
gong opened a new issue, #665: URL: https://github.com/apache/inlong-website/issues/665 ### Description Update clickhouse connector doc ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this

[GitHub] [inlong] gong commented on pull request #7150: [INLONG-7149][Manager] Replace tableName in ClickHouseLoadNode with databaseName.tableName

2023-01-04 Thread GitBox
gong commented on PR #7150: URL: https://github.com/apache/inlong/pull/7150#issuecomment-1370855256 ref to https://github.com/apache/inlong/pull/6595 -- 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

[GitHub] [inlong] dockerzhang merged pull request #7150: [INLONG-7149][Manager] Replace tableName in ClickHouseLoadNode with databaseName.tableName

2023-01-04 Thread GitBox
dockerzhang merged PR #7150: URL: https://github.com/apache/inlong/pull/7150 -- 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-7149][Manager] Replace tableName in ClickHouseLoadNode with databaseName.tableName (#7150)

2023-01-04 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 ad28d5594 [INLONG-7149][Manager] Replace ta

[GitHub] [inlong] gosonzhang commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
gosonzhang commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062027011 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java: ## @@ -228,7 +228,7 @@ private HeartbeatMsg buildHeartbeatMsg() {

[inlong] branch master updated: [INLONG-7151][Manager] Fix failure to create node when init sort (#7152)

2023-01-04 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 15da36a0e [INLONG-7151][Manager] Fix failur

[GitHub] [inlong] dockerzhang merged pull request #7152: [INLONG-7151][Manager] Fix failure to create node when init sort

2023-01-04 Thread GitBox
dockerzhang merged PR #7152: URL: https://github.com/apache/inlong/pull/7152 -- 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] gosonzhang commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
gosonzhang commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062030204 ## inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongClusterController.java: ## @@ -228,11 +228,11 @@ public Response deleteNode

[GitHub] [inlong] github-actions[bot] commented on issue #5839: [Feature][SortStandalone] Add SortStandalone option in start script

2023-01-04 Thread GitBox
github-actions[bot] commented on issue #5839: URL: https://github.com/apache/inlong/issues/5839#issuecomment-1371653278 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, please

[GitHub] [inlong] github-actions[bot] commented on issue #5133: [Feature] Add InfluxDB Extract and Load Node for Sort

2023-01-04 Thread GitBox
github-actions[bot] commented on issue #5133: URL: https://github.com/apache/inlong/issues/5133#issuecomment-1371653307 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, please

[GitHub] [inlong] thesumery commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
thesumery commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062049599 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java: ## @@ -228,7 +228,7 @@ private HeartbeatMsg buildHeartbeatMsg() {

[GitHub] [inlong] thesumery commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
thesumery commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062049599 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java: ## @@ -228,7 +228,7 @@ private HeartbeatMsg buildHeartbeatMsg() {

[GitHub] [inlong] dockerzhang merged pull request #7107: [INLONG-7103][Sort] Support InLongMsg format in Kafka

2023-01-04 Thread GitBox
dockerzhang merged PR #7107: URL: https://github.com/apache/inlong/pull/7107 -- 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-7103][Sort] Support InLongMsg format in Kafka (#7107)

2023-01-04 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 803941656 [INLONG-7103][Sort] Support InLon

[GitHub] [inlong] gosonzhang merged pull request #7147: [INLONG-7144][Manager] Add interface field limit

2023-01-04 Thread GitBox
gosonzhang merged PR #7147: URL: https://github.com/apache/inlong/pull/7147 -- 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.a

[inlong] branch master updated: [INLONG-7144][Manager] Add interface field limit (#7147)

2023-01-04 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 cdb7c45a6 [INLONG-7144][Manager] Add interfa

[GitHub] [inlong] bluewang opened a new pull request, #7155: [INLONG-7153][Dashboard] The data subscription status code shows the specific meaning

2023-01-04 Thread GitBox
bluewang opened a new pull request, #7155: URL: https://github.com/apache/inlong/pull/7155 ### 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] pocozh opened a new pull request, #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
pocozh opened a new pull request, #7157: URL: https://github.com/apache/inlong/pull/7157 ### Prepare a Pull Request *(Change the title refer to the following example)* - [INLONG-7156][Agent] Support directly sending raw file data *(The following *XYZ* should be replaced by th

[GitHub] [inlong] thesumery commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
thesumery commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062092764 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/task/TestTextFileTask.java: ## @@ -180,7 +182,7 @@ public void testReadFull() throws IOExcep

[GitHub] [inlong] vernedeng opened a new pull request, #7158: [INLONG-7154][SDK] Fix metric report failure when topic does not exist

2023-01-04 Thread GitBox
vernedeng opened a new pull request, #7158: URL: https://github.com/apache/inlong/pull/7158 ### Prepare a Pull Request - Fixes #7154 ### Motivation Get SortSdk metric item fail when the topic does not exist, which will lead to null pointer exception. ### Modifica

[GitHub] [inlong] fuweng11 commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
fuweng11 commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062136995 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/SourceRequest.java: ## @@ -72,8 +72,8 @@ public class SourceRequest { @ApiModelP

[GitHub] [inlong] fuweng11 commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
fuweng11 commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062137741 ## inlong-common/src/main/java/org/apache/inlong/common/heartbeat/HeartbeatMsg.java: ## @@ -78,7 +78,7 @@ public class HeartbeatMsg { /** * Tag of node, sep

[GitHub] [inlong] leezng merged pull request #7145: [INLONG-7139][Dashboard] Cluster and node support for connectivity testing

2023-01-04 Thread GitBox
leezng merged PR #7145: URL: https://github.com/apache/inlong/pull/7145 -- 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.apach

[inlong] branch master updated (cdb7c45a6 -> 3afe33b68)

2023-01-04 Thread leezng
This is an automated email from the ASF dual-hosted git repository. leezng pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from cdb7c45a6 [INLONG-7144][Manager] Add interface field limit (#7147) add 3afe33b68 [INLONG-7139][Dashboard] Cluster

[GitHub] [inlong] leezng merged pull request #7155: [INLONG-7153][Dashboard] The data subscription status code shows the specific meaning

2023-01-04 Thread GitBox
leezng merged PR #7155: URL: https://github.com/apache/inlong/pull/7155 -- 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.apach

[inlong] branch master updated: [INLONG-7153][Dashboard] The data subscription status code shows the specific meaning (#7155)

2023-01-04 Thread leezng
This is an automated email from the ASF dual-hosted git repository. leezng 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 8ff9d905c [INLONG-7153][Dashboard] The data subs

[GitHub] [inlong] thesumery commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

2023-01-04 Thread GitBox
thesumery commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062146712 ## inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongClusterApi.java: ## @@ -101,5 +101,5 @@ Call>> listNodeByGroupId(@Qu

[GitHub] [inlong] dockerzhang merged pull request #7158: [INLONG-7154][SDK] Fix metric report failure when topic does not exist

2023-01-04 Thread GitBox
dockerzhang merged PR #7158: URL: https://github.com/apache/inlong/pull/7158 -- 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-7154][SDK] Fix metric report failure when topic does not exist (#7158)

2023-01-04 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 a5bacfa1d [INLONG-7154][SDK] Fix metric rep

[GitHub] [inlong] healchow commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
healchow commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062178555 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/FileReaderOperator.java: ## @@ -278,6 +282,9 @@ public void resiterMeta(J

[GitHub] [inlong] pocozh commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
pocozh commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062181321 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/FileReaderOperator.java: ## @@ -278,6 +282,9 @@ public void resiterMeta(Job

[GitHub] [inlong] healchow commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
healchow commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062185420 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/FileReaderOperator.java: ## @@ -278,6 +282,9 @@ public void resiterMeta(J

[GitHub] [inlong] healchow commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
healchow commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062186433 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/FileReaderOperator.java: ## @@ -104,6 +104,7 @@ public class FileReaderOp

[GitHub] [inlong] pocozh commented on a diff in pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

2023-01-04 Thread GitBox
pocozh commented on code in PR #7157: URL: https://github.com/apache/inlong/pull/7157#discussion_r1062195858 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/file/FileReaderOperator.java: ## @@ -278,6 +282,9 @@ public void resiterMeta(Job