[
https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37161:
---
Description:
In Flink 2.0, we support the capability of adaptive skewed join optimization
for batch
Zakelly commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2608722972
@pnowojski Glad to see you here. @xuyangzhong is right, you have that
guarantee. The same-key records and timers will happen in order of arrival.
That is, when watermark advance, the time
xuyangzhong commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2608696358
@pnowojski IIUC, the async state operator currently processes watermarks
**only** after all prior async state requests have been completed. That means
when the event time timer is tri
Zakelly merged PR #26053:
URL: https://github.com/apache/flink/pull/26053
--
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-37148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37148:
--
Assignee: xuhuang
> Add documentation for datastream v2 api
> ---
codenohup opened a new pull request, #26057:
URL: https://github.com/apache/flink/pull/26057
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916262#comment-17916262
]
ZhengYu Chen commented on FLINK-36061:
--
I think we should implement this feature ba
flinkbot commented on PR #26057:
URL: https://github.com/apache/flink/pull/26057#issuecomment-2608886489
## CI report:
* d7118feba7756ee0f06f9cc9e2dd87f1c2999c25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly merged PR #26054:
URL: https://github.com/apache/flink/pull/26054
--
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
dianfu commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2608914945
@mina-asham Thanks for the update! These are test failures, could you take a
look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
xintongsong commented on code in PR #26057:
URL: https://github.com/apache/flink/pull/26057#discussion_r1926349435
##
docs/content/docs/dev/datastream-v2/overview.md:
##
@@ -0,0 +1,195 @@
+---
+title: Overview
+weight: 2
+type: docs
+---
+
+
+# Flink DataStream API Programming G
GOODBOY008 commented on PR #3882:
URL: https://github.com/apache/flink-cdc/pull/3882#issuecomment-2608962525
@ruanhang1993 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 co
yuxiqian commented on PR #3884:
URL: https://github.com/apache/flink-cdc/pull/3884#issuecomment-2608981436
Part of this change has been discussed in
https://github.com/apache/flink-cdc/pull/3684#discussion_r1827701219, needs
hearing from @leonardBang 👀
--
This is an automated message fr
dianfu opened a new pull request, #26060:
URL: https://github.com/apache/flink/pull/26060
…am version
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-tr
ruanhang1993 merged PR #3882:
URL: https://github.com/apache/flink-cdc/pull/3882
--
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...@flin
Zakelly commented on PR #103:
URL: https://github.com/apache/flink-benchmarks/pull/103#issuecomment-2609010817
As we can see, the `--add-opens` is successfully added during CI testing.
https://g
yuxiqian opened a new pull request, #3884:
URL: https://github.com/apache/flink-cdc/pull/3884
This is a preparatory PR (for FLINK-37191) mainly focusing on improving test
case effectiveness, including:
* Single-stage CI failure should not cause the whole matrix got cancelled
* Adde
Zakelly Lan created FLINK-37206:
---
Summary: Initialization issue of batching timer service in async
state operators
Key: FLINK-37206
URL: https://issues.apache.org/jira/browse/FLINK-37206
Project: Flink
glorinli opened a new pull request, #26061:
URL: https://github.com/apache/flink/pull/26061
## What is the purpose of the change
A minor typo fix in task_failure_recovery.md's java example code, the
Duration is mispelled Durartion.
## Verifying this change
Doc ch
Dian Fu created FLINK-37207:
---
Summary: Distributed cache set in the DataStream API does not work
if a job use both the Table API & DataStream API
Key: FLINK-37207
URL: https://issues.apache.org/jira/browse/FLINK-37207
ruanhang1993 closed pull request #3879: [hotfix][build] Add release-3.3 docs
build action
URL: https://github.com/apache/flink-cdc/pull/3879
--
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 speci
lvyanquan commented on code in PR #3723:
URL: https://github.com/apache/flink-cdc/pull/3723#discussion_r1926486699
##
docs/content/docs/connectors/pipeline-connectors/elasticsearch.md:
##
@@ -169,7 +169,7 @@ Pipeline Connector Options
optional
(none)
Long
-
[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37207:
Description:
It will clear the distributed cache in the method[
StreamExecutionEnvironment.configure|http
leonardBang commented on PR #3650:
URL: https://github.com/apache/flink-cdc/pull/3650#issuecomment-2609045244
@lvyanquan A rebase action is welcome
--
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
Zakelly Lan created FLINK-37208:
---
Summary: Properly notify a new key is selected for async state
operators
Key: FLINK-37208
URL: https://issues.apache.org/jira/browse/FLINK-37208
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37207:
Description:
It will clear the distributed cache in the method
[StreamExecutionEnvironment.configure|http
lvyanquan commented on code in PR #3723:
URL: https://github.com/apache/flink-cdc/pull/3723#discussion_r1926489573
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/Elasticsearch
[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37207:
---
Labels: pull-request-available (was: )
> Distributed cache set in the DataStream API does n
dianfu opened a new pull request, #26062:
URL: https://github.com/apache/flink/pull/26062
## What is the purpose of the change
*This pull request fixes the issue that the distributed cache was cleared in
StreamExecutionEnvironment.configure. It has side effect that distributed
caches
lvyanquan commented on PR #3650:
URL: https://github.com/apache/flink-cdc/pull/3650#issuecomment-2609084505
> @lvyanquan A rebase action is welcome
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
reswqa commented on code in PR #26057:
URL: https://github.com/apache/flink/pull/26057#discussion_r1926517227
##
docs/content/docs/dev/datastream-v2/building_blocks.md:
##
@@ -0,0 +1,215 @@
+---
+title: Building Blocks
+weight: 3
+type: docs
+---
+
+
+# Building Blocks
+
+DataSt
ruanhang1993 merged PR #3886:
URL: https://github.com/apache/flink-cdc/pull/3886
--
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...@flin
reswqa commented on code in PR #26057:
URL: https://github.com/apache/flink/pull/26057#discussion_r1926520983
##
docs/content/docs/dev/datastream-v2/building_blocks.md:
##
@@ -0,0 +1,215 @@
+---
+title: Building Blocks
+weight: 3
+type: docs
+---
+
+
+# Building Blocks
+
+DataSt
beryllw commented on PR #3723:
URL: https://github.com/apache/flink-cdc/pull/3723#issuecomment-2609091793
> LGTM.
Thanks for your review.
--
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
ChaomingZhang created FLINK-37204:
-
Summary: Add missing StarRocks connector options for 1.2.10.
Key: FLINK-37204
URL: https://issues.apache.org/jira/browse/FLINK-37204
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37205:
Description: It has changed the state cache strategy from size based to
bytes based since Beam 2.42.0 (See
dianfu opened a new pull request, #26058:
URL: https://github.com/apache/flink/pull/26058
## What is the purpose of the change
*This pull request fixes the state cache behavior during bump beam version.
It has changed the state cache strategy from size based to bytes based since
dianfu opened a new pull request, #26059:
URL: https://github.com/apache/flink/pull/26059
…am version
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-tr
[
https://issues.apache.org/jira/browse/FLINK-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37205:
---
Labels: pull-request-available (was: )
> Correct the state cache behavior during bump beam
Dian Fu created FLINK-37205:
---
Summary: Correct the state cache behavior during bump beam version
Key: FLINK-37205
URL: https://issues.apache.org/jira/browse/FLINK-37205
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-37204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37204:
---
Labels: pull-request-available (was: )
> Add missing StarRocks connector options for 1.2.10
[
https://issues.apache.org/jira/browse/FLINK-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37205:
Affects Version/s: 1.20.0
1.19.0
1.18.0
[
https://issues.apache.org/jira/browse/FLINK-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37205:
Affects Version/s: 1.19.1
1.18.1
1.17.2
[
https://issues.apache.org/jira/browse/FLINK-37204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37204:
--
Assignee: ChaomingZhang
> Add missing StarRocks connector options for 1.2.10.
> -
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36061:
--
Assignee: ZhengYu Chen
> Support Apache iceberg for pipeline connector
>
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916295#comment-17916295
]
Leonard Xu commented on FLINK-36061:
Splitting the connector development into two p
ruanhang1993 merged PR #3885:
URL: https://github.com/apache/flink-cdc/pull/3885
--
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...@flin
[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37207:
Attachment: image-2025-01-23-15-34-13-242.png
> Distributed cache set in the DataStream API does not work
[
https://issues.apache.org/jira/browse/FLINK-37207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37207:
Description:
It will clear the distributed cache in the method
[StreamExecutionEnvironment.configure|http
ruanhang1993 opened a new pull request, #3885:
URL: https://github.com/apache/flink-cdc/pull/3885
(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 unsubscrib
ruanhang1993 opened a new pull request, #3886:
URL: https://github.com/apache/flink-cdc/pull/3886
This PR changes docs in master to 3.4-SNAPSHOT
--
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
gaborgsomogyi commented on PR #26035:
URL: https://github.com/apache/flink/pull/26035#issuecomment-2606542484
Not sure why but some of the tests are flaky so rebased to the latest
master. Hope this helps.
--
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915950#comment-17915950
]
Dawid Wysakowicz commented on FLINK-37098:
--
Additional fix in:
* master
** e000
gaborgsomogyi commented on PR #26035:
URL: https://github.com/apache/flink/pull/26035#issuecomment-2606541564
> So this connector will be included in the state-processor-api.jar under
the opt/ folder of the flink distribution, right?
Yeah, it's intended to be optional.
--
This is a
Jiabao Sun created FLINK-37197:
--
Summary: Release flink-connector-mongodb v2.0.0 for Flink 1.20
Key: FLINK-37197
URL: https://issues.apache.org/jira/browse/FLINK-37197
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-37118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-37118:
--
Fix Version/s: cdc-3.4.0
> Enhance flink cdc metrics
> -
>
> Key: FLIN
jiefei30 commented on PR #26034:
URL: https://github.com/apache/flink/pull/26034#issuecomment-2606560021
> If you think the root cause is something different then please share the
details. In my case the mentioned code caused it. Does this work on your end?
Sorry I can't provide more
JEnglandOhalo commented on PR #203:
URL: https://github.com/apache/flink-docker/pull/203#issuecomment-2606591222
> I didn't learn about any plans for 1.20 to support jdk21, or maybe I
missed some discussion.
>
> cc @snuyanzin as you've done most of the work for jdk21 support.
I
[
https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Wu updated FLINK-36631:
--
Fix Version/s: cdc-3.4.0
> Supports reading incremental data from Oracle from a specified SCN
> --
MartijnVisser commented on PR #23844:
URL: https://github.com/apache/flink/pull/23844#issuecomment-2606592216
> Should we temporarily drop support for S3
It's the most used blob storage integration in OS Flink, we can't drop that.
--
This is an automated message from the Apache Git
1996fanrui commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924588749
##
flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/derby/DerbyExtension.java:
##
@@ -76,7 +79,8 @@ p
flinkbot commented on PR #26047:
URL: https://github.com/apache/flink/pull/26047#issuecomment-2606630124
## CI report:
* 73608a77e3f9d8ae510c95219b6d3f80ca38f3de UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on PR #203:
URL: https://github.com/apache/flink-docker/pull/203#issuecomment-2606628533
we had all the tests cron jobs for jdk21 since 1.19
the last bit (for development) is enablement of spotless done in 2.0 since
this task required dropping of jdk 1.8
At the
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915967#comment-17915967
]
melin commented on FLINK-36061:
---
Add compaction optimization? For example, commit executes
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915967#comment-17915967
]
melin edited comment on FLINK-36061 at 1/22/25 8:57 AM:
Add comp
Jiabao-Sun opened a new pull request, #48:
URL: https://github.com/apache/flink-connector-mongodb/pull/48
Drop support for Flink 1.18 and update development version to 2.0-SNAPSHOT
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
gaborgsomogyi commented on PR #26034:
URL: https://github.com/apache/flink/pull/26034#issuecomment-2606652011
Good to hear it's working on your side too.
--
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
101 - 167 of 167 matches
Mail list logo
