Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]

2024-07-16 Thread via GitHub
XComp commented on code in PR #25027: URL: https://github.com/apache/flink/pull/25027#discussion_r1680520986 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java: ## @@ -97,6 +106,14 @@ public JobManagerRunner unregister(JobID j

Re: [PR] [FLINK-35832][Table SQL / Planner] Fix IFNULL outputTypeStrategy [flink]

2024-07-16 Thread via GitHub
flinkbot commented on PR #25099: URL: https://github.com/apache/flink/pull/25099#issuecomment-2232561121 ## CI report: * 44145686170d159ef0a7742d49d41da7651ae7e0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34111][table] Add support for json_quote, json_unquote, address PR feedback #24156 [flink]

2024-07-16 Thread via GitHub
anupamaggarwal commented on PR #24967: URL: https://github.com/apache/flink/pull/24967#issuecomment-2232553702 thanks @snuyanzin, fixed in [7546d9c](https://github.com/apache/flink/pull/24967/commits/7546d9ceb85b5650804d6868bb34797507076c16) Hmm, that's strange, when I tested >SEL

[PR] [FLINK-35832][Table SQL / Planner] Fix IFNULL outputTypeStrategy [flink]

2024-07-16 Thread via GitHub
dylanhz opened a new pull request, #25099: URL: https://github.com/apache/flink/pull/25099 ## What is the purpose of the change Fix the incorrect output datatype of `IFNULL`. ## Brief change log The `IfNullTypeStrategy` previously takes the datatype of nullRep

[jira] [Updated] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

2024-07-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35832: --- Labels: pull-request-available (was: ) > IFNULL returns incorrect result in Flink SQL > ---

[PR] add note **Please note that the lib here refers to the lib of flink-c… [flink-cdc]

2024-07-16 Thread via GitHub
Lordeath opened a new pull request, #3476: URL: https://github.com/apache/flink-cdc/pull/3476 add note **Please note that the lib here refers to the lib of flink-cdc, not the lib of flink. Do not put pipeline-related packages under the lib of flink, otherwise it will cause class loading rel

[PR] 增加注释 **请注意这里的lib指的是flink-cdc的lib,而不是flink的lib,pipeline相关的包不要放到flink的l… [flink-cdc]

2024-07-16 Thread via GitHub
Lordeath opened a new pull request, #3477: URL: https://github.com/apache/flink-cdc/pull/3477 增加注释 **请注意这里的lib指的是flink-cdc的lib,而不是flink的lib,pipeline相关的包不要放到flink的lib下,否则会引发类加载相关问题** -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
leonardBang commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1677568777 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/HashFunctionProvider.java: ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software Foundati

[jira] [Updated] (FLINK-35817) High RSS Memory Growth in Long-Running Flink Tasks with Low Heap Usage: Is Prometheus Metrics Reporting the Culprit?

2024-07-16 Thread ZHangTianLong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZHangTianLong updated FLINK-35817: -- Priority: Blocker (was: Major) > High RSS Memory Growth in Long-Running Flink Tasks with Low

[jira] [Updated] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

