[
https://issues.apache.org/jira/browse/FLINK-37872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955310#comment-17955310
]
Sai Sharath Dandi commented on FLINK-37872:
---
Hi [~gyfora] , Could you please r
[
https://issues.apache.org/jira/browse/FLINK-37871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37871.
-
Fix Version/s: 2.1.0
Resolution: Fixed
> Remove FlinkRelMdUtil#getJoinDistinctRow
[
https://issues.apache.org/jira/browse/FLINK-37878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955304#comment-17955304
]
Sergey Nuyanzin commented on FLINK-37878:
-
Merged as
[6936b2ae594112622ec09cf6d
[
https://issues.apache.org/jira/browse/FLINK-37878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37878.
-
Fix Version/s: 2.1.0
Resolution: Fixed
> Extract handling of processors in Planne
[
https://issues.apache.org/jira/browse/FLINK-37871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955305#comment-17955305
]
Sergey Nuyanzin commented on FLINK-37871:
-
Merged as
[84054386f8651c82e09b27868
snuyanzin merged PR #26615:
URL: https://github.com/apache/flink/pull/26615
--
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
[
https://issues.apache.org/jira/browse/FLINK-37880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-37880.
Resolution: Duplicate
> build_wheels_on_macos fails every time
> -
gaborgsomogyi commented on code in PR #794:
URL: https://github.com/apache/flink-web/pull/794#discussion_r2116482606
##
docs/content/posts/2025-05-28-release-kubernetes-operator-1.12.0.md:
##
@@ -0,0 +1,61 @@
+---
+title: "Apache Flink Kubernetes Operator 1.12.0 Release Announc
[
https://issues.apache.org/jira/browse/FLINK-37804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955291#comment-17955291
]
Ferenc Csaky commented on FLINK-37804:
--
Merged into release-1.19 via ecbacfd96983ea
[
https://issues.apache.org/jira/browse/FLINK-37804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-37804:
-
Fix Version/s: 1.19.3
1.20.2
2.1.0
2.0.1
Sergey Nuyanzin created FLINK-37880:
---
Summary: build_wheels_on_macos fails every time
Key: FLINK-37880
URL: https://issues.apache.org/jira/browse/FLINK-37880
Project: Flink
Issue Type: Bug
ferenc-csaky opened a new pull request, #797:
URL: https://github.com/apache/flink-web/pull/797
(no comment)
--
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,
rmetzger commented on code in PR #794:
URL: https://github.com/apache/flink-web/pull/794#discussion_r2116107590
##
docs/content/posts/2025-05-28-release-kubernetes-operator-1.12.0.md:
##
@@ -0,0 +1,61 @@
+---
+title: "Apache Flink Kubernetes Operator 1.12.0 Release Announcement
mxm commented on PR #26100:
URL: https://github.com/apache/flink/pull/26100#issuecomment-2922822650
@twalthr Do you mind having a look?
--
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 specifi
1996fanrui commented on code in PR #26619:
URL: https://github.com/apache/flink/pull/26619#discussion_r2116001670
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2ITCase.java:
##
@@ -111,12 +114,13 @@ public void writerAndCommitterExecuteInStreamingMode
[
https://issues.apache.org/jira/browse/FLINK-37870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37870:
---
Labels: pull-request-available (was: )
> Unaligned checkpoint is disabled for all connectio
1996fanrui commented on PR #26619:
URL: https://github.com/apache/flink/pull/26619#issuecomment-2922532180
Thanks @pnowojski for the quick review!
> Actually we still don't have a true ITCase, verifying unaligned
checkpoints are completing 🤔 But I don't have any proposal how to do tha
[
https://issues.apache.org/jira/browse/FLINK-37861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955183#comment-17955183
]
dalongliu commented on FLINK-37861:
---
Good
> FLIP-520: Simplify StructuredType handlin
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115564263
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLookupJoin.java:
##
@@ -211,6 +214,64 @@ public Trans
Sergey Nuyanzin created FLINK-37878:
---
Summary: Extract handling of processors in PlannerBase into
PlannerBase#applyProcessors and make it public
Key: FLINK-37878
URL: https://issues.apache.org/jira/browse/FLINK-
[
https://issues.apache.org/jira/browse/FLINK-37878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37878:
---
Labels: pull-request-available (was: )
> Extract handling of processors in PlannerBase into
snuyanzin merged PR #26618:
URL: https://github.com/apache/flink/pull/26618
--
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
dawidwys commented on code in PR #26313:
URL: https://github.com/apache/flink/pull/26313#discussion_r2115913246
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Lice
flinkbot commented on PR #26620:
URL: https://github.com/apache/flink/pull/26620#issuecomment-2922381182
## CI report:
* e6821c5f9cbf3475af7df1cd92b83e8ca975c04d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37851:
---
Labels: pull-request-available (was: )
> Migrate state processor API from source API v1 to
gaborgsomogyi opened a new pull request, #26620:
URL: https://github.com/apache/flink/pull/26620
## What is the purpose of the change
The state processor API is now depending on data source v1 API and in the PR
I've migrated it to data source v2.
## Brief change log
Migr
[
https://issues.apache.org/jira/browse/FLINK-37879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Gong updated FLINK-37879:
-
Description:
concat function:
!image-2025-05-30-21-01-40-897.png|width=596,height=349!
Caused by: org.
pnowojski commented on code in PR #26619:
URL: https://github.com/apache/flink/pull/26619#discussion_r2115854495
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2ITCase.java:
##
@@ -111,12 +114,13 @@ public void writerAndCommitterExecuteInStreamingMode(
Xin Gong created FLINK-37879:
Summary: transform concat function don't support utf-8 and cast
don't support STRING
Key: FLINK-37879
URL: https://issues.apache.org/jira/browse/FLINK-37879
Project: Flink
pnowojski commented on code in PR #26619:
URL: https://github.com/apache/flink/pull/26619#discussion_r2115854495
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2ITCase.java:
##
@@ -111,12 +114,13 @@ public void writerAndCommitterExecuteInStreamingMode(
flinkbot commented on PR #26618:
URL: https://github.com/apache/flink/pull/26618#issuecomment-2921926950
## CI report:
* 873336fdffc21a4e78634c70c48e0fe8a4df77a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on code in PR #794:
URL: https://github.com/apache/flink-web/pull/794#discussion_r2115820420
##
docs/content/posts/2025-05-28-release-kubernetes-operator-1.12.0.md:
##
@@ -0,0 +1,61 @@
+---
+title: "Apache Flink Kubernetes Operator 1.12.0 Release Announc
gaborgsomogyi commented on code in PR #794:
URL: https://github.com/apache/flink-web/pull/794#discussion_r2115814640
##
docs/content/posts/2025-05-28-release-kubernetes-operator-1.12.0.md:
##
@@ -0,0 +1,61 @@
+---
+title: "Apache Flink Kubernetes Operator 1.12.0 Release Announc
ferenc-csaky opened a new pull request, #796:
URL: https://github.com/apache/flink-web/pull/796
(no comment)
--
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,
davidradl commented on code in PR #26609:
URL: https://github.com/apache/flink/pull/26609#discussion_r2115666380
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -1259,7 +1259,7 @@ public static void setOperatorConfig(
flinkbot commented on PR #26619:
URL: https://github.com/apache/flink/pull/26619#issuecomment-2921971126
## CI report:
* f427fb0e482ecc476b9539790be2347a54962c41 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui opened a new pull request, #26619:
URL: https://github.com/apache/flink/pull/26619
## What is the purpose of the change
[FLINK-37870][checkpoint] Fix the bug that unaligned checkpoint is disabled
for all connections unexpectedly
### Bug reason:
`Set seen = new
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115626093
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java:
##
@@ -481,7 +516,14 @@ private Stre
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115584086
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115619379
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java:
##
@@ -481,7 +516,14 @@ private Stre
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115606722
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/LookupJoinUtil.java:
##
@@ -209,23 +210,30 @@ public static class AsyncLook
snuyanzin opened a new pull request, #26618:
URL: https://github.com/apache/flink/pull/26618
## What is the purpose of the change
The PR extracts logic for applying processors into a separate method and
makes it public in order to allow invoking it in downstream projects
Also r
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115591333
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLookupJoin.java:
##
@@ -294,4 +355,47 @@ protected Tr
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115584086
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115554582
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115564263
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLookupJoin.java:
##
@@ -211,6 +214,64 @@ public Trans
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115564263
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLookupJoin.java:
##
@@ -211,6 +214,64 @@ public Trans
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115545347
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r211555
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java:
##
@@ -310,6 +314,21 @@ protected Tr
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115554582
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
davidradl commented on code in PR #26616:
URL: https://github.com/apache/flink/pull/26616#discussion_r2115548946
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -374,6 +374,15 @@ public class ExecutionConfigO
[
https://issues.apache.org/jira/browse/FLINK-37876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37876:
---
Labels: pull-request-available (was: )
> Introduce key ordered component in runtime
> -
[
https://issues.apache.org/jira/browse/FLINK-37861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955162#comment-17955162
]
Timo Walther commented on FLINK-37861:
--
[~lsy] yes, I'm actively working on it. I s
lvyanquan merged PR #4023:
URL: https://github.com/apache/flink-cdc/pull/4023
--
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.a
joyCurry30 commented on PR #4023:
URL: https://github.com/apache/flink-cdc/pull/4023#issuecomment-2921748383
> I'm wondering why our check style plugin could not discover this issue.
The current version of Spotless does not support removing unused static
imports.
--
This is an auto
darenwkt opened a new pull request, #212:
URL: https://github.com/apache/flink-connector-aws/pull/212
## Purpose of the change
[FLINK-37866] Migrate glue schema registry e2e test to use
aws-kinesis-streams connector
## Verifying this change
This change is
[
https://issues.apache.org/jira/browse/FLINK-37866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37866:
---
Labels: pull-request-available (was: )
> Migrate glue schema registry e2e test to use aws-k
zhyayun opened a new pull request, #4032:
URL: https://github.com/apache/flink-cdc/pull/4032
[https://issues.apache.org/jira/browse/FLINK-37855](url)
MySqlSchemaUtils#listTables and TableDiscoveryUtils#listTables is called to
get the table names of all tables that need to be processed, Ho
[
https://issues.apache.org/jira/browse/FLINK-37855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37855:
---
Labels: pull-request-available (was: )
> Reduce the time cost in MySqlSchemaUtils#listTable
xishuaidelin opened a new pull request, #26616:
URL: https://github.com/apache/flink/pull/26616
## What is the purpose of the change
*This pull request aims to introduce the option and support key ordered
async look up join in planner.*
## Brief change log
1. int
flinkbot commented on PR #26617:
URL: https://github.com/apache/flink/pull/26617#issuecomment-2921616611
## CI report:
* 1e273ac1790952b4c60aabe8c61347e72701edd4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37876:
-
Component/s: Table SQL / Runtime
> Introduce key ordered component in runtime
>
Shuai Xu created FLINK-37877:
Summary: Add the key ordered operator in table runtime
Key: FLINK-37877
URL: https://issues.apache.org/jira/browse/FLINK-37877
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-37877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuai Xu updated FLINK-37877:
-
Component/s: Table SQL / Runtime
> Add the key ordered operator in table runtime
> -
xishuaidelin opened a new pull request, #26617:
URL: https://github.com/apache/flink/pull/26617
## What is the purpose of the change
*This pull request aims to introduce the async execution controller
framework in table runtime.*
## Brief change log
Introduce an
Shuai Xu created FLINK-37876:
Summary: Introduce key ordered component in runtime
Key: FLINK-37876
URL: https://issues.apache.org/jira/browse/FLINK-37876
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #26616:
URL: https://github.com/apache/flink/pull/26616#issuecomment-2921592719
## CI report:
* 5c55211e0976dde3e3c2e490772fe8aaa05c4636 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37875:
---
Labels: pull-request-available (was: )
> Introduce the option and the support of planner
>
[
https://issues.apache.org/jira/browse/FLINK-37875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-37875:
-
Assignee: Shuai Xu
> Introduce the option and the support of planner
>
[
https://issues.apache.org/jira/browse/FLINK-37874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-37874:
-
Assignee: Shuai Xu
> FLIP-519: Introduce async lookup key ordered mode
> --
Shuai Xu created FLINK-37875:
Summary: Introduce the option and the support of planner
Key: FLINK-37875
URL: https://issues.apache.org/jira/browse/FLINK-37875
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-37874:
Summary: FLIP-519: Introduce async lookup key ordered mode
Key: FLINK-37874
URL: https://issues.apache.org/jira/browse/FLINK-37874
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-37870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-37870:
Summary: Unaligned checkpoint is disabled for all connections unexpectedly
(was: Unaligned checkpoint is
[
https://issues.apache.org/jira/browse/FLINK-37223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37223.
Fix Version/s: cdc-3.5.0
Assignee: Yanquan Lv
Resolution: Fixed
Fixed in master vi
lvyanquan merged PR #3894:
URL: https://github.com/apache/flink-cdc/pull/3894
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-37870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-37870:
Description:
FLINK-36287 would disable unaligned checkpoint between {color:#172b4d}the sink
writer and co
[
https://issues.apache.org/jira/browse/FLINK-37814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955130#comment-17955130
]
Stepan Stepanishchev commented on FLINK-37814:
--
Hey, [~gustavodemorais] don
gyfora commented on code in PR #794:
URL: https://github.com/apache/flink-web/pull/794#discussion_r2115295735
##
docs/content/posts/2025-05-28-release-kubernetes-operator-1.12.0.md:
##
@@ -0,0 +1,61 @@
+---
+title: "Apache Flink Kubernetes Operator 1.12.0 Release Announcement"
78 matches
Mail list logo
