[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

2024-10-25 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893031#comment-17893031 ] Anil Dasari commented on FLINK-36584: - I found high watermark info here - [https://

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

2024-10-25 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893029#comment-17893029 ] Anil Dasari commented on FLINK-36584: - "backfill log" mean DB updates during snapsho

[jira] [Commented] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

2024-10-25 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893028#comment-17893028 ] Anil Dasari commented on FLINK-36584: - [~loserwang1024] Thank you for sharing the de

Re: [PR] [BP-1.20][docs] Update Java 17 compatibility docs [flink]

2024-10-25 Thread via GitHub
ferenc-csaky merged PR #25557: URL: https://github.com/apache/flink/pull/25557 -- 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.

Re: [PR] [BP-1.19][docs] Update Java 17 compatibility docs [flink]

2024-10-25 Thread via GitHub
ferenc-csaky merged PR #25558: URL: https://github.com/apache/flink/pull/25558 -- 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.

[PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink]

2024-10-25 Thread via GitHub
liuml07 opened a new pull request, #25576: URL: https://github.com/apache/flink/pull/25576 https://issues.apache.org/jira/browse/FLINK-36604 ## What is the purpose of the change We can add a precondition check and report meaningful error message for debugging. ## Verifyi

Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink]

2024-10-25 Thread via GitHub
flinkbot commented on PR #25576: URL: https://github.com/apache/flink/pull/25576#issuecomment-2439076207 ## CI report: * ce5a58f65a4e29cd717a37a087334ef11d6205fa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

2024-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36604: --- Labels: pull-request-available (was: ) > StreamingJobGraphGenerator::setOperatorConfig chec

Re: [PR] [FLINK-35291] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme [flink-cdc]

2024-10-25 Thread via GitHub
github-actions[bot] commented on PR #3289: URL: https://github.com/apache/flink-cdc/pull/3289#issuecomment-2439061784 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

[jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

2024-10-25 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-36604: - Summary: StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Key: FLINK-36604 URL: https://issues.apache.org/jira/browse/FLINK-36604 Project

Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]

2024-10-25 Thread via GitHub
github-actions[bot] commented on PR #3254: URL: https://github.com/apache/flink-cdc/pull/3254#issuecomment-2439061801 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-35291] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme [flink-cdc]

2024-10-25 Thread via GitHub
github-actions[bot] closed pull request #3289: [FLINK-35291] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme URL: https://github.com/apache/flink-cdc/pull/3289 -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-35589][cdc-common] Support MemorySize type in FlinkCDC ConfigOptions. [flink-cdc]

2024-10-25 Thread via GitHub
github-actions[bot] commented on PR #3437: URL: https://github.com/apache/flink-cdc/pull/3437#issuecomment-2439061718 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-36266][table] Insert into as select * behaves incorrect [flink]

2024-10-25 Thread via GitHub
snuyanzin commented on PR #25316: URL: https://github.com/apache/flink/pull/25316#issuecomment-2438607426 @flinkbot run azure -- 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] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-10-25 Thread via GitHub
snuyanzin commented on PR #25316: URL: https://github.com/apache/flink/pull/25316#issuecomment-2438463937 @flinkbot run azure -- 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] [FLINK-36542] Bump spotless-maven-plugin version to 2.35.0 [flink]

2024-10-25 Thread via GitHub
ferenc-csaky merged PR #25525: URL: https://github.com/apache/flink/pull/25525 -- 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.

[jira] [Updated] (FLINK-36542) Bump spotless version to 2.35.0

2024-10-25 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-36542: - Priority: Minor (was: Major) > Bump spotless version to 2.35.0 > --

[jira] [Closed] (FLINK-36542) Bump spotless version to 2.35.0