2024-07-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35851: Fix Version/s: kubernetes-operator-1.10.0 > autoscaler standlone mode use `GlobalConfiguration.loadConfigu

[jira] [Comment Edited] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

2024-07-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866626#comment-17866626 ] yuanfenghu edited comment on FLINK-35851 at 7/17/24 6:05 AM: -

Re: [PR] [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public [flink]

2024-07-16 Thread via GitHub
superdiaodiao commented on PR #25081: URL: https://github.com/apache/flink/pull/25081#issuecomment-2232495590 > Thanks for the PR. If we want to also upgrade `TypeSerializerSnapshot` to Public, it's better to do this after removing related deprecated methods in 2.0. So in this PR, it'

[jira] [Commented] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

2024-07-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866626#comment-17866626 ] yuanfenghu commented on FLINK-35851: [~fanrui] Thanks for the reply. My idea is th

Re: [PR] [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public [flink]

2024-07-16 Thread via GitHub
superdiaodiao commented on PR #25081: URL: https://github.com/apache/flink/pull/25081#issuecomment-2232490576 > Thanks for the PR. > If we want to also upgrade `TypeSerializerSnapshot` to Public, it's better to do this after removing related deprecated methods in 2.0. So in this PR

Re: [PR] [FLINK-35154] Javadoc generating fix [flink]

2024-07-16 Thread via GitHub
reswqa commented on PR #24684: URL: https://github.com/apache/flink/pull/24684#issuecomment-2232490279 Let's build the doc to see if it was fixed. -- 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

Re: [PR] [FLINK-35154] Javadoc generating fix [flink]

2024-07-16 Thread via GitHub
reswqa merged PR #24684: URL: https://github.com/apache/flink/pull/24684 -- 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: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-32248][tests] fix incorrect AssertJ usage [flink]

2024-07-16 Thread via GitHub
codenohup closed pull request #22749: [FLINK-32248][tests] fix incorrect AssertJ usage URL: https://github.com/apache/flink/pull/22749 -- 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 co

[jira] [Updated] (FLINK-35855) Upgrade Calcite version to 1.36.0

2024-07-16 Thread TJ Banghart (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ Banghart updated FLINK-35855: Description: https://calcite.apache.org/news/2023/11/10/release-1.36.0/ > Upgrade Calcite version

[jira] [Updated] (FLINK-35854) Upgrade Calcite version to 1.35.0

2024-07-16 Thread TJ Banghart (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ Banghart updated FLINK-35854: Description: https://calcite.apache.org/news/2023/07/26/release-1.35.0/ > Upgrade Calcite version

[jira] [Created] (FLINK-35856) Upgrade Calcite version to 1.37.0

2024-07-16 Thread TJ Banghart (Jira)
TJ Banghart created FLINK-35856: --- Summary: Upgrade Calcite version to 1.37.0 Key: FLINK-35856 URL: https://issues.apache.org/jira/browse/FLINK-35856 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-35855) Upgrade Calcite version to 1.36.0

2024-07-16 Thread TJ Banghart (Jira)
TJ Banghart created FLINK-35855: --- Summary: Upgrade Calcite version to 1.36.0 Key: FLINK-35855 URL: https://issues.apache.org/jira/browse/FLINK-35855 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-35854) Upgrade Calcite version to 1.35.0

2024-07-16 Thread TJ Banghart (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ Banghart updated FLINK-35854: Component/s: Table SQL / API > Upgrade Calcite version to 1.35.0 > ---

[jira] [Created] (FLINK-35854) Upgrade Calcite version to 1.35.0

2024-07-16 Thread TJ Banghart (Jira)
TJ Banghart created FLINK-35854: --- Summary: Upgrade Calcite version to 1.35.0 Key: FLINK-35854 URL: https://issues.apache.org/jira/browse/FLINK-35854 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-31362) Upgrade to Calcite version to 1.33.0

2024-07-16 Thread TJ Banghart (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866604#comment-17866604 ] TJ Banghart commented on FLINK-31362: - Hey there, just checking what the status is o

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
yuxiqian commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680353616 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Commented] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

2024-07-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866603#comment-17866603 ] Rui Fan commented on FLINK-35851: - I load the config from main parameters for 2 reasons:

[jira] [Assigned] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

2024-07-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35851: --- Assignee: yuanfenghu > autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
yuxiqian commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680373178 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
dingxin-tech commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680368470 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
dingxin-tech commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680367973 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35847] Add 1.20 release announcement [flink-web]

2024-07-16 Thread via GitHub
reswqa commented on code in PR #751: URL: https://github.com/apache/flink-web/pull/751#discussion_r1680363087 ## docs/content/posts/2024-07-15-release-1.20.0.md: ## @@ -0,0 +1,510 @@ +--- +authors: +- reswqa: + name: "Weijie Guo" + twitter: "WeijieGuo12" +- 1996fanrui: + name

[jira] [Closed] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source

2024-07-16 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang closed FLINK-34966. --- Resolution: Won't Do > Support to read snapshot by table partitions in MySQL CDC Source > --

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
yuxiqian commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680356424 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
yuxiqian commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680356955 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-16 Thread via GitHub
yuxiqian commented on code in PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414#discussion_r1680356424 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultHashFunctionProvider.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Commented] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source

2024-07-16 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866600#comment-17866600 ] He Wang commented on FLINK-34966: - [~renqs] Sorry for the late reply. Once I wanted to e

Re: [PR] [Kafka]Kafka sink numRecordsOutByIncremental metrics [flink-cdc]

2024-07-16 Thread via GitHub
ChengJie1053 commented on PR #3471: URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2232291457 > I have two points to be discussed. > > 1. Does 'numRecordsOutByIncremental' refer to the incremental phase here? We don't have a way to determine whether we have reached th

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-07-16 Thread via GitHub
lvyanquan commented on PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#issuecomment-2232258238 @czy006 PTAL as this failed case maybe related to https://github.com/apache/flink-cdc/pull/3240. -- This is an automated message from the Apache Git Service. To respond to the messa

Re: [PR] [FLINK-28023][docs]Translate "Native Kubernetes" page into Chinese [flink]

2024-07-16 Thread via GitHub
flinkbot commented on PR #25098: URL: https://github.com/apache/flink/pull/25098#issuecomment-2232254110 ## CI report: * 2031638bda9aa885a69a4a778e6b1a3a3efbc85a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-28023][docs]Translate "Native Kubernetes" page into Chinese [flink]

2024-07-16 Thread via GitHub
bobobozh closed pull request #25098: [FLINK-28023][docs]Translate "Native Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/25098 -- 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 t

Re: [PR] [Kafka]Kafka sink numRecordsOutByIncremental metrics [flink-cdc]

2024-07-16 Thread via GitHub
lvyanquan commented on PR #3471: URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2232251987 I have two points to be discussed. 1. Does 'numRecordsOutByIncremental' refer to the incremental phase here? We don't have a way to determine whether we have reached this phase in t

[jira] [Updated] (FLINK-28023) Translate "Native Kubernetes" page into Chinese

2024-07-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28023: --- Labels: pull-request-available (was: ) > Translate "Native Kubernetes" page into Chinese >

[PR] [FLINK-28023][docs]Translate "Native Kubernetes" page into Chinese [flink]

2024-07-16 Thread via GitHub
bobobozh opened a new pull request, #25098: URL: https://github.com/apache/flink/pull/25098 ## What is the purpose of the change Translate "Native Kubernetes" page into Chinese. -- This is an automated message from the Apache Git Service. To respond to the me

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-07-16 Thread via GitHub
beryllw commented on PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#issuecomment-2232245355 Looks like an error related to MySQL CDC. ```2024-07-16T10:37:08.5109144Z 52153 [debezium-reader-1] ERROR io.debezium.relational.TableSchemaBuilder - Failed to properly convert data

