[GitHub] [inlong] gong commented on issue #5797: [Bug][Manager] Fix Binary type mapping error

gong commented on issue #5797: URL: https://github.com/apache/inlong/issues/5797#issuecomment-1272873412 close it, pr [https://github.com/apache/inlong/pull/6079](https://github.com/apache/inlong/pull/6079) had fixed it. -- This is an automated message from the Apache Git Service. To res

[GitHub] [inlong] woofyzhao opened a new pull request, #6122: [INLONG-6121][Manager] Fix source list unassigned error when list stream

woofyzhao opened a new pull request, #6122: URL: https://github.com/apache/inlong/pull/6122 - Fixes #6121 The source list is not assigned when list streams. Fix it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

yunqingmoswu opened a new pull request, #6123: URL: https://github.com/apache/inlong/pull/6123 ### Prepare a Pull Request *(Change the title refer to the following example)* Title: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode *(The following *XYZ* should be rep

[GitHub] [inlong] gosonzhang opened a new pull request, #6125: [INLONG-6124][TubeMQ] Small optimizations about the implementation of metadata logic

gosonzhang opened a new pull request, #6125: URL: https://github.com/apache/inlong/pull/6125 - Fixes #6124 -- 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 unsubscri

[GitHub] [inlong] dockerzhang merged pull request #6122: [INLONG-6121][Manager] Fix source list unassigned error when list stream

dockerzhang merged PR #6122: URL: https://github.com/apache/inlong/pull/6122 -- 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-6121][Manager] Fix source list unassigned error when list stream (#6122)

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 bde66dcbd [INLONG-6121][Manager] Fix source

