flinkbot commented on PR #25864:
URL: https://github.com/apache/flink/pull/25864#issuecomment-2563427072
## CI report:
* e13c34820a86990c0f8d6575f4ea89bef12e0dc4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36968:
---
Labels: pull-request-available (was: )
> The "values" lookup table used for testing does no
xuyangzhong opened a new pull request, #25864:
URL: https://github.com/apache/flink/pull/25864
## What is the purpose of the change
*This pr tries to fix the 'values' connector only used for testing!*
Currently, the "values" lookup table used for testing does not deduplicate
data with
[
https://issues.apache.org/jira/browse/FLINK-36968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-36968:
---
Summary: The "values" lookup table used for testing does not deduplicate
data with the same pk. (was: The "
xuyang created FLINK-36968:
--
Summary: The "values" lookup table used for testing does not
deduplicate data with the same key.
Key: FLINK-36968
URL: https://issues.apache.org/jira/browse/FLINK-36968
Project:
hql0312 commented on code in PR #3808:
URL: https://github.com/apache/flink-cdc/pull/3808#discussion_r1898300731
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.java:
#
hql0312 commented on code in PR #3808:
URL: https://github.com/apache/flink-cdc/pull/3808#discussion_r1898300731
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.java:
#
loserwang1024 commented on code in PR #3808:
URL: https://github.com/apache/flink-cdc/pull/3808#discussion_r1898288855
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.j
yangjf2019 commented on PR #3820:
URL: https://github.com/apache/flink-cdc/pull/3820#issuecomment-2563332666
Hi @leonardBang ,please take a look in your spare time,thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/FLINK-36967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36967:
---
Labels: pull-request-available (was: )
> Bump dependency of Paimon Pipeline connector to 0.
Jeff Yang created FLINK-36967:
-
Summary: Bump dependency of Paimon Pipeline connector to 0.9.0
Key: FLINK-36967
URL: https://issues.apache.org/jira/browse/FLINK-36967
Project: Flink
Issue Type: I
Zakelly commented on code in PR #25853:
URL: https://github.com/apache/flink/pull/25853#discussion_r1898251815
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AsyncKeyedProcessOperator.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache So
Zakelly commented on code in PR #25818:
URL: https://github.com/apache/flink/pull/25818#discussion_r1898232175
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/filemapping/FileMappingManager.java:
##
@@ -0,0 +1,247 @@
+/*
+ * License
Zakelly commented on code in PR #25818:
URL: https://github.com/apache/flink/pull/25818#discussion_r1898221236
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/filemapping/MappingEntry.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to th
flinkbot commented on PR #25863:
URL: https://github.com/apache/flink/pull/25863#issuecomment-2563280786
## CI report:
* 277e20facee59407b14193e8df80bb04bb805384 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36850:
---
Labels: pull-request-available (was: )
> Disable streamGraph adaptive optimization when ena
JunRuiLee opened a new pull request, #25863:
URL: https://github.com/apache/flink/pull/25863
## What is the purpose of the change
[FLINK-36850][runtime] Disable adaptive batch execution when batch job
progress recovery is enabled
## Brief change log
- Support Int
[
https://issues.apache.org/jira/browse/FLINK-36960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36960:
--
Assignee: xuhuang
> FLIP-467 Introduce Generalized Watermarks for DataStream V2
> ---
fredia commented on code in PR #25853:
URL: https://github.com/apache/flink/pull/25853#discussion_r1897727311
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclarationChain.java:
##
@@ -0,0 +1,216 @@
+/*
+ * Licensed to the Apache Software Found
[
https://issues.apache.org/jira/browse/FLINK-36880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36880:
---
Fix Version/s: 2.0.0
> Hybrid Shuffle support batch job recovery
> -
[
https://issues.apache.org/jira/browse/FLINK-36880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908366#comment-17908366
]
Weijie Guo commented on FLINK-36880:
master(2.0) via 3f247042fa8f310cae44001c9cae48d
reswqa merged PR #25842:
URL: https://github.com/apache/flink/pull/25842
--
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.apache
zhuzhurk commented on code in PR #25578:
URL: https://github.com/apache/flink/pull/25578#discussion_r1898203822
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalHashJoin.scala:
##
@@ -49,7 +49,8 @@ class Batc
yuxiqian commented on PR #3818:
URL: https://github.com/apache/flink-cdc/pull/3818#issuecomment-256397
A little off topic, but we're really lacking E2e tests to real-life data
sinks with complicated writing topologies. #3491 with higher pressure might be
necessary to expose more issues
yuxiqian commented on PR #3818:
URL: https://github.com/apache/flink-cdc/pull/3818#issuecomment-2563220029
Hi @lvyanquan, I have some concern about how BucketAssignOperator works with
schema evolution strategy.
1) FlushEvent now works as a "pipeline drain indicator", which means after
[
https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908355#comment-17908355
]
hql0312 commented on FLINK-36141:
-
i am using flink-cdc-source-connctors 3.2.1, but has
[
https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908355#comment-17908355
]
hql0312 edited comment on FLINK-36141 at 12/27/24 12:58 AM:
github-actions[bot] closed pull request #2069: [mysql] Support mysql primary
keys using encoding types different fro…
URL: https://github.com/apache/flink-cdc/pull/2069
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
github-actions[bot] commented on PR #2069:
URL: https://github.com/apache/flink-cdc/pull/2069#issuecomment-2563181281
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
github-actions[bot] closed pull request #3615: [minor][cdc-connector][mongodb]
Add `op_type` metadata column
URL: https://github.com/apache/flink-cdc/pull/3615
--
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
github-actions[bot] commented on PR #3615:
URL: https://github.com/apache/flink-cdc/pull/3615#issuecomment-2563181213
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
[
https://issues.apache.org/jira/browse/FLINK-34505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908346#comment-17908346
]
Sergey Nuyanzin commented on FLINK-34505:
-
Merged as
[dacb848f84f0993afb2fc809e
snuyanzin merged PR #24375:
URL: https://github.com/apache/flink/pull/24375
--
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
snuyanzin commented on code in PR #25862:
URL: https://github.com/apache/flink/pull/25862#discussion_r1898092185
##
flink-runtime/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker:
##
@@ -0,0 +1,16 @@
+# Licensed to the Apache Software Foundation (ASF) under on
flinkbot commented on PR #25862:
URL: https://github.com/apache/flink/pull/25862#issuecomment-2563072858
## CI report:
* 01a11330799ce77ce398675f8c2c1aee26002911 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Sergey Nuyanzin created FLINK-36966:
---
Summary: Bump mockito to 5.x
Key: FLINK-36966
URL: https://issues.apache.org/jira/browse/FLINK-36966
Project: Flink
Issue Type: Technical Debt
snuyanzin commented on code in PR #25862:
URL: https://github.com/apache/flink/pull/25862#discussion_r1898091164
##
pom.xml:
##
@@ -586,13 +586,13 @@ under the License.
net.bytebuddy
byte-bu
snuyanzin commented on code in PR #25862:
URL: https://github.com/apache/flink/pull/25862#discussion_r1898091068
##
flink-runtime/pom.xml:
##
@@ -301,7 +301,7 @@ under the License.
org.mockito
- mockito-inline
+
[
https://issues.apache.org/jira/browse/FLINK-36966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36966:
---
Labels: pull-request-available (was: )
> Bump mockito to 5.x
> ---
>
>
snuyanzin opened a new pull request, #25862:
URL: https://github.com/apache/flink/pull/25862
## What is the purpose of the change
The PR bumps mockito to 5.14.2
## Brief change log
Bump mockito to 5.14.2, adapt dependencies
## Verifying this change
the change is abo
snuyanzin commented on PR #25840:
URL: https://github.com/apache/flink/pull/25840#issuecomment-2563055430
@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-36948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908337#comment-17908337
]
Sergey Nuyanzin commented on FLINK-36948:
-
Merged as
[bc9a99fa061e4cd2f00374244
snuyanzin merged PR #25839:
URL: https://github.com/apache/flink/pull/25839
--
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
herunkang2018 commented on PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#issuecomment-2562830068
@leonardBang @lvyanquan @yuxiqian Thanks for the review. All comments
resolved, would you like to help review again?
--
This is an automated message from the Apache Git Service.
herunkang2018 commented on PR #3707:
URL: https://github.com/apache/flink-cdc/pull/3707#issuecomment-2562823952
@leonardBang @Jiabao-Sun Could you please help to review this PR? Thanks
very much.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
herunkang2018 commented on PR #3705:
URL: https://github.com/apache/flink-cdc/pull/3705#issuecomment-2562821241
@leonardBang @lvyanquan Could you please help to review this PR if you have
time? Thanks very much.
--
This is an automated message from the Apache Git Service.
To respond to th
herunkang2018 commented on code in PR #3434:
URL: https://github.com/apache/flink-cdc/pull/3434#discussion_r1897949986
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Software Found
flinkbot commented on PR #25861:
URL: https://github.com/apache/flink/pull/25861#issuecomment-2562668121
## CI report:
* d29c7868ee75a6bcff6fbbe5fbbdbf1bba0f8ade UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
aiwenmo commented on PR #3819:
URL: https://github.com/apache/flink-cdc/pull/3819#issuecomment-2562662899
PTAL @lvyanquan @leonardBang
--
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
[
https://issues.apache.org/jira/browse/FLINK-36927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36927:
---
Labels: pull-request-available (was: )
> Introduce slicing & one stage Window Aggregate wit
xuyangzhong opened a new pull request, #25861:
URL: https://github.com/apache/flink/pull/25861
## What is the purpose of the change
Introduce slicing & one stage Window Aggregate with Async State API.
## Brief change log
- *Add window components related to async state s
[
https://issues.apache.org/jira/browse/FLINK-36865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36865:
---
Labels: pull-request-available (was: )
> Provide UNIX_TIMESTAMP series functions in YAML pi
aiwenmo opened a new pull request, #3819:
URL: https://github.com/apache/flink-cdc/pull/3819
(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, e-
SinBex commented on code in PR #25578:
URL: https://github.com/apache/flink/pull/25578#discussion_r1897890840
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashJoin.java:
##
@@ -111,6 +111,9 @@ public class BatchEx
SinBex commented on code in PR #25578:
URL: https://github.com/apache/flink/pull/25578#discussion_r1897888785
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/AdaptiveJoinProcessor.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licens
SinBex commented on code in PR #25578:
URL: https://github.com/apache/flink/pull/25578#discussion_r1897887738
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/AdaptiveJoinProcessor.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-36067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-36067.
--
Fix Version/s: 2.0.0
Resolution: Fixed
mater:
95f9a1605321a55fc22bb81fa503d2a9eac9d433
0ce55c37
JunRuiLee merged PR #25790:
URL: https://github.com/apache/flink/pull/25790
--
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-36963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36963.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Wrong context maintain around `asyncProcessWithK
[
https://issues.apache.org/jira/browse/FLINK-36963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908289#comment-17908289
]
Zakelly Lan commented on FLINK-36963:
-
Merge 19bc0b3 into master
> Wrong context ma
[
https://issues.apache.org/jira/browse/FLINK-35904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908288#comment-17908288
]
Zakelly Lan commented on FLINK-35904:
-
Merge 3165f94 into master
> Test harness for
Zakelly merged PR #25855:
URL: https://github.com/apache/flink/pull/25855
--
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
Zakelly merged PR #25858:
URL: https://github.com/apache/flink/pull/25858
--
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
[
https://issues.apache.org/jira/browse/FLINK-36964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36964:
---
Labels: pull-request-available (was: )
> Fix potential exception when SchemaChange in paral
64 matches
Mail list logo
