[
https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891735#comment-17891735
]
Jake.zhang edited comment on FLINK-36569 at 10/22/24 6:34 AM:
[
https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891735#comment-17891735
]
Jake.zhang commented on FLINK-36569:
add schedule close service in
`org.apache.flin
yunfengzhou-hub commented on PR #25501:
URL: https://github.com/apache/flink/pull/25501#issuecomment-2428319498
Thanks for the update. The runtime part LGTM.
--
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
flinkbot commented on PR #2:
URL: https://github.com/apache/flink/pull/2#issuecomment-2428292787
## CI report:
* 1656356a2b283dbffa1dcec3685025dd32b24cb8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
atu-sharm commented on PR #2:
URL: https://github.com/apache/flink/pull/2#issuecomment-2428292821
Hi @xuyangzhong can you please review this
--
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 t
flinkbot commented on PR #25554:
URL: https://github.com/apache/flink/pull/25554#issuecomment-2428292508
## CI report:
* 98ea2df3c759b9d866b0e0327ec6a06883ff6dc9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36506:
---
Labels: pull-request-available (was: )
> Remove all deprecated methods in `ColumnStats`
> -
atu-sharm opened a new pull request, #2:
URL: https://github.com/apache/flink/pull/2
## What is the purpose of the change
Removing all deprecated methods as per
[FLINK-36506](https://issues.apache.org/jira/browse/FLINK-36506) in
`ColumnStats`
*(For example: This pu
[
https://issues.apache.org/jira/browse/FLINK-36521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36521:
---
Labels: pull-request-available (was: )
> Introduce TtlAwareSerializer to resolve the compat
xiangyuf opened a new pull request, #25554:
URL: https://github.com/apache/flink/pull/25554
## 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 o
[
https://issues.apache.org/jira/browse/FLINK-36503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891725#comment-17891725
]
Atul Sharma commented on FLINK-36503:
-
Hi [~xuyangzhong] can i work on this?
> Remo
[
https://issues.apache.org/jira/browse/FLINK-36506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891724#comment-17891724
]
Atul Sharma commented on FLINK-36506:
-
Hi [~xuyangzhong] can i work on this?
> Remo
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-36578:
-
Description:
The function to convert json to string is different in the snapshot step and
the b
fredia commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1809809121
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java:
##
@@ -67,6 +67,12 @@ default boolean isRestored() {
*/
[
https://issues.apache.org/jira/browse/FLINK-34825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891714#comment-17891714
]
JunboWang commented on FLINK-34825:
---
Interested in this. Please assign it to me. Thank
SML0127 commented on PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#issuecomment-2428093914
@leonardBang @PatrickRen 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 specifi
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-36578:
-
Description:
The function to convert json to string is different in the snapshot step and
the b
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-36578:
-
Description:
The function to convert json to string is different in the snapshot step and
the b
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891706#comment-17891706
]
Lee SeungMin commented on FLINK-36578:
--
PR: https://github.com/apache/flink-cdc/pul
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36578:
---
Labels: pull-request-available (was: )
> Fixed bug when converting json to string
> ---
SML0127 opened a new pull request, #3658:
URL: https://github.com/apache/flink-cdc/pull/3658
The function to convert json to string is different in the snapshot step and
the binlog step.
This causes the following differences.
```d
original data : {"key": "value", "key1": "value1"}
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891704#comment-17891704
]
Lee SeungMin commented on FLINK-36578:
--
assign this pr to me
PTAL [~Leonard], [~re
[
https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-36578:
-
Description:
The function to convert json to string is different in the snapshot step and
the b
Lee SeungMin created FLINK-36578:
Summary: Fixed bug when converting json to string
Key: FLINK-36578
URL: https://issues.apache.org/jira/browse/FLINK-36578
Project: Flink
Issue Type: Bug
yunfengzhou-hub commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1809757295
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java:
##
@@ -67,6 +67,12 @@ default boolean isRestored() {
herunkang2018 commented on code in PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#discussion_r1809718242
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java:
###
herunkang2018 commented on code in PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#discussion_r1809715176
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java:
#
github-actions[bot] commented on PR #3538:
URL: https://github.com/apache/flink-cdc/pull/3538#issuecomment-2427952144
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3539:
URL: https://github.com/apache/flink-cdc/pull/3539#issuecomment-2427952115
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
SamBarker opened a new pull request, #906:
URL: https://github.com/apache/flink-kubernetes-operator/pull/906
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cu
kimgr commented on PR #25340:
URL: https://github.com/apache/flink/pull/25340#issuecomment-2427619439
@becketqin That test fails consistently (before and after fix) with
`java.lang.IllegalStateException: The split fetcher manager has closed.` due to
state validation in `SplitFetcherManager.
jnh5y commented on code in PR #24699:
URL: https://github.com/apache/flink/pull/24699#discussion_r1809434479
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/MatchRecognizeITCase.java:
##
@@ -567,7 +912,7 @@ void testUserDefinedFu
kimgr commented on PR #25340:
URL: https://github.com/apache/flink/pull/25340#issuecomment-2427449905
Thanks, I'll try to hack up a testcase!
--
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 s
becketqin commented on PR #25340:
URL: https://github.com/apache/flink/pull/25340#issuecomment-2427417285
@kimgr Sorry for the late reply. And thanks for the patch.
The patch itself looks good to me. Usually, a test needs to be added to
verify the bug is actually fixed. For race cond
[
https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36542:
-
Fix Version/s: 2.0.0
> Enable upToDateChecking to speed up the spotless
> --
[
https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-36542:
Assignee: Wenjun Ruan
> Enable upToDateChecking to speed up the spotless
> --
ferenc-csaky commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2427353187
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Sharath Dandi updated FLINK-36557:
--
Description:
The KubernetesJobAutoScalerContext is
[cached|https://github.com/apache/
[
https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891612#comment-17891612
]
Sai Sharath Dandi commented on FLINK-36557:
---
Hi [~gyfora] , Could you please h
pnowojski merged PR #94:
URL: https://github.com/apache/flink-benchmarks/pull/94
--
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
pnowojski commented on PR #94:
URL: https://github.com/apache/flink-benchmarks/pull/94#issuecomment-2427270392
I think the problem got resolved by
https://github.com/apache/flink-benchmarks/pull/97
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
zhuzhurk commented on code in PR #25472:
URL: https://github.com/apache/flink/pull/25472#discussion_r1808402242
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFactory.java:
##
@@ -80,6 +83,14 @@ public SchedulerNG createInstance(
f
JuliaBogdan commented on PR #46:
URL:
https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2427101306
> > Hi, @ferenc-csaky. I'm interested in the connector for Flink > 1.18 and
glad to see this PR, thank you for the work! I wonder if there is there
anything that is blockin
[
https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36194:
---
Labels: pull-request-available starter (was: starter)
> Shutdown hook for ExecutionGraphInf
flinkbot commented on PR #25553:
URL: https://github.com/apache/flink/pull/25553#issuecomment-2426917163
## CI report:
* af6861f7c46e6033e5b9afea5f5fce703be10c4c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
eaugene opened a new pull request, #25553:
URL: https://github.com/apache/flink/pull/25553
## What is the purpose of the change
This fixes the race-condition of writing to a closed file in the cluster
shutdown is triggered
## Brief change log
- removing the shut
mateczagany opened a new pull request, #905:
URL: https://github.com/apache/flink-kubernetes-operator/pull/905
With the usual `helm upgrade`, the new FlinkStateSnapshot CRD won't be
installed, and it will need to be installed with `kubectl create`.
--
This is an automated message from the
ferenc-csaky commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2426536625
> @ferenc-csaky Thanks for your review, as far as I know, the index file
will be generated under root/target, this will not be put into binary package,
so will not break the RAT lice
[
https://issues.apache.org/jira/browse/FLINK-35016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35016.
Fix Version/s: 2.0.0
Assignee: Hao Li
Resolution: Fixed
Fixed in master: 2d17f6148
twalthr merged PR #25211:
URL: https://github.com/apache/flink/pull/25211
--
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
michalmw commented on PR #25450:
URL: https://github.com/apache/flink/pull/25450#issuecomment-2426504565
@simplejason or @yangjunhan can you check this?
--
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
[
https://issues.apache.org/jira/browse/FLINK-36502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891523#comment-17891523
]
Shengbo commented on FLINK-36502:
-
Hi [~xuyangzhong], I'd like to work on this subtask a
guluo2016 commented on PR #25153:
URL: https://github.com/apache/flink/pull/25153#issuecomment-2426468450
> Thanks for the contribution
>
> can you please also update `process_function.md` and `sourceSincks.md`,
probably `data_stream_api.md` as well since they have the same issue. May
[
https://issues.apache.org/jira/browse/FLINK-36577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mate Czagany updated FLINK-36577:
-
Description:
There are already two CRD compatibility checks in the
flink-kubernetes-operator-ap
Mate Czagany created FLINK-36577:
Summary: Add compatibility check for FlinkStateSnapshot CRD
Key: FLINK-36577
URL: https://issues.apache.org/jira/browse/FLINK-36577
Project: Flink
Issue Type
tinaselenge commented on code in PR #25445:
URL: https://github.com/apache/flink/pull/25445#discussion_r1808630829
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java:
##
@@ -214,9 +215,12 @@ public ClusterClientProvider
deployApplicat
ferenc-csaky commented on PR #46:
URL:
https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2426418591
> Hi, @ferenc-csaky. I'm interested in the connector for Flink > 1.18 and
glad to see this PR, thank you for the work! I wonder if there is there
anything that is blocking
mateczagany commented on code in PR #758:
URL: https://github.com/apache/flink-web/pull/758#discussion_r1808609610
##
docs/content/posts/2024-10-30-release-kubernetes-operator-1.10.0.md:
##
@@ -0,0 +1,75 @@
+---
+title: "Apache Flink Kubernetes Operator 1.10.0 Release Announcem
JuliaBogdan commented on PR #46:
URL:
https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2426326123
Hi, @ferenc-csaky. I'm interested in the connector for Flink > 1.18 and glad
to see this PR, thank you for the work!
I wonder if there is there anything that is blocking
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891492#comment-17891492
]
Leonard Xu commented on FLINK-34467:
[~arvid] [~ZhenqiuHuang] Could you check your l
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891488#comment-17891488
]
Leonard Xu commented on FLINK-34467:
merged into jdbc connector repo vias main:
72f
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891488#comment-17891488
]
Leonard Xu edited comment on FLINK-34467 at 10/21/24 10:35 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34467:
---
Affects Version/s: jdbc-3.2.0
(was: 1.19.0)
> Implement Lineage Interface
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34467:
---
Fix Version/s: cdc-3.3.0
> Implement Lineage Interface in Jdbc Connector
> -
leonardBang merged PR #137:
URL: https://github.com/apache/flink-connector-jdbc/pull/137
--
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
boring-cyborg[bot] commented on PR #137:
URL:
https://github.com/apache/flink-connector-jdbc/pull/137#issuecomment-2426275936
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891481#comment-17891481
]
xuyang commented on FLINK-36476:
[~davidradl] Good idea. The vast majority of the deleti
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891463#comment-17891463
]
Vincent Woo edited comment on FLINK-34636 at 10/21/24 9:32 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891463#comment-17891463
]
Vincent Woo edited comment on FLINK-34636 at 10/21/24 9:32 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-36568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36568:
---
Assignee: Junrui Li
> IllegalStateException Causes Collect Sink to Fail to Collect Result
> ---
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891463#comment-17891463
]
Vincent Woo commented on FLINK-34636:
-
This issue is occurring in version 1.13.2, an
[
https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35387:
--
Assignee: Hongshun Wang
> PG CDC source support heart beat
>
lvyanquan commented on code in PR #3639:
URL: https://github.com/apache/flink-cdc/pull/3639#discussion_r1808408534
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java:
#
ruanwenjun commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2426100238
@ferenc-csaky Thanks for your review, as far as I know, the index file will
be generated under root/target, this will not be put into binary package, so
will not break the RAT license
[
https://issues.apache.org/jira/browse/FLINK-34636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vincent Woo updated FLINK-34636:
Affects Version/s: 1.13.2
> Requesting exclusive buffers timeout causes repeated restarts and cann
yuxiqian opened a new pull request, #3657:
URL: https://github.com/apache/flink-cdc/pull/3657
Flink CDC has been released and we're preparing for the following 3.3
release. Adding it to migration testing matrix should help us ensuring state
backwards compatibility.
--
This is an automate
[
https://issues.apache.org/jira/browse/FLINK-36568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36568.
---
Fix Version/s: 2.0.0
Resolution: Fixed
2c830898640fe65016763c747c05110bd79b8894
> IllegalStateExcept
zhuzhurk merged PR #25542:
URL: https://github.com/apache/flink/pull/25542
--
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.apac
lvyanquan commented on code in PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#discussion_r1808363691
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java:
#
flinkbot commented on PR #25552:
URL: https://github.com/apache/flink/pull/25552#issuecomment-2425962755
## CI report:
* 5765848fe5d10d5ea875a723f1683645c9efd9bd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36576:
---
Labels: pull-request-available (was: )
> Improving amount-based data balancing distribution
noorall opened a new pull request, #25552:
URL: https://github.com/apache/flink/pull/25552
## What is the purpose of the change
Currently, the DefaultVertexParallelismAndInputInfosDecider is able to
implement a balanced distribution algorithm based on the amount of data and the
numbe
beryllw commented on PR #3649:
URL: https://github.com/apache/flink-cdc/pull/3649#issuecomment-2425946273
@leonardBang Vitess dead link causes CI to fail. Please help to re-trigger
CI.Thanks a lot.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
flinkbot commented on PR #25551:
URL: https://github.com/apache/flink/pull/25551#issuecomment-2425912906
## CI report:
* b99b368660d7e45b2e5e8265e05c778bf4b7c372 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36575:
---
Labels: pull-request-available (was: )
> ExecutionVertexInputInfo supports consuming subpar
noorall opened a new pull request, #25551:
URL: https://github.com/apache/flink/pull/25551
## What is the purpose of the change
Currently, the ExecutionVertexInputInfo describes the task's input through a
combination of a PartitionRange and a SubpartitionRange. However, in the case
o
ferenc-csaky commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2425881444
I think this would be pretty useful, just wondering about if we enable it by
default could it break something in any CI? My understanding is that by default
the index file is placed
Lei Yang created FLINK-36576:
Summary: Improving amount-based data balancing distribution
algorithm for DefaultVertexParallelismAndInputInfosDecider
Key: FLINK-36576
URL: https://issues.apache.org/jira/browse/FLINK-36
[
https://issues.apache.org/jira/browse/FLINK-36576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lei Yang updated FLINK-36576:
-
Description:
Currently, the DefaultVertexParallelismAndInputInfosDecider is able to
implement a balance
Lei Yang created FLINK-36575:
Summary: ExecutionVertexInputInfo supports consuming subpartition
groups
Key: FLINK-36575
URL: https://issues.apache.org/jira/browse/FLINK-36575
Project: Flink
Issu
JunRuiLee closed pull request #25431: [W.I.P] Run tests
URL: https://github.com/apache/flink/pull/25431
--
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:
yuxiqian commented on PR #3614:
URL: https://github.com/apache/flink-cdc/pull/3614#issuecomment-2425837181
Fixed in https://github.com/apache/doris-flink-connector/pull/490
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
yuxiqian closed pull request #3614: [FLINK-36285] Pass default value expression
in AlterColumnTypeEvent
URL: https://github.com/apache/flink-cdc/pull/3614
--
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 g
gracegrimwood commented on code in PR #25550:
URL: https://github.com/apache/flink/pull/25550#discussion_r1808227768
##
flink-rpc/flink-rpc-akka/src/main/resources/META-INF/NOTICE:
##
@@ -6,17 +6,17 @@ The Apache Software Foundation (http://www.apache.org/).
This project bund
yuxiqian commented on PR #3427:
URL: https://github.com/apache/flink-cdc/pull/3427#issuecomment-2425814837
Fixed in #3514
--
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
yuxiqian closed pull request #3427: [hotfix][tests] Separate Pipeline and
Source E2e tests
URL: https://github.com/apache/flink-cdc/pull/3427
--
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 spec
ferenc-csaky commented on PR #25550:
URL: https://github.com/apache/flink/pull/25550#issuecomment-2425809842
1.20 backport of https://github.com/apache/flink/pull/25494, will merge them
together.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ferenc-csaky commented on code in PR #25550:
URL: https://github.com/apache/flink/pull/25550#discussion_r1808220796
##
flink-rpc/flink-rpc-akka/src/main/resources/META-INF/NOTICE:
##
@@ -6,17 +6,17 @@ The Apache Software Foundation (http://www.apache.org/).
This project bundl
98 matches
Mail list logo
