[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883672#comment-17883672
]
Weijie Guo commented on FLINK-33555:
https://dev.azure.com/apache-flink/apache-flink
loserwang1024 commented on PR #2901:
URL: https://github.com/apache/flink-cdc/pull/2901#issuecomment-2367145529
> Not supporting BATCH execution mode
hi, @LinMingQiang, still not support execution.runtime-mode=BATCH now,
though snapshot mode will read in batch. Because we still don't su
fredia commented on code in PR #25367:
URL: https://github.com/apache/flink/pull/25367#discussion_r1770726474
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -189,6 +194,9 @@ public RecordContext buildContext(Object re
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883670#comment-17883670
]
Weijie Guo commented on FLINK-36166:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883671#comment-17883671
]
Weijie Guo commented on FLINK-36290:
https://dev.azure.com/apache-flink/apache-flink
[ https://issues.apache.org/jira/browse/FLINK-36166 ]
Weijie Guo deleted comment on FLINK-36166:
was (Author: weijie guo):
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=62326&view=logs&j=1c002d28-a73d-5309-26ee-10036d847
[
https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36348:
---
Description:
Found the root cause from downloaded artifacts.
{code:java}
org.apache.flink.runtime.io
[
https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36348:
---
Description:
{code:java}
org.apache.flink.runtime.io.network.netty.exception.LocalTransportExceptio
Weijie Guo created FLINK-36348:
--
Summary: Netty shuffle direct memory consumption end-to-end test
failed due to direct memory OOM
Key: FLINK-36348
URL: https://issues.apache.org/jira/browse/FLINK-36348
P
Zakelly commented on code in PR #25367:
URL: https://github.com/apache/flink/pull/25367#discussion_r1770742198
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -189,6 +194,9 @@ public RecordContext buildContext(Object r
Zakelly commented on code in PR #25367:
URL: https://github.com/apache/flink/pull/25367#discussion_r1770746753
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -189,6 +194,9 @@ public RecordContext buildContext(Object r
fredia merged PR #25360:
URL: https://github.com/apache/flink/pull/25360
--
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
lvyanquan commented on PR #25331:
URL: https://github.com/apache/flink/pull/25331#issuecomment-2367194793
Hi @PatrickRen, could you please help to review this as I'm not really
familiar with the API norms.
--
This is an automated message from the Apache Git Service.
To respond to the mess
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2367194478
@JunRuiLee First of all, apologies for very late reply!
I think the issue is, if source parallelism is not explicitly set and if
`execution.batch.adaptive.auto-parallelism.max-par
[
https://issues.apache.org/jira/browse/FLINK-36321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-36321.
Assignee: Yanfei Lei
Resolution: Fixed
Merged into master via 1d1bf5c8f
> Execute read/writ
xuyangzhong commented on code in PR #25320:
URL: https://github.com/apache/flink/pull/25320#discussion_r1770706342
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/JoinITCase.scala:
##
@@ -99,6 +106,33 @@ class JoinITCase(miniBa
1996fanrui commented on code in PR #25218:
URL: https://github.com/apache/flink/pull/25218#discussion_r1770708552
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAssignerTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Softw
1996fanrui commented on code in PR #25218:
URL: https://github.com/apache/flink/pull/25218#discussion_r1770708552
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAssignerTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Softw
JunRuiLee commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1768349683
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/ChainedOperatorHashInfo.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongmin Qiao updated FLINK-36347:
--
External issue URL: https://github.com/apache/flink-cdc/pull/3616
> Using the offset obtained
[
https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883652#comment-17883652
]
Xuannan Su commented on FLINK-33750:
Most easy-to-remove ConfigOptions are removed
Zakelly commented on code in PR #25367:
URL: https://github.com/apache/flink/pull/25367#discussion_r1770772924
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java:
##
@@ -250,6 +250,13 @@ public void setCurrentKey(K newKey) {
RocMarshal commented on code in PR #25218:
URL: https://github.com/apache/flink/pull/25218#discussion_r1770790841
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAssignerTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Softw
xuyangzhong commented on PR #25334:
URL: https://github.com/apache/flink/pull/25334#issuecomment-2367274893
@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
JunRuiLee closed pull request #25264: [FLINK-33678][streaming-java] Remove
CheckpointStorage related public API.
URL: https://github.com/apache/flink/pull/25264
--
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
XComp commented on PR #25218:
URL: https://github.com/apache/flink/pull/25218#issuecomment-2367315487
Sure, I can take a pass over it today.
--
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 sp
xuyangzhong commented on PR #25266:
URL: https://github.com/apache/flink/pull/25266#issuecomment-2367368865
The failed test is traced by
https://issues.apache.org/jira/browse/FLINK-36293
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
reswqa commented on PR #25347:
URL: https://github.com/apache/flink/pull/25347#issuecomment-2367285342
Thanks for the review, merging...
--
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 specif
reswqa merged PR #25347:
URL: https://github.com/apache/flink/pull/25347
--
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 #25352:
URL: https://github.com/apache/flink/pull/25352#discussion_r1768319833
##
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendLoadingTest.java:
##
@@ -219,29 +218,14 @@ pub
[
https://issues.apache.org/jira/browse/FLINK-36257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-36257.
Fix Version/s: 2.0-preview
Resolution: Done
master(2.0-preview) via 7989f485f109d213dfc5a0d
JunRuiLee commented on PR #25352:
URL: https://github.com/apache/flink/pull/25352#issuecomment-2367290298
Thanks @zhuzhurk , I've updated this pr. 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
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2367214026
To illustrate with an example test case, try changing the `executeJob` and
`createConfiguration` with below code and run `testScheduling`:
```
private void executeJob(Boolean u
MOBIN-F commented on PR #49:
URL:
https://github.com/apache/flink-connector-hbase/pull/49#issuecomment-2367334732
@MartijnVisser can you help to trigger a CI run, 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-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883710#comment-17883710
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-34447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883711#comment-17883711
]
Matthias Pohl commented on FLINK-34447:
---
https://dev.azure.com/apache-flink/apache
reswqa opened a new pull request, #25374:
URL: https://github.com/apache/flink/pull/25374
## What is the purpose of the change
*Remove deprecated API in flink-streaming-java module*
## Brief change log
- *Remove deprecated API in flink-streaming-java module*
[
https://issues.apache.org/jira/browse/FLINK-36346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36346:
---
Labels: pull-request-available (was: )
> Remove deprecated API in flink-streaming-java modu
flinkbot commented on PR #25374:
URL: https://github.com/apache/flink/pull/25374#issuecomment-2366135001
## CI report:
* 530bf52976a08ad3b847e6c1edd2b0304e329090 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zhongmin Qiao created FLINK-36347:
-
Summary: Using the offset obtained after a query transaction as a
high watermark cannot ensure exactly-once semantics.
Key: FLINK-36347
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongmin Qiao updated FLINK-36347:
--
Description:
!image-2024-09-22-16-51-09-930.png|width=891,height=564!
Using the offset obtain
qiaozongmi opened a new pull request, #3616:
URL: https://github.com/apache/flink-cdc/pull/3616
Obtain the high watermark offset and table data in the same transaction
during the Snapshot phase,This ensures that the data retrieved is consistent
and avoids any potential data loss.
--
This
showuon commented on PR #25371:
URL: https://github.com/apache/flink/pull/25371#issuecomment-2365680553
@becketqin , please take a look. 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 th
reswqa merged PR #25324:
URL: https://github.com/apache/flink/pull/25324
--
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
reswqa merged PR #25348:
URL: https://github.com/apache/flink/pull/25348
--
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
Weijie Guo created FLINK-36346:
--
Summary: Remove deprecated API in flink-streaming-java module
Key: FLINK-36346
URL: https://issues.apache.org/jira/browse/FLINK-36346
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongmin Qiao resolved FLINK-36347.
---
Resolution: Fixed
> Using the offset obtained after a query transaction as a high watermark
[
https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883579#comment-17883579
]
Zhongmin Qiao commented on FLINK-36347:
---
Assign this pr to me please. [ https://g
[
https://issues.apache.org/jira/browse/FLINK-36295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36295:
-
Assignee: Zdenek Tison (was: Matthias Pohl)
> AdaptiveSchedulerClusterITCase. testChec
xiangyuf commented on PR #25035:
URL: https://github.com/apache/flink/pull/25035#issuecomment-2366757734
@Zakelly Currently, the serializer's compatibility check assumes the new
serializer and previous serializer should have the same datatype. This does not
apply to compatibility check betw
xishuaidelin commented on code in PR #25320:
URL: https://github.com/apache/flink/pull/25320#discussion_r1770576947
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/JoinITCase.scala:
##
@@ -99,6 +106,33 @@ class JoinITCase(miniB
51 matches
Mail list logo
