[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892678#comment-17892678
]
Hongshun Wang commented on FLINK-36584:
---
# Issue-1: yes, you can see the argue of
loserwang1024 commented on PR #3030:
URL: https://github.com/apache/flink-cdc/pull/3030#issuecomment-2437022722
I will rebase it.
--
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
atu-sharm commented on PR #2:
URL: https://github.com/apache/flink/pull/2#issuecomment-2436863036
Sure @tinaselenge will do.. thanks!!
--
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
[
https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35387:
---
Labels: pull-request-available (was: )
> PG CDC source support heart beat
> ---
loserwang1024 commented on PR #3667:
URL: https://github.com/apache/flink-cdc/pull/3667#issuecomment-2436996841
@leonardBang @ruanhang1993 , CC
--
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
loserwang1024 opened a new pull request, #3667:
URL: https://github.com/apache/flink-cdc/pull/3667
As shown in FLINK-35387, postgres cdc support:
debezium.heartbeat.action.query
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Yi Cai created FLINK-36601:
--
Summary: Add JobID property to FlinkResultSet
Key: FLINK-36601
URL: https://issues.apache.org/jira/browse/FLINK-36601
Project: Flink
Issue Type: Improvement
Co
Yi Cai created FLINK-36600:
--
Summary: Implement java.sql.Wrapper interface.
Key: FLINK-36600
URL: https://issues.apache.org/jira/browse/FLINK-36600
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-36429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892488#comment-17892488
]
Eaugene Thomas commented on FLINK-36429:
Hi , If anyone is not working on , I am
alnzng commented on PR #907:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/907#issuecomment-2436959770
@gyfora A minor improvement for doc, would you mind helping take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-36599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36599:
---
Labels: pull-request-available (was: )
> Correct the name of the config which enables respo
alnzng opened a new pull request, #907:
URL: https://github.com/apache/flink-kubernetes-operator/pull/907
## What is the purpose of the change
This PR is for fixing the name of the metric config which enables the
response codes group in "[Metrics and
Logging](https://nightlie
[
https://issues.apache.org/jira/browse/FLINK-36599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alan Zhang updated FLINK-36599:
---
Description:
In the "Metrics and Logging" doc, it doesn't use the full name of the operator
config(
Alan Zhang created FLINK-36599:
--
Summary: Correct the name of the config which enables response
codes group
Key: FLINK-36599
URL: https://issues.apache.org/jira/browse/FLINK-36599
Project: Flink
loserwang1024 commented on PR #3510:
URL: https://github.com/apache/flink-cdc/pull/3510#issuecomment-2436894467
> @loserwang1024 Please rebase to master and solove confilcts.
@GOODBOY008 done it, and all the tests are passed.
--
This is an automated message from the Apache Git Serv
[
https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892471#comment-17892471
]
Wenjun Ruan commented on FLINK-36542:
-
After upgrade spotless-maven-plugin version t
[
https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35600:
--
Fix Version/s: cdc-3.3.0
> Data read duplication during the full-to-incremental conversion phase
> ---
cy2008 closed pull request #22498: [FLINK-31928][build] Upgrade okhttp3 to
4.11.0
URL: https://github.com/apache/flink/pull/22498
--
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
[
https://issues.apache.org/jira/browse/FLINK-36032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li resolved FLINK-36032.
---
Release Note: In version 2.0, we changed the default job submission
behavior from submitting the job
[
https://issues.apache.org/jira/browse/FLINK-36032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-36032:
--
Release Note: In 2.0, we changed the default job submission behavior from
submitting the job graph to
SamBarker commented on code in PR #906:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/906#discussion_r1815896525
##
flink-kubernetes-webhook/pom.xml:
##
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
flink-kubernetes-operator-parent
yuxiqian commented on code in PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#discussion_r1815882769
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerLenientITCase.java:
##
@@ -169,6 +171,66 @@ void testSingleSplitSingleTa
[
https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-33696.
--
Release Note: Flink now supports reporting metrics and traces to
OpenTelemetry using gRPC
[
https://issues.apache.org/jira/browse/FLINK-36590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux resolved FLINK-36590.
-
Resolution: Duplicate
Duplicate of FLINK-36520
> Flink CDC does not Support MySQL > 8.0.x
> ---
[
https://issues.apache.org/jira/browse/FLINK-36520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36520:
---
Labels: pull-request-available (was: )
> Flink CDC doesn't support MySQL > 8.0
> --
yuxiqian opened a new pull request, #3666:
URL: https://github.com/apache/flink-cdc/pull/3666
This closes FLINK-36520, FLINK-36590.
Currently, trying to use MySQL CDC with MySQL 8.4 would cause the following
exception:
```
Caused by: org.apache.flink.util.FlinkRuntimeExcepti
github-actions[bot] commented on PR #3572:
URL: https://github.com/apache/flink-cdc/pull/3572#issuecomment-2436543491
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.
--
[
https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenjun Ruan updated FLINK-36542:
Summary: Bump spotless version to 2.35.0 (was: Enable upToDateChecking to
speed up the spotless)
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1814837025
##
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryTestBase.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache Softwa
ferenc-csaky commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2436340186
@ruanwenjun can you pls. rebase on top of the latest master and force-push
again? That wikipedia example got broken a couple days ago, but since then it
was removed, so it does not b
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1815533794
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/facets/KafkaDatasetFacet.java:
##
@@ -0,0 +1,97 @@
+package org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-36512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892485#comment-17892485
]
Prashant Bhardwaj commented on FLINK-36512:
---
[~mapohl] If nobody is working on
vahmed-hamdy commented on PR #30:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/30#issuecomment-2435460105
@snuyanzin Could you please review or nominate a reviewer please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
tinaselenge commented on PR #25564:
URL: https://github.com/apache/flink/pull/25564#issuecomment-2434605355
@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
vahmed-hamdy commented on PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#issuecomment-2434760164
@hlteoh37 gentle reminder if you have any other feedback
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
pnowojski merged PR #25539:
URL: https://github.com/apache/flink/pull/25539
--
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
flinkbot commented on PR #25574:
URL: https://github.com/apache/flink/pull/25574#issuecomment-2435567392
## CI report:
* 4db768dbd95281848b092efdd7fcb2649f1a9c79 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36556:
---
Labels: pull-request-available (was: )
> Allow to configure starting buffer size when using
pnowojski opened a new pull request, #25574:
URL: https://github.com/apache/flink/pull/25574
## What is the purpose of the change
This PR intends to improve the behaviour of buffer debloating.
## Brief change log
[FLINK-36555] Guarantee buffer grows even with very small a
qg-lin commented on code in PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#discussion_r1815121775
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.java:
[
https://issues.apache.org/jira/browse/FLINK-36317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36317:
-
Assignee: Eaugene Thomas
> Populate the ArchivedExecutionGraph with CheckpointStatsSnap
tomncooper opened a new pull request, #25573:
URL: https://github.com/apache/flink/pull/25573
## What is the purpose of the change
Currently, the `flink-table` modules uses json-path 2.7.0. This is
vulnerable to CVE-2023-1370 and CVE-2023-51074.
## Brief change log
Upgr
ruanwenjun commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2435229437
@ferenc-csaky Done, updated the PR title and jira.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
dannycranmer merged PR #132:
URL: https://github.com/apache/flink-connector-kafka/pull/132
--
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-unsubs
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1814885284
##
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java:
##
@@ -0,0 +1,276 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892460#comment-17892460
]
Danny Cranmer commented on FLINK-36595:
---
Merged commit
[{{06159a2}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-36595.
---
Resolution: Fixed
> Supported Flink version for connector documentation does not get matched
yuxiqian commented on code in PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#discussion_r1814417426
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.jav
lvyanquan commented on code in PR #3644:
URL: https://github.com/apache/flink-cdc/pull/3644#discussion_r1814860259
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java:
##
fredia commented on code in PR #25561:
URL: https://github.com/apache/flink/pull/25561#discussion_r1814198955
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -46,21 +54,44 @@ public class ForStFlinkF
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1814845364
##
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java:
##
@@ -0,0 +1,276 @@
+/*
+ * Licensed to the A
yuxiqian opened a new pull request, #3665:
URL: https://github.com/apache/flink-cdc/pull/3665
This closes FLINK-36596. Requires FLINK-36461 being merged first.
As described in docs, omitting `transform[*].projection` field in YAML
definition should be equivalent to `projection: \*` ex
pnowojski commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1814837025
##
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryTestBase.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892455#comment-17892455
]
Hongshun Wang commented on FLINK-36569:
---
[~ft20082] Thanks for your explain, it s
rkhachatryan commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1814757339
##
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryMetricReporterITCase.java:
##
@@ -0,0 +1,276 @@
+/*
+ * Licensed to th
dawidwys commented on code in PR #25171:
URL: https://github.com/apache/flink/pull/25171#discussion_r1814803784
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecMatch.java:
##
@@ -86,7 +89,8 @@ public abstract class
dawidwys commented on code in PR #25171:
URL: https://github.com/apache/flink/pull/25171#discussion_r1814809608
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/MatchRecognizeTestPrograms.java:
##
@@ -121,6 +122,27 @@ public
hlteoh37 merged PR #177:
URL: https://github.com/apache/flink-connector-aws/pull/177
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-36280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HunterXHunter updated FLINK-36280:
--
Attachment: image-2024-10-24-14-17-07-675.png
> Snapshot scan mode do not support batch execut
tomncooper commented on PR #25567:
URL: https://github.com/apache/flink/pull/25567#issuecomment-2434752346
@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
superdiaodiao commented on code in PR #25081:
URL: https://github.com/apache/flink/pull/25081#discussion_r1814637228
##
pom.xml:
##
@@ -2386,6 +2386,9 @@ under the License.
org.apache.flink.types.DoubleValue
superdiaodiao commented on code in PR #25081:
URL: https://github.com/apache/flink/pull/25081#discussion_r1814637228
##
pom.xml:
##
@@ -2386,6 +2386,9 @@ under the License.
org.apache.flink.types.DoubleValue
superdiaodiao commented on code in PR #25081:
URL: https://github.com/apache/flink/pull/25081#discussion_r1814637228
##
pom.xml:
##
@@ -2386,6 +2386,9 @@ under the License.
org.apache.flink.types.DoubleValue
noorall commented on PR #25551:
URL: https://github.com/apache/flink/pull/25551#issuecomment-2434867066
@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.
[
https://issues.apache.org/jira/browse/FLINK-36428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36428:
---
Assignee: maoxingda
> DynamoDb Table API Sink fails when null value in the RowData
[
https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-36595:
-
Assignee: Aleksandr Pilipenko
> Supported Flink version for connector documentation doe
[
https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-36595:
--
Fix Version/s: kafka-3.4.0
> Supported Flink version for connector documentation does not get
ferenc-csaky commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2434614251
@jnh5y @ruanwenjun Thanks for the added thoughts! I am okay with updating
this PR with simply bumping the spotless version to `2.35.0`, putting the index
under `target/` is not harmf
[
https://issues.apache.org/jira/browse/FLINK-36428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-36428.
-
Resolution: Fixed
merged commit
[{{c057031}}|https://github.com/apache/flink-connector
boring-cyborg[bot] commented on PR #173:
URL:
https://github.com/apache/flink-connector-aws/pull/173#issuecomment-2434781963
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
superdiaodiao commented on code in PR #25081:
URL: https://github.com/apache/flink/pull/25081#discussion_r1814637228
##
pom.xml:
##
@@ -2386,6 +2386,9 @@ under the License.
org.apache.flink.types.DoubleValue
superdiaodiao commented on code in PR #25081:
URL: https://github.com/apache/flink/pull/25081#discussion_r1814637228
##
pom.xml:
##
@@ -2386,6 +2386,9 @@ under the License.
org.apache.flink.types.DoubleValue
[
https://issues.apache.org/jira/browse/FLINK-36523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-36523.
-
Resolution: Fixed
merged commit
[{{52870f1}}|https://github.com/apache/flink-connector
[
https://issues.apache.org/jira/browse/FLINK-36596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36596:
---
Labels: pull-request-available (was: )
> YAML Pipeline fails to schema change with no proje
[
https://issues.apache.org/jira/browse/FLINK-36032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-36032:
Fix Version/s: 2.0.0
> FLIP-468: Introducing StreamGraph-Based Job Submission
> --
[
https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36065.
---
Fix Version/s: 2.0.0
Resolution: Done
98f712640555333d5e1842a53441b283ca2f6e29
64cbcd2d4b360f03f7964e
tinaselenge commented on PR #25563:
URL: https://github.com/apache/flink/pull/25563#issuecomment-2434696853
@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
[
https://issues.apache.org/jira/browse/FLINK-36523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36523:
---
Assignee: Abhi Gupta
> DDB Streams connector treating LATEST as TRIM_HORIZON for so
zhuzhurk closed pull request #25472: [FLINK-36065][runtime] Support submit
stream graph.
URL: https://github.com/apache/flink/pull/25472
--
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
Zakelly Lan created FLINK-36598:
---
Summary: [state/forst] Refactor initialization of ForSt db core
Key: FLINK-36598
URL: https://issues.apache.org/jira/browse/FLINK-36598
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-36597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36597:
---
Labels: pull-request-available (was: )
> Optimize SnapshotSplitAssigner error log output
>
MOBIN-F opened a new pull request, #3664:
URL: https://github.com/apache/flink-cdc/pull/3664
Caused by: java.lang.IllegalStateException: Invalid assigner status {}
[NEWLY_ADDED_ASSIGNING_FIN
MOBIN created FLINK-36597:
-
Summary: Optimize SnapshotSplitAssigner error log output
Key: FLINK-36597
URL: https://issues.apache.org/jira/browse/FLINK-36597
Project: Flink
Issue Type: Bug
C
yuxiqian commented on PR #3622:
URL: https://github.com/apache/flink-cdc/pull/3622#issuecomment-2434508943
Also could you please please rebase this PR with latest `master` branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
yux created FLINK-36596:
---
Summary: YAML Pipeline fails to schema change with no projection
fields specified
Key: FLINK-36596
URL: https://issues.apache.org/jira/browse/FLINK-36596
Project: Flink
Issue
fredia commented on code in PR #25561:
URL: https://github.com/apache/flink/pull/25561#discussion_r1814392234
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java:
##
@@ -58,6 +58,22 @@ public class ForStOptions {
86 matches
Mail list logo
