Vincent-Woo opened a new pull request, #3205:
URL: https://github.com/apache/flink-cdc/pull/3205
## What is the purpose of the change
Translate "Deployment - YARN" page into Chinese.
The page url is
https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/zh/docs/deploymen
[
https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34738:
---
Labels: pull-request-available (was: )
> "Deployment - YARN" Page for Flink CDC Chinese Doc
LadyForest commented on code in PR #24555:
URL: https://github.com/apache/flink/pull/24555#discussion_r1554549162
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java:
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
lvyanquan commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1554559016
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java:
##
@@ -111,8 +115,13 @@ private SchemaChangeResponse requestSc
lvyanquan commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1554559194
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java:
##
@@ -127,4 +136,13 @@ RESPONSE sendRequestToCoordinator(REQU
lvyanquan commented on PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#issuecomment-2041034979
> Thanks @lvyanquan for the fix, I left some comments. And I think tests is
necessary, e.g. a test mocked RPC timeout when processing schema change event
is welcome.
Add new te
liyubin117 commented on PR #24555:
URL: https://github.com/apache/flink/pull/24555#issuecomment-2041047820
> I'm still confused about this. The base class `SqlShowCreate` already
defined a protected variable called `sqlIdentifier`. Why not use it to
represent the catalog name, just like oth
wolfboys closed pull request #19798: [FLINK-27299][Runtime/Configuration] flink
parsing parameter bug fixed.
URL: https://github.com/apache/flink/pull/19798
--
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
liyubin117 commented on code in PR #24555:
URL: https://github.com/apache/flink/pull/24555#discussion_r1554574354
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java:
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
Jiabao-Sun merged PR #24622:
URL: https://github.com/apache/flink/pull/24622
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-35011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35011.
Resolution: Fixed
Fixed via master: 3590c2d86f4186771ffcd64712f756d31306eb88
> The change in visi
skymilong commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1552023129
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java:
##
@@ -20,17 +20,24 @@
import org.apache.flink.cdc.common.configuration.C
Ahmed Hamdy created FLINK-35022:
---
Summary: Add TypeInformed Element Converter for DynamoDbSink
Key: FLINK-35022
URL: https://issues.apache.org/jira/browse/FLINK-35022
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834533#comment-17834533
]
Ahmed Hamdy commented on FLINK-35022:
-
[~danny.cranmer] Wdyt about this proposal?
A
[
https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yansuopeng updated FLINK-34995:
---
Issue Type: Improvement (was: Bug)
> flink kafka connector source stuck when partition leader inval
lvyanquan commented on code in PR #2959:
URL: https://github.com/apache/flink-cdc/pull/2959#discussion_r1554795369
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java:
##
@@ -53,12 +53,46 @@ public class CliFrontendOptions {
.desc
leonardBang commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1554795438
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java:
##
@@ -127,4 +136,13 @@ RESPONSE sendRequestToCoordinator(RE
leonardBang commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1554795627
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -85,5 +89,12 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-34973:
--
Assignee: Yanfei Lei
> FLIP-425: Asynchronous Execution Model
> -
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834580#comment-17834580
]
xiaogang zhou commented on FLINK-32070:
---
[~Zakelly] Hi, we met a problem that FLIN
Jiabao-Sun commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-mongodb/pull/32#discussion_r1554796798
##
flink-connector-mongodb-e2e-tests/pom.xml:
##
@@ -65,6 +65,11 @@ under the License.
mongodb
test
loserwang1024 commented on code in PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#discussion_r1554797030
##
pom.xml:
##
@@ -462,8 +462,15 @@ under the License.
submodules, ${flink.version} will be
resolved as the actual Fli
[
https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834581#comment-17834581
]
yansuopeng commented on FLINK-34995:
[~martijnvisser] Apologies for the confusion;
1996fanrui merged PR #24601:
URL: https://github.com/apache/flink/pull/24601
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34980:
---
Assignee: Caican Cai
> Translate overview document into Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-34970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34970:
---
Assignee: Caican Cai
> Translate architecture documents into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-34932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34932:
---
Assignee: Caican Cai
> Translate concepts of Flink-Kubernetes-Operator documentation
>
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-34979:
-
Fix Version/s: 1.20.0
> Implement State Future and related utilities
> -
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34979.
--
Resolution: Fixed
merged 739bd337 into master
> Implement State Future and related utilities
[
https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-34979:
-
Component/s: Runtime / State Backends
> Implement State Future and related utilities
> -
Weijie Guo created FLINK-35023:
--
Summary: YARNApplicationITCase failed on Azure
Key: FLINK-35023
URL: https://issues.apache.org/jira/browse/FLINK-35023
Project: Flink
Issue Type: Bug
C
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2041280097
Rebased and pushed again.
--
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 comm
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834583#comment-17834583
]
Weijie Guo commented on FLINK-34273:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834584#comment-17834584
]
Weijie Guo edited comment on FLINK-18476 at 4/7/24 2:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834585#comment-17834585
]
Weijie Guo commented on FLINK-34273:
https://dev.azure.com/apache-flink/apache-flink
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2041280495
@fredia @masteryhx would you please take a look?
--
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-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834584#comment-17834584
]
Weijie Guo commented on FLINK-18476:
1.20
https://dev.azure.com/apache-flink/apache
masteryhx closed pull request #24597: [FLINK-34979][State] Implement State
Future and related utilities
URL: https://github.com/apache/flink/pull/24597
--
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
masteryhx closed pull request #24480: [FLINK-32079][checkpoint] Support to
read/write checkpoint metadata of merged files
URL: https://github.com/apache/flink/pull/24480
--
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-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-32079.
--
Resolution: Fixed
merged ea4e4981 and 0b7f0fde into master
> Read/write checkpoint metadata o
LadyForest merged PR #24555:
URL: https://github.com/apache/flink/pull/24555
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-24939:
--
Fix Version/s: 1.20.0
> Support 'SHOW CREATE CATALOG' syntax
>
>
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-24939.
---
Resolution: Fixed
> Support 'SHOW CREATE CATALOG' syntax
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-24939.
-
> Support 'SHOW CREATE CATALOG' syntax
>
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834588#comment-17834588
]
Jane Chan commented on FLINK-24939:
---
Fixed in master 2747a5814bcc5cd45f15c023beba9b064
loserwang1024 commented on code in PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204#discussion_r1554801419
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkOperator.java:
##
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the Apache Softwa
loserwang1024 commented on code in PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204#discussion_r1554801483
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkOptions.j
loserwang1024 commented on code in PR #3150:
URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1554803332
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/CdcDataTypeTransf
xleoken commented on PR #3200:
URL: https://github.com/apache/flink-cdc/pull/3200#issuecomment-2041289392
cc @Jiabao-Sun
--
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
reswqa opened a new pull request, #24627:
URL: https://github.com/apache/flink/pull/24627
## What is the purpose of the change
*Correct the option key for sortPartition's java doc*
## Brief change log
- *Correct the option key for sortPartition's java doc.*
- *
RubyChou commented on PR #24567:
URL: https://github.com/apache/flink/pull/24567#issuecomment-2041291550
@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.
flinkbot commented on PR #24627:
URL: https://github.com/apache/flink/pull/24627#issuecomment-2041291845
## CI report:
* 7435124358660a306a82811a6a94a0799cbddcab UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xleoken commented on PR #3200:
URL: https://github.com/apache/flink-cdc/pull/3200#issuecomment-2041294135
cc @Jiabao-Sun @PatrickRen
--
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 c
lincoln-lil commented on PR #24517:
URL: https://github.com/apache/flink/pull/24517#issuecomment-2041294668
@masteryhx Thanks for reviewing 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 to t
fredia commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554800173
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ContextStateFutureImpl.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundati
lincoln-lil commented on PR #24517:
URL: https://github.com/apache/flink/pull/24517#issuecomment-2041294975
Rebased latest 1.19 and triggered a new ci run before merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834589#comment-17834589
]
Xin Gong commented on FLINK-34908:
--
Starrocks only support second precision.
[https://
[
https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34908:
---
Labels: pull-request-available (was: )
> [Feature][Pipeline] Mysql pipeline to doris and st
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554810305
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateFutureFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation
GOODBOY008 commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-mongodb/pull/32#discussion_r1554810987
##
flink-connector-mongodb-e2e-tests/pom.xml:
##
@@ -65,6 +65,11 @@ under the License.
mongodb
test
[
https://issues.apache.org/jira/browse/FLINK-34405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834591#comment-17834591
]
Jiabao Sun commented on FLINK-34405:
taskRunner Thread: testDriver() -> AbstractOut
Jiabao-Sun opened a new pull request, #24628:
URL: https://github.com/apache/flink/pull/24628
## What is the purpose of the change
[FLINK-34405][tests] Fix unstable test
RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort1 and
testCancelOuterJoinTaskWhileSort2
## B
[
https://issues.apache.org/jira/browse/FLINK-34405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34405:
---
Labels: pull-request-available starter test-stability (was: starter
test-stability)
> Righ
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554811623
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
flinkbot commented on PR #24628:
URL: https://github.com/apache/flink/pull/24628#issuecomment-2041303328
## CI report:
* 5348510da80f6f12061ae0c9ad7e5e38792b188a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2041303349
@fredia thank for your suggestions!
--
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 spe
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834595#comment-17834595
]
Zakelly Lan commented on FLINK-32070:
-
[~zhoujira86] Yes, this helps the scenario wh
Laffery opened a new pull request, #3208:
URL: https://github.com/apache/flink-cdc/pull/3208
Optimize styles of the Flink CDC website documentation homepage:
- support responsive styles to improve reading experience under mobile
device.
- optimize the background image to avoid larg
fredia commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554814874
##
flink-runtime/src/test/java/org/apache/flink/runtime/asyncprocessing/ContextStateFutureImplTest.java:
##
@@ -0,0 +1,234 @@
+/*
+ * Licensed to the Apache Software Fou
fredia commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554815099
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
Yanfei Lei created FLINK-35024:
--
Summary: Implement record order preservation and buffering of
AsyncExecutionController
Key: FLINK-35024
URL: https://issues.apache.org/jira/browse/FLINK-35024
Project: Fl
Yanfei Lei created FLINK-35025:
--
Summary: Wire AsyncExecutionController to AbstractStreamOperator
Key: FLINK-35025
URL: https://issues.apache.org/jira/browse/FLINK-35025
Project: Flink
Issue Typ
Yanfei Lei created FLINK-35026:
--
Summary: Introduce async-state configurations
Key: FLINK-35026
URL: https://issues.apache.org/jira/browse/FLINK-35026
Project: Flink
Issue Type: Sub-task
libenchao commented on code in PR #24567:
URL: https://github.com/apache/flink/pull/24567#discussion_r1554798121
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnUniquenessTest.scala:
##
@@ -193,26 +193,26 @@ class Fl
libenchao commented on code in PR #24567:
URL: https://github.com/apache/flink/pull/24567#discussion_r1554809730
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala:
##
@@ -438,9 +438,36 @@ class FlinkRelMdUni
Jiabao-Sun commented on code in PR #32:
URL:
https://github.com/apache/flink-connector-mongodb/pull/32#discussion_r1554818610
##
flink-connector-mongodb-e2e-tests/pom.xml:
##
@@ -65,6 +65,11 @@ under the License.
mongodb
test
lvyanquan commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1554820774
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -85,5 +89,12 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834603#comment-17834603
]
Zakelly Lan commented on FLINK-33734:
-
I'd +1 for this optimization.
> Merge unalig
[
https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834604#comment-17834604
]
Jiabao Sun commented on FLINK-35008:
Hi [~martijnvisser], maybe we should bump the c
[
https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834606#comment-17834606
]
Jiabao Sun commented on FLINK-35008:
Due to an incorrect dependency on the Charsets
leonardBang commented on PR #3208:
URL: https://github.com/apache/flink-cdc/pull/3208#issuecomment-2041324990
@GOODBOY008 Would you like to help review this PR？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834607#comment-17834607
]
Jiabao Sun commented on FLINK-35010:
I think we should bump commons-compress version
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-35010:
--
Assignee: Zhongqiang Gong
> Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 fo
gong commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2041325325
@leonardBang 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 comment.
To
Yanfei Lei created FLINK-35027:
--
Summary: Implement checkpoint drain in AsyncExecutionController
Key: FLINK-35027
URL: https://issues.apache.org/jira/browse/FLINK-35027
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35026:
---
Component/s: Runtime / Configuration
Runtime / Task
> Introduce async-state configu
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35025:
---
Component/s: Runtime / Task
> Wire AsyncExecutionController to AbstractStreamOperator
>
[
https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35027:
---
Component/s: Runtime / Checkpointing
> Implement checkpoint drain in AsyncExecutionController
>
[
https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35006:
---
Assignee: Kirill Plugatarev
> Use try with-resource for StandaloneAutoscalerExecutor
>
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834609#comment-17834609
]
xiaogang zhou commented on FLINK-32070:
---
Is there any Branch I can view do a POC?
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834610#comment-17834610
]
Zhongqiang Gong commented on FLINK-35010:
-
+1 , It's better to bump commons-comp
Yanfei Lei created FLINK-35028:
--
Summary: Processing timer firing under async execution model
Key: FLINK-35028
URL: https://issues.apache.org/jira/browse/FLINK-35028
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834609#comment-17834609
]
xiaogang zhou edited comment on FLINK-32070 at 4/7/24 6:36 AM:
---
1996fanrui commented on code in PR #811:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/811#discussion_r1554828200
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java:
##
@@ -60,9 +60,11 @@ publi
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-24939:
-
Summary: Complete 'SHOW CREATE CATALOG' syntax (was: Support 'SHOW CREATE
CATALOG' syntax)
> Complete
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34915:
-
Summary: Complete `DESCRIBE CATALOG` syntax (was: Support `DESCRIBE
CATALOG` syntax)
> Complete `DESCR
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-24939:
-
Summary: Support 'SHOW CREATE CATALOG' syntax (was: Complete 'SHOW CREATE
CATALOG' syntax)
> Support '
Yanfei Lei created FLINK-35029:
--
Summary: Store timer in JVM heap when async execution enabled
Key: FLINK-35029
URL: https://issues.apache.org/jira/browse/FLINK-35029
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35026:
---
Summary: Introduce async execution configurations (was: Introduce
async-state configurations)
> In
Yanfei Lei created FLINK-35030:
--
Summary: Introduce Epoch Manager for watermark under async
execution
Key: FLINK-35030
URL: https://issues.apache.org/jira/browse/FLINK-35030
Project: Flink
Issu
1 - 100 of 101 matches
Mail list logo