2024-10-25 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-36542. Resolution: Fixed [{{5872a7a}}|https://github.com/apache/flink/commit/5872a7afd9ab1646278740f01324

[jira] [Updated] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-36591: --- Fix Version/s: 2.0.0 1.18.2 1.19.2 1

[jira] [Closed] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-36591. -- Resolution: Fixed > WikipediaEditsSourceTest fails in all cases >

[jira] [Commented] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892847#comment-17892847 ] Martijn Visser commented on FLINK-36591: Fixed in: release-1.18: b2a260ac957dac

Re: [PR] [FLINK-36591][BP 1.20] Remove `flink-contrib` [flink]

2024-10-25 Thread via GitHub
MartijnVisser merged PR #25572: URL: https://github.com/apache/flink/pull/25572 -- 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

Re: [PR] [FLINK-36591][BP 1.19] Remove `flink-contrib` [flink]

2024-10-25 Thread via GitHub
MartijnVisser merged PR #25571: URL: https://github.com/apache/flink/pull/25571 -- 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

Re: [PR] [FLINK-36591][BP 1.18] Remove `flink-contrib` [flink]

2024-10-25 Thread via GitHub
MartijnVisser merged PR #25570: URL: https://github.com/apache/flink/pull/25570 -- 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

[PR] [FLINK-36603][Connectors/Prometheus] Fixed spelling of "retryable" and "behavior" [flink-connector-prometheus]

2024-10-25 Thread via GitHub
nicusX opened a new pull request, #10: URL: https://github.com/apache/flink-connector-prometheus/pull/10 ## Purpose of the change Fixed spelling of words "behavior" and "retryable" inconsistently used across the code and the API ## Verifying this change Please make sure

Re: [PR] [FLINK-36556][FLINK-36555] Improve buffer debloating [flink]

2024-10-25 Thread via GitHub
pnowojski merged PR #25574: URL: https://github.com/apache/flink/pull/25574 -- 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.apa

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36603: --- Labels: pull-request-available (was: ) > Inconsistent spelling of "behavior" and "retryable

[jira] [Closed] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36555. -- Fix Version/s: 2.0.0 Resolution: Fixed Merged to master as d488b7a989d > Guarantee deb

[jira] [Updated] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-36556: --- Release Note: When using buffer debloating, during job's startup or recovery, when we don't

[jira] [Closed] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36556. -- Fix Version/s: 2.0.0 Release Note: When using buffer debloating, during job's startup int

[jira] [Closed] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-36593. -- Fix Version/s: 2.0.0 Assignee: Thomas Cooper Resolution: Fixed Fixed in apache

Re: [PR] [FLINK-36593][flink-runtime] Update io.airlift:aircompressor to 0.27 [flink]

2024-10-25 Thread via GitHub
MartijnVisser merged PR #25567: URL: https://github.com/apache/flink/pull/25567 -- 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

Re: [PR] Support config yaml [flink-kubernetes-operator]

2024-10-25 Thread via GitHub
myskaludek commented on PR #848: URL: https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2437590183 Hi I made changes to helm template file, but operator pod will not start with error ``` Exception in thread "main" org.apache.flink.configuration.IllegalC

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36603: --- Description: The spelling of the word "behavior" is inconsistent across the API e.g. {{.set

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36603: --- Summary: Inconsistent spelling of "behavior" and "retryable" across the API (was: Inconsist

Re: [PR] [FLINK-36571][web] Fix issue to allow Busy and Backpressure numbers o… [flink]

2024-10-25 Thread via GitHub
hlteoh37 commented on PR #25548: URL: https://github.com/apache/flink/pull/25548#issuecomment-2437902849 @flinkbot run azure -- 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.

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CV

Re: [PR] [FLINK-36571][web] Fix issue to allow Busy and Backpressure numbers o… [flink]

2024-10-25 Thread via GitHub
hlteoh37 commented on PR #25548: URL: https://github.com/apache/flink/pull/25548#issuecomment-2437865377 CI seems to be failing because of editing a wiki -.- 99.9% sure it's not related to this change! ![image](https://github.com/user-attachments/assets/219bd6c8-b03b-42dd-9fea-306f3e

[jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36603: -- Summary: Inconsistent spelling of "behavior" across the API Key: FLINK-36603 URL: https://issues.apache.org/jira/browse/FLINK-36603 Project: Flink Issue

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CVE

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Issue Type: Improvement (was: Technical Debt) > Upgrade Calcite version to 1.38.0 > -

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Affects Version/s: 2.0-preview > Upgrade Calcite version to 1.38.0 > -

[jira] [Updated] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper updated FLINK-36602: -- Description: The currently used Calcite version (1.32) has a high severity vulnerability ([CVE

[jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0

2024-10-25 Thread Thomas Cooper (Jira)
Thomas Cooper created FLINK-36602: - Summary: Upgrade Calcite version to 1.38.0 Key: FLINK-36602 URL: https://issues.apache.org/jira/browse/FLINK-36602 Project: Flink Issue Type: Technical Deb

[jira] [Assigned] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-36377: -- Assignee: Yang Li > Support the use of the LAST_VALUE aggregate function on ROW type

[jira] [Commented] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-10-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892801#comment-17892801 ] Martijn Visser commented on FLINK-36377: [~dezhouliyang] I've assigned it to you

Re: [PR] Support config yaml [flink-kubernetes-operator]

2024-10-25 Thread via GitHub
myskaludek commented on PR #848: URL: https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2437587335 Hi , i made changes to helm template and in values set ```yaml defaultConfiguration: standardYaml: true ``` The operator dont start pod with errror

Re: [PR] [FLINK-36542] Bump spotless-maven-plugin version to 2.35.0 [flink]

2024-10-25 Thread via GitHub
ruanwenjun commented on PR #25525: URL: https://github.com/apache/flink/pull/25525#issuecomment-2437568942 Done. -- 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 unsubscr

Re: [PR] [FLINK-36589][state/runtime] Decouple the initialization of sync and async keyed statebackend [flink]

2024-10-25 Thread via GitHub
Zakelly commented on PR #25560: URL: https://github.com/apache/flink/pull/25560#issuecomment-2437562920 @flinkbot run azure -- 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.

[jira] [Comment Edited] (FLINK-33571) Bump json-path from 2.7.0 to 2.8.0

2024-10-25 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892173#comment-17892173 ] Thomas Cooper edited comment on FLINK-33571 at 10/24/24 2:46 PM: -

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-25 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1816437897 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-33137] Prometheus connector docs [flink-connector-prometheus]

2024-10-25 Thread via GitHub
nicusX commented on PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#issuecomment-2437409370 New [docs preview](https://github.com/user-attachments/files/17520427/prometheus-connectr-docs-preview.pdf) with latest changes -- This is an automated message fro

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-25 Thread via GitHub
pawel-big-lebowski commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1816418355 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink]

2024-10-25 Thread via GitHub
noorall commented on code in PR #25414: URL: https://github.com/apache/flink/pull/25414#discussion_r1816403718 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/StreamEdgeUpdateRequestInfo.java: ## @@ -0,0 +1,62 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [FLINK-36591][BP 1.18] Remove `flink-contrib` [flink]

2024-10-25 Thread via GitHub
MartijnVisser commented on PR #25570: URL: https://github.com/apache/flink/pull/25570#issuecomment-2437305946 @flinkbot run azure -- 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 comm

Re: [PR] [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot [flink]

2024-10-25 Thread via GitHub
xiangyuf commented on PR #25554: URL: https://github.com/apache/flink/pull/25554#issuecomment-2437301871 @Zakelly hi, all comments have been resolved. Would you kindly take a look when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, p

Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink]

2024-10-25 Thread via GitHub
tinaselenge commented on PR #25565: URL: https://github.com/apache/flink/pull/25565#issuecomment-2437269158 @flinkbot run azure -- 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 commen

Re: [PR] [FLINK-36490][TABLE API] Remove the deprecated method in DataStreamScanProvider [flink]

2024-10-25 Thread via GitHub
tinaselenge commented on PR #25563: URL: https://github.com/apache/flink/pull/25563#issuecomment-2437266570 Failing test seems to be unrelated to this change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] [FLINK-36491][TABLE API] Remove the deprecated method in DataStreamSinkProvider [flink]

2024-10-25 Thread via GitHub
tinaselenge commented on PR #25564: URL: https://github.com/apache/flink/pull/25564#issuecomment-2437263499 Failing test is unrelated to this change. -- 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

Re: [PR] [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot [flink]

2024-10-25 Thread via GitHub
xiangyuf commented on code in PR #25554: URL: https://github.com/apache/flink/pull/25554#discussion_r1816289307 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF

Re: [PR] [FLINK-36591][BP 1.20] Remove `flink-contrib` [flink]

2024-10-25 Thread via GitHub
flinkbot commented on PR #25572: URL: https://github.com/apache/flink/pull/25572#issuecomment-2432909372 ## CI report: * f6802244c03f4855910a9bbfc8585c63005d437b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34792) [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1

2024-10-25 Thread wangli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangli updated FLINK-34792: --- Attachment: image-2024-10-25-16-00-58-373.png > [Bug] Incremental source never switches to streaming mode wi

[jira] [Commented] (FLINK-34792) [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1

2024-10-25 Thread wangli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892701#comment-17892701 ] wangli commented on FLINK-34792: I think there are two problems here. # If checkpointin

Re: [PR] [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot [flink]

2024-10-25 Thread via GitHub
xiangyuf commented on code in PR #25554: URL: https://github.com/apache/flink/pull/25554#discussion_r1816190153 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF

Re: [PR] [FLINK-33571][table] Backport json-path upgrade to deal with CVE [flink]

2024-10-25 Thread via GitHub
tomncooper commented on PR #25573: URL: https://github.com/apache/flink/pull/25573#issuecomment-2435518436 This is failing to build with JDK 11 but the main `release-1.20` branch also fails to build with JDK 11 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-36317) Populate the ArchivedExecutionGraph with CheckpointStatsSnapshot data if in WaitingForResources state with a previousExecutionGraph being set

2024-10-25 Thread Eaugene Thomas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892498#comment-17892498 ] Eaugene Thomas commented on FLINK-36317: Hi [~mapohl]  , Can you assign to me ? 

Re: [PR] [FLINK-36460] Refactoring the CI matrix [flink-kubernetes-operator]

2024-10-25 Thread via GitHub
SamBarker commented on PR #893: URL: https://github.com/apache/flink-kubernetes-operator/pull/893#issuecomment-2437141425 This shows it in action on my fork: ![Screenshot 2024-10-25 at 8 58 16  pm](https://github.com/user-attachments/assets/6e69c7b2-eaea-4b35-abe5-c898d02b2461) -- Thi

Re: [PR] [FLINK-36460] Refactoring the CI matrix [flink-kubernetes-operator]

2024-10-25 Thread via GitHub
SamBarker commented on PR #893: URL: https://github.com/apache/flink-kubernetes-operator/pull/893#issuecomment-2437138461 @gyfora alternative CI matrix as requested. Even if the matrix proposed in this PR doesn't feel "right" it sets things up so that the matrix is considerably easier to c

[jira] [Updated] (FLINK-34792) [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1

2024-10-25 Thread wangli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangli updated FLINK-34792: --- Attachment: (was: image-2024-10-25-15-46-28-124.png) > [Bug] Incremental source never switches to stream

Re: [PR] [FLINK-36571][web] Fix issue to allow Busy and Backpressure numbers o… [flink]

2024-10-25 Thread via GitHub
hlteoh37 commented on PR #25548: URL: https://github.com/apache/flink/pull/25548#issuecomment-2437121774 @flinkbot run azure -- 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.

[jira] [Updated] (FLINK-34792) [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1

2024-10-25 Thread wangli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangli updated FLINK-34792: --- Attachment: image-2024-10-25-15-46-28-124.png > [Bug] Incremental source never switches to streaming mode wi

Re: [PR] [oracle]Use Incremental Snapshot Framework for Oracle CDC Connector [flink-cdc]

2024-10-25 Thread via GitHub
tttzzzwww commented on PR #1079: URL: https://github.com/apache/flink-cdc/pull/1079#issuecomment-2437099920 hello!In flink cdc 2.2, flink does need to build table permission and write permission, because in io.debezium.connector. oracle.logminer Log location of the latest read to be logged,

Re: [PR] [FLINK-36600][FLINK-36601][jdbc-driver] Improve Flink SQL JDBC [flink]

2024-10-25 Thread via GitHub
cy2008 commented on PR #25575: URL: https://github.com/apache/flink/pull/25575#issuecomment-2437089614 @flinkbot run azure -- 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. T

[jira] [Updated] (FLINK-36600) Implement java.sql.Wrapper interface.

2024-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36600: --- Labels: pull-request-available (was: ) > Implement java.sql.Wrapper interface. > --

Re: [PR] [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot [flink]

2024-10-25 Thread via GitHub
Zakelly commented on code in PR #25554: URL: https://github.com/apache/flink/pull/25554#discussion_r1814205003 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics [flink-cdc]

2024-10-25 Thread via GitHub
ruanhang1993 commented on code in PR #3619: URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1816066674 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/HybridSplitAssigner.java: ## @

Re: [PR] [FLINK-36428][Connectors/DynamoDB] DynamoDb Table API Sink fails when null value in the RowData [flink-connector-aws]

2024-10-25 Thread via GitHub
hlteoh37 merged PR #173: URL: https://github.com/apache/flink-connector-aws/pull/173 -- 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...@

Re: [PR] [FLINK-34466] Lineage interfaces for kafka connector [flink-connector-kafka]

2024-10-25 Thread via GitHub
AHeise commented on code in PR #130: URL: https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1815533393 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/facets/KafkaDatasetFacet.java: ## @@ -0,0 +1,97 @@ +package org.apache.flink

Re: [PR] [FLINK-33571][table] Backport json-path upgrade to deal with CVE [flink]

2024-10-25 Thread via GitHub
flinkbot commented on PR #25573: URL: https://github.com/apache/flink/pull/25573#issuecomment-2435389238 ## CI report: * 16b263e8fec166a065f50877b6aa9491e1c43fca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36593][flink-runtime] Update io.airlift:aircompressor to 0.27 [flink]

2024-10-25 Thread via GitHub
tomncooper commented on PR #25567: URL: https://github.com/apache/flink/pull/25567#issuecomment-2435193363 @flinkbot run azure -- 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] Improve Flink SQL JDBC [flink]

2024-10-25 Thread via GitHub
flinkbot commented on PR #25575: URL: https://github.com/apache/flink/pull/25575#issuecomment-2437053426 ## CI report: * 866e0fd0b4a546dbd8e3dc340a8b29468839b41b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Improve Flink SQL JDBC [flink]

2024-10-25 Thread via GitHub
cy2008 opened a new pull request, #25575: URL: https://github.com/apache/flink/pull/25575 ## What is the purpose of the change Improve Flink SQL JDBC ## Brief change log [FLINK-36600][jdbc-driver] Implement java.sql.Wrapper interface [FLINK-36600][jdbc-driv