Yanfei Lei created FLINK-35031:
--
Summary: Event timer firing under async execution model
Key: FLINK-35031
URL: https://issues.apache.org/jira/browse/FLINK-35031
Project: Flink
Issue Type: Sub-ta
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
[
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-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-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 '
[
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: Complete 'SHOW CREATE CATALOG' syntax (was: Support 'SHOW CREATE
CATALOG' syntax)
> Complete
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-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:
---
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-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
[
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-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-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-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-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
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
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
[
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
[
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
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-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
[
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-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
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 {
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
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
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
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
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-35024:
--
Summary: Implement record order preservation and buffering of
AsyncExecutionController
Key: FLINK-35024
URL: https://issues.apache.org/jira/browse/FLINK-35024
Project: Fl
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
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
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
[
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
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
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 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)
[
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
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:comment-tabpanel&focusedCommentId=17834591#comment-17834591
]
Jiabao Sun commented on FLINK-34405:
taskRunner Thread: testDriver() -> AbstractOut
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
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
[
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
[
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://
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
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-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
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
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`
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.
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.*
- *
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
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
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 #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
[
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
[
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: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 updated FLINK-24939:
--
Fix Version/s: 1.20.0
> Support 'SHOW CREATE CATALOG' syntax
>
>
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-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
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
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
[
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
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-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
[
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=17834583#comment-17834583
]
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-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
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
[
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
> -
[
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:
-
Fix Version/s: 1.20.0
> Implement State Future and related utilities
> -
[
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-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-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34980:
---
Assignee: Caican Cai
> Translate overview document into Chinese
> -
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-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834581#comment-17834581
]
yansuopeng commented on FLINK-34995:
[~martijnvisser] Apologies for the confusion;
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
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
[
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
[
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
> -
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 {
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
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
[
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
[
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
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:
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
[
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
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
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
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 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
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
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 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
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
[
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
1 - 100 of 101 matches
Mail list logo