[jira] [Commented] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

2024-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866594#comment-17866594 ] dalongliu commented on FLINK-35832: --- [~dylanhz] will help to fix it. > IFNULL returns

[jira] [Assigned] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

2024-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35832: - Assignee: Dylan He > IFNULL returns incorrect result in Flink SQL > ---

[jira] [Resolved] (FLINK-35812) Move tuple interfaces to flink-core-api

2024-07-16 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35812. - Fix Version/s: 2.0.0 Resolution: Fixed > Move tuple interfaces to flink-core-api > --

[jira] [Commented] (FLINK-35812) Move tuple interfaces to flink-core-api

2024-07-16 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866591#comment-17866591 ] Zakelly Lan commented on FLINK-35812: - Merged into master via: 78c15a2dd2149385ff29f

Re: [PR] [FLINK-35812][Core/API] Move tuple interfaces to flink-core-api [flink]

2024-07-16 Thread via GitHub
Zakelly merged PR #25074: URL: https://github.com/apache/flink/pull/25074 -- 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: issues-unsubscr...@flink.apach

Re: [PR] [FLINK-35812][Core/API] Move tuple interfaces to flink-core-api [flink]

2024-07-16 Thread via GitHub
Zakelly commented on PR #25074: URL: https://github.com/apache/flink/pull/25074#issuecomment-2232219714 Thanks @reswqa , merging... -- 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 co

