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
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
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
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
[
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 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
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.
--
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
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
[
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(
[
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)
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
]
ASF GitHub Bot updated FLINK-36599:
---
Labels: pull-request-available (was: )
> Correct the name of the config which enables respo
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-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
[
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
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
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
[
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
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
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
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:
##
[
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
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
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
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
[
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 #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
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
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
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
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:
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
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
[
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
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-36317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36317:
-
Assignee: Eaugene Thomas
> Populate the ArchivedExecutionGraph with CheckpointStatsSnap
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
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
[
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
[
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
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
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
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...@
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
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
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 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
[
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
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`
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-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-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-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
> ---
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-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
> --
[
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
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
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
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
[
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
>
[
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
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
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
[
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
[
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-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-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
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
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
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-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
[
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
[
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
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.
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
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 {
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
86 matches
Mail list logo