[inlong] branch release-1.3.0 updated: [INLONG-6121][Manager] Fix source list unassigned error when list stream (#6122)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new 4bf05427c [INLONG-6121][Manag

[GitHub] [inlong] gosonzhang opened a new pull request, #6127: [INLONG-6126][TubeMQ] Optimize StoreRepairAdmin logic

gosonzhang opened a new pull request, #6127: URL: https://github.com/apache/inlong/pull/6127 - Fixes #6126 -- 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 u

[inlong] branch master updated: [INLONG-6119][SDK] Fix log level and improve proxylist update strategy (#6120)

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 1d99a0d23 [INLONG-6119][SDK] Fix log level

[GitHub] [inlong] dockerzhang merged pull request #6120: [INLONG-6119][SDK] Fix log level and improve proxylist update strategy

dockerzhang merged PR #6120: URL: https://github.com/apache/inlong/pull/6120 -- 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] dockerzhang merged pull request #6074: [INLONG-6073][Kubernetes] Add audit.config.store.mode configurable to k8s

dockerzhang merged PR #6074: URL: https://github.com/apache/inlong/pull/6074 -- 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-6073][Kubernetes] Add audit.config.store.mode configurable to k8s (#6074)

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 252c2a6d3 [INLONG-6073][Kubernetes] Add aud

[GitHub] [inlong] gosonzhang merged pull request #6125: [INLONG-6124][TubeMQ] Small optimizations about the implementation of metadata logic

gosonzhang merged PR #6125: URL: https://github.com/apache/inlong/pull/6125 -- 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-6124][TubeMQ] Small optimizations about the implementation of metadata logic (#6125)

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 fd454ad4e [INLONG-6124][TubeMQ] Small optimi

[GitHub] [inlong] Keylchen commented on pull request #6112: [INLONG-6115][Agent] To solve Prometheus listener error and add unit tests

Keylchen commented on PR #6112: URL: https://github.com/apache/inlong/pull/6112#issuecomment-1273069599 1. The original PrometheusListener cannot get the data after running a collection task. The problem is idCounter label dimension is not same with addCounterMetricFamily dimension coun

[GitHub] [inlong] gosonzhang merged pull request #6127: [INLONG-6126][TubeMQ] Optimize StoreRepairAdmin logic

gosonzhang merged PR #6127: URL: https://github.com/apache/inlong/pull/6127 -- 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-6126][TubeMQ] Optimize StoreRepairAdmin logic (#6127)

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 d25db080e [INLONG-6126][TubeMQ] Optimize Sto

[GitHub] [inlong] gong commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

gong commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991137398 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java: ## @@ -176,6 +186,17 @@ public void setPartitions(int[]

[GitHub] [inlong] gong commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

gong commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991139744 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/DebeziumJsonDynamicSchemaFormat.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache

[GitHub] [inlong] EMsnap opened a new pull request, #6128: [INLONG-6113][Sort] Mysql cdc connector support read table schema when using debezium function

EMsnap opened a new pull request, #6128: URL: https://github.com/apache/inlong/pull/6128 - Fixes #6113 ### Motivation The Mysql Connector for extracting data now doesn't support reading table schema when there is no primary key specified. Canal Json requires field names cal

[GitHub] [inlong] EMsnap commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

EMsnap commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991179290 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/DynamicSchemaFormatFactory.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache So

[GitHub] [inlong] gong commented on a diff in pull request #6128: [INLONG-6113][Sort] Mysql cdc connector support read table schema when using debezium function

gong commented on code in PR #6128: URL: https://github.com/apache/inlong/pull/6128#discussion_r991195949 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/SqlServerExtractNode.java: ## @@ -139,6 +139,6 @@ public boolean isVirtual(MetaField me

[GitHub] [inlong] EMsnap commented on a diff in pull request #6128: [INLONG-6113][Sort] Mysql cdc connector support read table schema when using debezium function

EMsnap commented on code in PR #6128: URL: https://github.com/apache/inlong/pull/6128#discussion_r991199803 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/SqlServerExtractNode.java: ## @@ -139,6 +139,6 @@ public boolean isVirtual(MetaField

[GitHub] [inlong] healchow merged pull request #6112: [INLONG-6115][Agent] To solve Prometheus listener error and add unit tests

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

[inlong] branch release-1.3.0 updated: [INLONG-6115][Agent] Solve Prometheus listener error and add unit tests (#6112)

This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new e3242e1d8 [INLONG-6115][Agent] S

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

yunqingmoswu commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991207109 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/DebeziumJsonDynamicSchemaFormat.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to th

[inlong] branch master updated: [INLONG-6115][Agent] Solve Prometheus listener error and add unit tests (#6112)

This is an automated email from the ASF dual-hosted git repository. healchow 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 b0fd63b93 [INLONG-6115][Agent] Solve Prometheu

[GitHub] [inlong] gosonzhang opened a new pull request, #6130: [INLONG-6129][TubeMQ] Optimize the broker's node management

gosonzhang opened a new pull request, #6130: URL: https://github.com/apache/inlong/pull/6130 - Fixes #6129 -- 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 unsub

[GitHub] [inlong] GanfengTan opened a new pull request, #6132: [INLONG-6131][Agent] Support file filtering by condition

GanfengTan opened a new pull request, #6132: URL: https://github.com/apache/inlong/pull/6132 Filter file names by file attributes. - Fixes #6131 ### Motivation 1. Filter files by file properties, for example: logs of k8s. 2. Add rule filter file. ### Modifications

[GitHub] [inlong] gosonzhang merged pull request #6130: [INLONG-6129][TubeMQ] Optimize the broker's node management

gosonzhang merged PR #6130: URL: https://github.com/apache/inlong/pull/6130 -- 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-6129][TubeMQ] Optimize the broker's node management (#6130)

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 0133149cd [INLONG-6129][TubeMQ] Optimize the

[GitHub] [inlong] EMsnap commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

EMsnap commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991757209 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java: ## @@ -176,6 +189,17 @@ public void setPartitions(int

[GitHub] [inlong] EMsnap commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

EMsnap commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991758374 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/AbstractDynamicSchemaFormat.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

yunqingmoswu commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991772033 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java: ## @@ -176,6 +189,17 @@ public void setPartitio

[GitHub] [inlong] gosonzhang opened a new pull request, #6134: [INLONG-6133][TubeMQ] Add query parameter groupName in method admin_query_consumer_regmap

gosonzhang opened a new pull request, #6134: URL: https://github.com/apache/inlong/pull/6134 - Fixes #6133 -- 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 un

[GitHub] [inlong] EMsnap commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

EMsnap commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991776722 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java: ## @@ -176,6 +189,17 @@ public void setPartitions(int

[GitHub] [inlong] bluewang opened a new pull request, #6135: [INLONG-5814][Dashboard] Supports setting the precision of a field when adding a table field

bluewang opened a new pull request, #6135: URL: https://github.com/apache/inlong/pull/6135 ### 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] EMsnap commented on a diff in pull request #6132: [INLONG-6131][Agent] Support file filtering by condition

EMsnap commented on code in PR #6132: URL: https://github.com/apache/inlong/pull/6132#discussion_r991777389 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/FileJob.java: ## @@ -41,13 +41,16 @@ public class FileJob { private String envList; -p

[GitHub] [inlong] GanfengTan commented on a diff in pull request #6132: [INLONG-6131][Agent] Support file filtering by condition

GanfengTan commented on code in PR #6132: URL: https://github.com/apache/inlong/pull/6132#discussion_r991781225 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/FileJob.java: ## @@ -41,13 +41,16 @@ public class FileJob { private String envList; -

[GitHub] [inlong] EMsnap commented on a diff in pull request #6132: [INLONG-6131][Agent] Support file filtering by condition

EMsnap commented on code in PR #6132: URL: https://github.com/apache/inlong/pull/6132#discussion_r991783022 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/FileDataUtils.java: ## @@ -65,4 +81,56 @@ public static boolean isJSON(String json) {

[GitHub] [inlong] GanfengTan commented on a diff in pull request #6132: [INLONG-6131][Agent] Support file filtering by condition

GanfengTan commented on code in PR #6132: URL: https://github.com/apache/inlong/pull/6132#discussion_r991791862 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/FileDataUtils.java: ## @@ -65,4 +81,56 @@ public static boolean isJSON(String json) {

[GitHub] [inlong] thesumery commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

thesumery commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991847775 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/Constants.java: ## @@ -86,25 +86,30 @@ public final class Constants { public static f

[GitHub] [inlong] thesumery commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

thesumery commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991849455 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java: ## @@ -289,9 +336,11 @@ public DynamicTableSink cre

[GitHub] [inlong] thesumery commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

thesumery commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991850958 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/KafkaDynamicSink.java: ## @@ -82,7 +81,8 @@ public class KafkaDynamicSink implements Dyn

[GitHub] [inlong] leezng commented on a diff in pull request #6135: [INLONG-5814][Dashboard] Supports setting the precision of a field when adding a table field

leezng commented on code in PR #6135: URL: https://github.com/apache/inlong/pull/6135#discussion_r991861091 ## inlong-dashboard/src/metas/sinks/sqlServer.tsx: ## @@ -20,36 +20,41 @@ import type { FieldItemType } from '@/metas/common'; import EditableTable from '@/components/Edi

[GitHub] [inlong] gosonzhang merged pull request #6134: [INLONG-6133][TubeMQ] Add query parameter groupName in method admin_query_consumer_regmap

gosonzhang merged PR #6134: URL: https://github.com/apache/inlong/pull/6134 -- 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-6133][TubeMQ] Add query parameter groupName in method admin_query_consumer_regmap (#6134)

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 2276c45ff [INLONG-6133][TubeMQ] Add query pa

[GitHub] [inlong] thesumery commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

thesumery commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991862654 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java: ## @@ -325,7 +374,9 @@ public DynamicTableSink crea

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

yunqingmoswu commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991866312 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java: ## @@ -325,7 +374,9 @@ public DynamicTableSink c

[GitHub] [inlong] EMsnap commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

EMsnap commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991866539 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache Soft

[GitHub] [inlong] thesumery commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

thesumery commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991869898 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apache S

[GitHub] [inlong] yurzhou commented on issue #6136: [Bug][Manager] Cannot find manager-web.log in docker mode

yurzhou commented on issue #6136: URL: https://github.com/apache/inlong/issues/6136#issuecomment-1274159202 I want to solve this problem, please assign the issue to me -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [inlong] healchow commented on issue #6136: [Bug][Manager] Cannot find manager-web.log in docker mode

healchow commented on issue #6136: URL: https://github.com/apache/inlong/issues/6136#issuecomment-1274161025 > I want to solve this problem, please assign the issue to me Done. Thanks for your contribution. -- This is an automated message from the Apache Git Service. To respond to t

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6123: [INLONG-6116][Sort] Support dynamic topic for KafkaLoadNode

yunqingmoswu commented on code in PR #6123: URL: https://github.com/apache/inlong/pull/6123#discussion_r991875873 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java: ## @@ -0,0 +1,168 @@ +/* + * Licensed to the Apach