masteryhx commented on code in PR #24461:
URL: https://github.com/apache/flink/pull/24461#discussion_r1535027271
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java:
##
@@ -122,8 +121,9 @@
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-33121:
---
Description:
We make the assumption that Global Failures (with null Task
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-33121:
---
Description:
We make the assumption that Global Failures (with null Task
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-33121:
---
Description:
We make the assumption that Global Failures (with null Task
flinkbot commented on PR #24553:
URL: https://github.com/apache/flink/pull/24553#issuecomment-2014352795
## CI report:
* aba805d48cecbc21eeb32da963e62581255bc7a8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33985:
---
Labels: pull-request-available (was: )
> Support obtain all partitions existing in cluster
JunRuiLee opened a new pull request, #24553:
URL: https://github.com/apache/flink/pull/24553
## What is the purpose of the change
[FLINK-33985][runtime] Support obtain all partitions existing in cluster
through ShuffleMaster.
## Brief change log
-
rovboyko commented on PR #21406:
URL: https://github.com/apache/flink/pull/21406#issuecomment-2014338903
@Myasuka after implementation of
[FLINK-30535](https://issues.apache.org/jira/browse/FLINK-30535) and
[FLINK-33881](https://issues.apache.org/jira/browse/FLINK-33881) I changed the
masteryhx commented on code in PR #24461:
URL: https://github.com/apache/flink/pull/24461#discussion_r1535027271
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java:
##
@@ -122,8 +121,9 @@
[
https://issues.apache.org/jira/browse/FLINK-34516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34516.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged 8fac8046...77945916 into master
> Move
masteryhx commented on PR #24381:
URL: https://github.com/apache/flink/pull/24381#issuecomment-2014287639
merged 8fac8046...77945916 into master
--
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
masteryhx closed pull request #24381: [FLINK-34516] Move CheckpointingMode to
flink-core
URL: https://github.com/apache/flink/pull/24381
--
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
lincoln-lil merged PR #24514:
URL: https://github.com/apache/flink/pull/24514
--
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:
lincoln-lil merged PR #24515:
URL: https://github.com/apache/flink/pull/24515
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34731.
---
Resolution: Done
master: cf0d75c4bb324825a057dc72243bb6a2046f8479
> Remove SpeculativeScheduler and
zhuzhurk closed pull request #24524: [FLINK-34731][runtime] Remove
SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler.
URL: https://github.com/apache/flink/pull/24524
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
Zakelly commented on code in PR #24461:
URL: https://github.com/apache/flink/pull/24461#discussion_r1534971391
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceRescaleITCase.java:
##
@@ -122,8 +121,9 @@
[
https://issues.apache.org/jira/browse/FLINK-34909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaotouming updated FLINK-34909:
Summary: OceanBase transctionID by Flink CDC (was: OceanBase事务ID需求)
> OceanBase transctionID by
[
https://issues.apache.org/jira/browse/FLINK-34909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaotouming updated FLINK-34909:
Description: want to get OceanBase transctionID by Flink CDC (was:
可以通过flink data
[
https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829718#comment-17829718
]
Thorne commented on FLINK-34903:
ok,tks,i have do it
> Add mysql-pipeline-connector with
[
https://issues.apache.org/jira/browse/FLINK-34909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-34909.
--
Resolution: Invalid
Please change to English to describe your ticket, feel free to reopen once
[
https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829715#comment-17829715
]
Hongshun Wang commented on FLINK-34903:
---
[~fffy] , Please change PR titile by
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-32513:
---
Assignee: Jeyhun Karimov
> Job in BATCH mode with a significant number of transformations freezes
rkhachatryan commented on PR #24550:
URL: https://github.com/apache/flink/pull/24550#issuecomment-2013992333
Sure, my theory is that although the order is correct, the write to this
field (`loggingEvents`) might not be visible to other threads, including
threads started by Flink and
snuyanzin merged PR #92:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/92
--
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:
flinkbot commented on PR #24552:
URL: https://github.com/apache/flink/pull/24552#issuecomment-2013078895
## CI report:
* d19f36951321edaed8d17c5a8bfe310ef4b2521d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34902:
---
Labels: pull-request-available (was: )
> INSERT INTO column mismatch leads to
jeyhunkarimov opened a new pull request, #24552:
URL: https://github.com/apache/flink/pull/24552
## What is the purpose of the change
Column mismatch validation error should not throw IndexOutOfBoundsException
## Brief change log
- Check column mismatch for SELECT
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829636#comment-17829636
]
Chloe He commented on FLINK-34898:
--
[~hackergin] I have updated the title and the content of this
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chloe He updated FLINK-34898:
-
Affects Version/s: 1.19.0
Description:
I want to construct data that consists of arrays of
[
https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829635#comment-17829635
]
Kumar Mallikarjuna commented on FLINK-34239:
Hello [~Zhanghao Chen] , [~zjureel], I've
snuyanzin commented on code in PR #24285:
URL: https://github.com/apache/flink/pull/24285#discussion_r1534233653
##
flink-end-to-end-tests/run-nightly-tests.sh:
##
@@ -125,30 +125,28 @@ function run_group_1 {
# Docker / Container / Kubernetes tests
[
https://issues.apache.org/jira/browse/FLINK-34910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-34910.
Resolution: Fixed
Fixed in 709bf93534fcdfd2b4452667af450f1748bf1ccc
> Can not plan
dawidwys merged PR #24549:
URL: https://github.com/apache/flink/pull/24549
--
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:
XComp commented on PR #24550:
URL: https://github.com/apache/flink/pull/24550#issuecomment-2012773585
Can you elaborate a bit why this would solve the issue? Isn't `beforeEach`
called only once per test method? :thinking:
--
This is an automated message from the Apache Git Service.
To
XComp commented on PR #24285:
URL: https://github.com/apache/flink/pull/24285#issuecomment-2012732613
I rebased the branch to most-recent `master`. But it won't make much of a
difference: The failed tests in CI are unrelated to the changes of this PR.
--
This is an automated message from
XComp commented on PR #24285:
URL: https://github.com/apache/flink/pull/24285#issuecomment-2012724874
> this thing from PR description is not clear to me
> if we temporarily enable it, what is the long term plan here?
I was referring to commit
snuyanzin commented on PR #24285:
URL: https://github.com/apache/flink/pull/24285#issuecomment-2012704935
should it be rebased because of FLINK-34718
to be sure that ci is green?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-34911:
Description:
[
https://issues.apache.org/jira/browse/FLINK-34911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34911:
--
Component/s: Runtime / State Backends
> ChangelogRecoveryRescaleITCase failed fatally with
[
https://issues.apache.org/jira/browse/FLINK-34911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34911:
--
Priority: Critical (was: Major)
> ChangelogRecoveryRescaleITCase failed fatally with 127
Ryan Skraba created FLINK-34911:
---
Summary: ChangelogRecoveryRescaleITCase failed fatally with 127
exit code
Key: FLINK-34911
URL: https://issues.apache.org/jira/browse/FLINK-34911
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829596#comment-17829596
]
lincoln lee edited comment on FLINK-34713 at 3/21/24 2:59 PM:
--
master also
[
https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829244#comment-17829244
]
lincoln lee edited comment on FLINK-34706 at 3/21/24 2:59 PM:
--
# (/)
[
https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829596#comment-17829596
]
lincoln lee commented on FLINK-34713:
-
master also needed:
[
https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829244#comment-17829244
]
lincoln lee edited comment on FLINK-34706 at 3/21/24 2:57 PM:
--
# (/)
lincoln-lil merged PR #24551:
URL: https://github.com/apache/flink/pull/24551
--
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:
lincoln-lil commented on PR #24551:
URL: https://github.com/apache/flink/pull/24551#issuecomment-2012514631
Skip the ci for just fixing the master doc build to restore the web link
`https://nightlies.apache.org/flink/flink-docs-stable/` pointing to 1.19.0
instead of 1.18.1
--
This is an
lincoln-lil opened a new pull request, #24551:
URL: https://github.com/apache/flink/pull/24551
Sync the docs build changes with 1.19
https://github.com/apache/flink/pull/24518
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
snuyanzin opened a new pull request, #94:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/94
The PR drops support for Flink 1.16 and adds 1.20 snapshot
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
snuyanzin opened a new pull request, #93:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/93
jackson from 2.13.4.20221013 to 2.15.3
junit5 from 5.9.1 to 5.10.2
assertj from 3.23.1 to 3.25.3
testcontainers from 1.17.2 to 1.19.7
mockito from 3.4.6 to 3.12.4
--
[
https://issues.apache.org/jira/browse/FLINK-34435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34435.
-
Resolution: Fixed
> Bump org.yaml:snakeyaml from 1.31 to 2.2 for
[
https://issues.apache.org/jira/browse/FLINK-34435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-34435.
---
> Bump org.yaml:snakeyaml from 1.31 to 2.2 for flink-connector-elasticsearch
>
[
https://issues.apache.org/jira/browse/FLINK-34435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829575#comment-17829575
]
Sergey Nuyanzin commented on FLINK-34435:
-
Merged as
[
https://issues.apache.org/jira/browse/FLINK-34435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34435:
---
Labels: pull-request-available (was: )
> Bump org.yaml:snakeyaml from 1.31 to 2.2 for
boring-cyborg[bot] commented on PR #90:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/90#issuecomment-2012397218
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message,
snuyanzin merged PR #90:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/90
--
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:
snuyanzin merged PR #89:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/89
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-34893.
---
> Bump Checkstyle to 9+
> -
>
> Key: FLINK-34893
>
[
https://issues.apache.org/jira/browse/FLINK-34893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34893.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> Bump Checkstyle to 9+
>
[
https://issues.apache.org/jira/browse/FLINK-34893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829567#comment-17829567
]
Sergey Nuyanzin commented on FLINK-34893:
-
Merged as
snuyanzin merged PR #24540:
URL: https://github.com/apache/flink/pull/24540
--
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:
snuyanzin commented on PR #24540:
URL: https://github.com/apache/flink/pull/24540#issuecomment-2012349819
Thanks for taking a look @RyanSkraba
--
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
flinkbot commented on PR #24550:
URL: https://github.com/apache/flink/pull/24550#issuecomment-2012310006
## CI report:
* 040e396ae5a8c84a62bc1b305dc222bb313a2940 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829560#comment-17829560
]
Roman Khachatryan commented on FLINK-34643:
---
Or maybe it's actually simple:
rkhachatryan opened a new pull request, #24550:
URL: https://github.com/apache/flink/pull/24550
## 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
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34369:
---
Labels: pull-request-available (was: )
> Elasticsearch connector supports SSL context
>
reta commented on PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#issuecomment-2012289683
@liuml07 could you please use the same configuration/API model as [1] does
for SSL support in OpenSearch? Besides just having familiar configuration, the
API is friendly
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829557#comment-17829557
]
Roman Khachatryan commented on FLINK-34643:
---
Thanks for reporting
My first suspicion was that
[
https://issues.apache.org/jira/browse/FLINK-34663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829555#comment-17829555
]
Andriy Redko commented on FLINK-34663:
--
[~wgendy] apologies for the delay, it seems like the only
flinkbot commented on PR #24549:
URL: https://github.com/apache/flink/pull/24549#issuecomment-2012256673
## CI report:
* d16fe63ecacbe579ca6c7eda4135b597c4eb6832 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil merged PR #24547:
URL: https://github.com/apache/flink/pull/24547
--
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:
lincoln-lil merged PR #24548:
URL: https://github.com/apache/flink/pull/24548
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34910:
---
Labels: pull-request-available (was: )
> Can not plan window join without projections
>
lincoln-lil commented on PR #24515:
URL: https://github.com/apache/flink/pull/24515#issuecomment-2012246995
@Myasuka Thanks for reviewing! Please help review the cherry-pick one:
https://github.com/apache/flink/pull/24514
--
This is an automated message from the Apache Git Service.
To
dawidwys opened a new pull request, #24549:
URL: https://github.com/apache/flink/pull/24549
## What is the purpose of the change
Fix support for
```
SELECT * FROM
TABLE(TUMBLE)
JOIN
TABLE(TUMBLE...)
```
without enclosing the tables with a
[
https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829244#comment-17829244
]
lincoln lee edited comment on FLINK-34706 at 3/21/24 1:00 PM:
--
# (/)
[
https://issues.apache.org/jira/browse/FLINK-34737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829544#comment-17829544
]
ZhengYu Chen commented on FLINK-34737:
--
https://issues.apache.org/jira/browse/FLINK-34737 doc
Dawid Wysakowicz created FLINK-34910:
Summary: Can not plan window join without projections
Key: FLINK-34910
URL: https://issues.apache.org/jira/browse/FLINK-34910
Project: Flink
Issue
lincoln-lil commented on code in PR #24515:
URL: https://github.com/apache/flink/pull/24515#discussion_r1533840206
##
pom.xml:
##
@@ -2358,12 +2358,6 @@ under the License.
xiaotouming created FLINK-34909:
---
Summary: OceanBase事务ID需求
Key: FLINK-34909
URL: https://issues.apache.org/jira/browse/FLINK-34909
Project: Flink
Issue Type: New Feature
Components:
vahmed-hamdy commented on code in PR #132:
URL:
https://github.com/apache/flink-connector-aws/pull/132#discussion_r1533768503
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/table/util/KinesisProducerOptionsMapperTest.java:
mxm commented on PR #799:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/799#issuecomment-2012067487
> > Autoscaling wouldn't have a chance to realize its SLOs.
>
> You are right. Autoscaler supports scaling parallelism and memory for now.
As I understand, the
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829513#comment-17829513
]
Feng Jin edited comment on FLINK-34898 at 3/21/24 11:51 AM:
I tried this
[
https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-34903:
---
Description:
When using the MySQL Pipeline connector for whole-database synchronization,
users
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829513#comment-17829513
]
Feng Jin commented on FLINK-34898:
--
I tried this case and indeed encountered an error, but I managed to
[
https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829512#comment-17829512
]
Thorne commented on FLINK-34903:
i take a pr in https://github.com/apache/flink-cdc/pull/3186
> Add
zhuzhurk commented on code in PR #24524:
URL: https://github.com/apache/flink/pull/24524#discussion_r1533719880
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java:
##
@@ -232,8 +230,8 @@ protected void
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829507#comment-17829507
]
Leonard Xu commented on FLINK-34908:
Thanks [~pacinogong], assigned this ticket to you.
>
shiyiky opened a new pull request, #3186:
URL: https://github.com/apache/flink-cdc/pull/3186
desc :[FLINK-34903](https://issues.apache.org/jira/browse/FLINK-34903)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34908:
--
Assignee: Xin Gong
> [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost
JunRuiLee commented on PR #24524:
URL: https://github.com/apache/flink/pull/24524#issuecomment-2011980990
Thanks @zhuzhurk for the review, 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
JunRuiLee commented on code in PR #24524:
URL: https://github.com/apache/flink/pull/24524#discussion_r1533688677
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultSpeculativeExecutionHandler.java:
##
@@ -7,62 +7,37 @@
* "License"); you may
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829485#comment-17829485
]
Matthias Pohl edited comment on FLINK-34643 at 3/21/24 11:13 AM:
-
*
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829501#comment-17829501
]
Matthias Pohl commented on FLINK-33186:
---
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829500#comment-17829500
]
Matthias Pohl commented on FLINK-28440:
---
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829499#comment-17829499
]
Matthias Pohl edited comment on FLINK-34227 at 3/21/24 11:11 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829499#comment-17829499
]
Matthias Pohl commented on FLINK-34227:
---
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829485#comment-17829485
]
Matthias Pohl edited comment on FLINK-34643 at 3/21/24 11:08 AM:
-
*
[
https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829484#comment-17829484
]
Matthias Pohl edited comment on FLINK-34718 at 3/21/24 11:08 AM:
-
before
1 - 100 of 192 matches
Mail list logo