[jira] [Commented] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

2024-07-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866589#comment-17866589 ] lincoln lee commented on FLINK-35832: - [~lsy] Could you help to fix this? > IFNULL

[jira] [Commented] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

2024-07-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866587#comment-17866587 ] lincoln lee commented on FLINK-35832: - [~yunta] Looks like this is the problem that

Re: [PR] [mysql] Add schema validation for table schema #493 [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #522: URL: https://github.com/apache/flink-cdc/pull/522#issuecomment-2232038606 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] expose meta_ts field in the metadata through flink sql [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1141: URL: https://github.com/apache/flink-cdc/pull/1141#issuecomment-2232038478 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] Support the rate limit when Mysql parallel read data output [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1573: URL: https://github.com/apache/flink-cdc/pull/1573#issuecomment-2232038435 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] optimize the update operation in binlog events [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #41: URL: https://github.com/apache/flink-cdc/pull/41#issuecomment-2232038633 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. -- Th

Re: [PR] fix: fix mysql-cdc case sensitive [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #831: URL: https://github.com/apache/flink-cdc/pull/831#issuecomment-2232038585 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] support for transaction metadata events [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1039: URL: https://github.com/apache/flink-cdc/pull/1039#issuecomment-2232038529 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] Added option for MysqlSource to dispatch watermark event at the begin… [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #883: URL: https://github.com/apache/flink-cdc/pull/883#issuecomment-2232038559 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [WIP] tidb netty worker leak [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1697: URL: https://github.com/apache/flink-cdc/pull/1697#issuecomment-2232038374 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle] The STRUCT type processing exception [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1790: URL: https://github.com/apache/flink-cdc/pull/1790#issuecomment-2232038306 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] keep order of each split by replacing HashMap with LinkedHashMap [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1075: URL: https://github.com/apache/flink-cdc/pull/1075#issuecomment-2232038498 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] Fix the binlogSplit state incompatibility when upgrading from 2.2.0 [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1211: URL: https://github.com/apache/flink-cdc/pull/1211#issuecomment-2232038451 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [#1770] fix NumberFormatException when mysql server_id is larger than INT_MAX [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1771: URL: https://github.com/apache/flink-cdc/pull/1771#issuecomment-2232038327 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] support table splitting process control when read table snapshot [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1625: URL: https://github.com/apache/flink-cdc/pull/1625#issuecomment-2232038412 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] fix bug 'mysql primary key of binary data type is compared incorrectly' [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1816: URL: https://github.com/apache/flink-cdc/pull/1816#issuecomment-2232038243 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] Use cursor fetch by default when snapshot. [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1629: URL: https://github.com/apache/flink-cdc/pull/1629#issuecomment-2232038393 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [tidb-cdc]When the task runs for a period of time, there are only Resolved Events [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1763: URL: https://github.com/apache/flink-cdc/pull/1763#issuecomment-2232038352 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle]Error when TIMESTAMP_LTZ type is encoded in string type [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1800: URL: https://github.com/apache/flink-cdc/pull/1800#issuecomment-2232038280 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [DOC] When type is number,update doc [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1801: URL: https://github.com/apache/flink-cdc/pull/1801#issuecomment-2232038261 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [common] Improve implementation of offset backing store [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1821: URL: https://github.com/apache/flink-cdc/pull/1821#issuecomment-2232038225 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Fix a Bug] add supported for Oracle CDB mode at OracleIncrementalSource [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1836: URL: https://github.com/apache/flink-cdc/pull/1836#issuecomment-2232038204 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [tidb-cdc]fix too many fields cause the value to be NULL [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1890: URL: https://github.com/apache/flink-cdc/pull/1890#issuecomment-2232038127 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oceanBase] add metrics for oceanbase cdc connector [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1863: URL: https://github.com/apache/flink-cdc/pull/1863#issuecomment-2232038188 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql][Improvement] Use debezium SPI way converter data types output. [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1882: URL: https://github.com/apache/flink-cdc/pull/1882#issuecomment-2232038143 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [build] Add maven wrapper [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1876: URL: https://github.com/apache/flink-cdc/pull/1876#issuecomment-2232038165 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle-cdc] Fix read one record in the incremental snapshot [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1918: URL: https://github.com/apache/flink-cdc/pull/1918#issuecomment-2232038022 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [postgresql] Fix debezium-postgresql data loss [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1895: URL: https://github.com/apache/flink-cdc/pull/1895#issuecomment-2232038107 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle-cdc] fix oracle scn huge increment, can not catch up new record in time #1940 [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1941: URL: https://github.com/apache/flink-cdc/pull/1941#issuecomment-2232037993 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle][fix]fix oracle maximum number of processes exceeded [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1903: URL: https://github.com/apache/flink-cdc/pull/1903#issuecomment-2232038092 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1915: URL: https://github.com/apache/flink-cdc/pull/1915#issuecomment-2232038039 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-35313][mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records … [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1907: URL: https://github.com/apache/flink-cdc/pull/1907#issuecomment-2232038069 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle-cdc]Optimized slow oracle real-time synchronization [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2009: URL: https://github.com/apache/flink-cdc/pull/2009#issuecomment-2232037952 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql-cdc] Fix MySqlSplitSerializer ConcurrentModificationException [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #1945: URL: https://github.com/apache/flink-cdc/pull/1945#issuecomment-2232037979 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [tidb]fix the tidb checkpoints to exactly once. [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2038: URL: https://github.com/apache/flink-cdc/pull/2038#issuecomment-2232037933 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [TEST] [WIP] reproduce oracle issue [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2167: URL: https://github.com/apache/flink-cdc/pull/2167#issuecomment-2232037815 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [oracle][fix] support multiple chunkKeys [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2068: URL: https://github.com/apache/flink-cdc/pull/2068#issuecomment-2232037912 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [mysql] Support mysql primary keys using encoding types different fro… [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2069: URL: https://github.com/apache/flink-cdc/pull/2069#issuecomment-2232037880 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] Update mysql binlog connector & changes for transaction payload events [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2134: URL: https://github.com/apache/flink-cdc/pull/2134#issuecomment-2232037835 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Bug][issues-2187] if splitTable method execute fast than getNext, job will be blocked [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2188: URL: https://github.com/apache/flink-cdc/pull/2188#issuecomment-2232037783 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [core] make ObjectUtils can not be instantiated [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2086: URL: https://github.com/apache/flink-cdc/pull/2086#issuecomment-2232037852 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Mysql] Mysql connector can't handle the case sensitive of rename/change column statement (#2144) [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2257: URL: https://github.com/apache/flink-cdc/pull/2257#issuecomment-2232037734 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] Add a AbstractJdbcSourceChunkSplitter to handle common logic [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2244: URL: https://github.com/apache/flink-cdc/pull/2244#issuecomment-2232037758 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [hotfix] Modify the schema and table name snapshot data reading probl… [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2266: URL: https://github.com/apache/flink-cdc/pull/2266#issuecomment-2232037704 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Oracle]修复oracle数据库表主键是NUMBER类型且不指定p,s长度时报校验异常:org.apache.flink.table.api.Val… [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2304: URL: https://github.com/apache/flink-cdc/pull/2304#issuecomment-2232037659 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Oracle]修复oracle数据库scan.incremental.snapshot.chunk.key-column设置不生效的问题 [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2298: URL: https://github.com/apache/flink-cdc/pull/2298#issuecomment-2232037682 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] Update OracleSourceBuilder's constructor to private [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2327: URL: https://github.com/apache/flink-cdc/pull/2327#issuecomment-2232037641 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] Support split snapshot asynchronously [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2329: URL: https://github.com/apache/flink-cdc/pull/2329#issuecomment-2232037623 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Bug][Oracle] oracle 单表全量阶段根据ROWID 字段 split chunk存在BUG [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2339: URL: https://github.com/apache/flink-cdc/pull/2339#issuecomment-2232037601 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [Improve][code style]Format some idea tips [flink-cdc]

2024-07-16 Thread via GitHub
github-actions[bot] commented on PR #2358: URL: https://github.com/apache/flink-cdc/pull/2358#issuecomment-2232037575 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

  1   2   3   >