[
https://issues.apache.org/jira/browse/FLINK-37450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37450:
--
Description:
Corrected the released version in the release document
[https://flink.apache.org/2025/03
[
https://issues.apache.org/jira/browse/FLINK-37450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37450:
--
Description:
Corrected the released version in the release document
https://flink.apache.org/2025/03/
[
https://issues.apache.org/jira/browse/FLINK-37326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37326.
Resolution: Duplicate
The issue also fixed by FLINK-37429
> The transform module reports an error
nilmadhab commented on PR #26239:
URL: https://github.com/apache/flink/pull/26239#issuecomment-2712844058
@davidradl any update here ?
--
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
lvyanquan commented on PR #3943:
URL: https://github.com/apache/flink-cdc/pull/3943#issuecomment-2712849304
@leonardBang PTAL.
--
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-37449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37449:
---
Labels: pull-request-available (was: )
> Postgres don't commit lsn when taskmanager failove
xuyangzhong commented on code in PR #26162:
URL: https://github.com/apache/flink/pull/26162#discussion_r1987137226
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java:
##
@@ -115,25 +115,26 @@
shameersss1 commented on PR #26162:
URL: https://github.com/apache/flink/pull/26162#issuecomment-2710471947
> `getPartitionsTableStats`
Thanks a lot @xuyangzhong for the review
1. Yes, you are correct, it never stated it skips stats collection from
catalog.
2. Fetching stats
jayadeep-jayaraman commented on PR #26160:
URL: https://github.com/apache/flink/pull/26160#issuecomment-2712455431
+1 (non-binding). This PR updates various versions of the gcs connector to
keep it in sync with the latest changes.
--
This is an automated message from the Apache Git Servic
whhe commented on PR #158:
URL:
https://github.com/apache/flink-connector-jdbc/pull/158#issuecomment-2712470576
This is a big feature and shouldn't be marked as a hotfix. Please create a
JIRA ticket for it https://issues.apache.org/jira/projects/FLINK/issues
--
This is an automated messa
xuyangzhong commented on PR #26162:
URL: https://github.com/apache/flink/pull/26162#issuecomment-2712270418
@shameersss1 Whether we modify the scope of the current configuration or
introduce a new one, it's advisable to implement changes through a Flip, as
these configurations are part of t
qianmoQ closed pull request #157: [hotfix] Support dameng database
URL: https://github.com/apache/flink-connector-jdbc/pull/157
--
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-37308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-37308:
---
Assignee: Xingcan Cui
> HybridSourceReader doesn't support pauseOrResumeSplits
> --
sn-12-3 opened a new pull request, #778:
URL: https://github.com/apache/flink-web/pull/778
Corrected the released version in the release document
https://flink.apache.org/2025/03/03/apache-flink-kubernetes-operator-1.11.0-release-announcement/#release-resources
from =>
The source a
sn-12-3 commented on PR #778:
URL: https://github.com/apache/flink-web/pull/778#issuecomment-2712644840
Hi @1996fanrui, did a minor correction to the release version in the doc,
could you please take a look when feasible?
--
This is an automated message from the Apache Git Service.
To res
leonardBang commented on code in PR #3939:
URL: https://github.com/apache/flink-cdc/pull/3939#discussion_r1988318488
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/TimestampTypeMetadataCo
beliefer commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1988241250
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,10 @@ public static String[] mergeListsToArray(List
base, List append)
[
https://issues.apache.org/jira/browse/FLINK-37429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37429.
Resolution: Resolved
Resolved via master: f309d311f8f79e0108a0666bf8cae7bd609cd2ef
> Map each ori
leonardBang merged PR #3939:
URL: https://github.com/apache/flink-cdc/pull/3939
--
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
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37443:
--
Assignee: Nil Madhab
> Add returns() method to DataStream V2 API for specifying output types
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934079#comment-17934079
]
Weijie Guo commented on FLINK-37443:
Yes, java's type derivation for lambda expressi
Shalini M created FLINK-37450:
-
Summary: Document correction
Key: FLINK-37450
URL: https://issues.apache.org/jira/browse/FLINK-37450
Project: Flink
Issue Type: Improvement
Reporter: S
[
https://issues.apache.org/jira/browse/FLINK-37450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37450:
--
Affects Version/s: 1.11.0
> Document correction
> ---
>
> Key: FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-37450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37450:
--
Labels: pull-request-available website (was: )
> Document correction
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-37450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37450:
--
Component/s: Project Website
> Document correction
> ---
>
> Key: FLIN
Shalini M created FLINK-37451:
-
Summary: Document correction - 1.10.0
Key: FLINK-37451
URL: https://issues.apache.org/jira/browse/FLINK-37451
Project: Flink
Issue Type: Improvement
Re
twalthr opened a new pull request, #26282:
URL: https://github.com/apache/flink/pull/26282
## What is the purpose of the change
Adds support for the `asArgument` expression in Table API.
Python and docs will follow.
## Brief change log
- Adopt ExpressionResolver to
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Affects Version/s: 1.10.0
> Document correction - 1.10.0
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Labels: pull-request-available website (was: )
> Document correction - 1.10.0
> -
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Labels: (was: pull-request-available website)
> Document correction - 1.10.0
> -
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Description:
Corrected the released version in the release document
[https://flink.apache.org/2024/10
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Labels: website (was: )
> Document correction - 1.10.0
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-37451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shalini M updated FLINK-37451:
--
Description:
Corrected the released version in the release document
[https://flink.apache.org/2024/10
Yanquan Lv created FLINK-37452:
--
Summary: Add support for writing to Paimon Append only table.
Key: FLINK-37452
URL: https://issues.apache.org/jira/browse/FLINK-37452
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-37429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934093#comment-17934093
]
Leonard Xu commented on FLINK-37429:
[~xiqian_yu], yes. This ticket will fix FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934095#comment-17934095
]
Yubiao Feng commented on FLINK-34962:
-
[~syhily] [~tison]
They are not the same
lvyanquan opened a new pull request, #3943:
URL: https://github.com/apache/flink-cdc/pull/3943
Update variables name that related to
`scan.incremental.snapshot.unbounded-chunk-first.enabled` option.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/FLINK-37352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37352:
--
Assignee: Yanquan Lv
> Write full changelog to Paimon Sink.
> ---
[
https://issues.apache.org/jira/browse/FLINK-37352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37352.
Resolution: Implemented
Implemented via master: e59a170064051051088c3275fe44b208fbd5763a
> Write
Efrat19 commented on PR #26276:
URL: https://github.com/apache/flink/pull/26276#issuecomment-2709714992
@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.
beliefer commented on code in PR #26273:
URL: https://github.com/apache/flink/pull/26273#discussion_r1986297042
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2218,7 +2218,9 @@ public static LocalStreamEnvironmen
beliefer commented on PR #26278:
URL: https://github.com/apache/flink/pull/26278#issuecomment-2709776602
cc @1996fanrui
--
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
beliefer commented on code in PR #26273:
URL: https://github.com/apache/flink/pull/26273#discussion_r1986790247
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2218,7 +2218,9 @@ public static LocalStreamEnvironmen
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933781#comment-17933781
]
Nil Madhab commented on FLINK-37443:
There is definitely some issue with lamdba expr
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933781#comment-17933781
]
Nil Madhab edited comment on FLINK-37443 at 3/10/25 9:08 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933781#comment-17933781
]
Nil Madhab edited comment on FLINK-37443 at 3/10/25 9:09 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933781#comment-17933781
]
Nil Madhab edited comment on FLINK-37443 at 3/10/25 9:08 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933830#comment-17933830
]
Gabor Somogyi commented on FLINK-37445:
---
Since this is deprecated what is the plan
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933835#comment-17933835
]
Poorvank Bhatia commented on FLINK-37445:
-
Hey [~gaborgsomogyi] , Was planning t
beliefer commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1987127696
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,8 @@ public static String[] mergeListsToArray(List base,
List append)
lianghongjia6 commented on PR #13081:
URL: https://github.com/apache/flink/pull/13081#issuecomment-2710345813
Hi @libenchao, are you still working on this issue? Can you rebase the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
laughingman7743 commented on code in PR #156:
URL:
https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1986988707
##
docs/content/docs/connectors/table/jdbc.md:
##
@@ -45,17 +45,18 @@ See how to link with it for cluster execution [here]({{<
ref "docs/dev/config
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933818#comment-17933818
]
david radley commented on FLINK-28897:
--
[~martijnvisser] [~lsy] [~Jiangang] it see
Poorvank Bhatia created FLINK-37445:
---
Summary: Migrate InputFormatSourceFunction to the Source V2 API
Key: FLINK-37445
URL: https://issues.apache.org/jira/browse/FLINK-37445
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933823#comment-17933823
]
Poorvank Bhatia commented on FLINK-37444:
-
Hey [~afedulov] can you assign this t
MOBIN-F commented on code in PR #3776:
URL: https://github.com/apache/flink-cdc/pull/3776#discussion_r1984763339
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java:
davidradl commented on PR #26277:
URL: https://github.com/apache/flink/pull/26277#issuecomment-2709954754
I see
[docs](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/execution/execution_configuration/)
we should update this test too. around " setParallelism(int par
davidradl commented on code in PR #156:
URL:
https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1986961532
##
docs/content/docs/connectors/table/jdbc.md:
##
@@ -45,17 +45,18 @@ See how to link with it for cluster execution [here]({{<
ref "docs/dev/configura
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1987026403
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26276:
URL: https://github.com/apache/flink/pull/26276#discussion_r1987031302
##
docs/content/docs/ops/metrics.md:
##
@@ -1741,6 +1741,56 @@ Note that the metrics are only available via reporters.
The total number of InputSplits this dat
Timo Walther created FLINK-37446:
Summary: Support asArgument in Table API
Key: FLINK-37446
URL: https://issues.apache.org/jira/browse/FLINK-37446
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-37447:
--
Summary: [Flink CDC] Supports Variant type in YAML API
Key: FLINK-37447
URL: https://issues.apache.org/jira/browse/FLINK-37447
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-37430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-37430:
--
Assignee: Rodrigo Meneses (was: Rodrigo Meneses)
> Operator hides the actual error on deploy
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933883#comment-17933883
]
Poorvank Bhatia commented on FLINK-37445:
-
Yes yes. The handling of bounded sour
snuyanzin commented on code in PR #777:
URL: https://github.com/apache/flink-web/pull/777#discussion_r1988098812
##
docs/content/posts/2025-03-01-release-2.0.0.md:
##
@@ -0,0 +1,1639 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2025-03-01T08:00:00Z"
+title: "Apac
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934016#comment-17934016
]
Alexander Fedulov commented on FLINK-37445:
---
[~martijnvisser] this was just th
afedulov merged PR #950:
URL: https://github.com/apache/flink-kubernetes-operator/pull/950
--
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-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934021#comment-17934021
]
Martijn Visser commented on FLINK-37445:
Gotcha, thanks!
> Migrate InputFormatS
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934016#comment-17934016
]
Alexander Fedulov edited comment on FLINK-37445 at 3/10/25 8:12 PM:
--
laughingman7743 commented on code in PR #156:
URL:
https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1986996966
##
docs/content/docs/connectors/table/jdbc.md:
##
@@ -702,7 +708,7 @@ SELECT * FROM given_database.test_table2;
Data Type Mapping
--
davidradl commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986932185
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,8 @@ public static String[] mergeListsToArray(List base,
List append)
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-37445:
-
Assignee: Poorvank Bhatia
> Migrate InputFormatSourceFunction to the Source V2
[
https://issues.apache.org/jira/browse/FLINK-37302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-37302.
Fix Version/s: 2.1.0
Resolution: Fixed
Fixed in master: 7b35edeb3e343d9d35e432bb2c08f43055b
twalthr merged PR #26250:
URL: https://github.com/apache/flink/pull/26250
--
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
davidradl commented on code in PR #26276:
URL: https://github.com/apache/flink/pull/26276#discussion_r1987028556
##
docs/content/docs/ops/metrics.md:
##
@@ -1741,6 +1741,56 @@ Note that the metrics are only available via reporters.
The total number of InputSplits this dat
[
https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Poorvank Bhatia updated FLINK-37444:
Description:
[ArrowSourceFunction
|https://github.com/apache/flink/blob/master/flink-pyth
ammu20-dev closed pull request #25809: [FLINK-28897] [TABLE-SQL] Backport fix
for fail to use udf in added jar when enabling checkpoint to 1.19.2
URL: https://github.com/apache/flink/pull/25809
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
davidradl commented on code in PR #26276:
URL: https://github.com/apache/flink/pull/26276#discussion_r1987031302
##
docs/content/docs/ops/metrics.md:
##
@@ -1741,6 +1741,56 @@ Note that the metrics are only available via reporters.
The total number of InputSplits this dat
[
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933862#comment-17933862
]
Gabor Somogyi commented on FLINK-37445:
---
Migration requires quite some efforts bec
snuyanzin commented on code in PR #777:
URL: https://github.com/apache/flink-web/pull/777#discussion_r1988098812
##
docs/content/posts/2025-03-01-release-2.0.0.md:
##
@@ -0,0 +1,1639 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2025-03-01T08:00:00Z"
+title: "Apac
[
https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Poorvank Bhatia updated FLINK-37444:
Description:
[ArrowSourceFunction
|https://github.com/apache/flink/blob/master/flink-pyth
[
https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Poorvank Bhatia updated FLINK-37444:
Description:
[ArrowSourceFunction
|https://github.com/apache/flink/blob/master/flink-pyth
[
https://issues.apache.org/jira/browse/FLINK-37444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Poorvank Bhatia updated FLINK-37444:
Description:
[ArrowSourceFunction|https://github.com/apache/flink/blob/master/flink-python
83 matches
Mail list logo
