morazow commented on PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#issuecomment-2041992850
Thanks @hugogu for the PR! I have added some comments, please have a look.
Do you know why the CI is failing?
--
This is an automated message from the Apache Git Servic
morazow commented on code in PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#discussion_r1555308164
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapperTest.java:
##
@@ -0,0 +1,63 @@
+package org.apache.flink.c
Hangxiang Yu created FLINK-35049:
Summary: Implement Async State API for ForStStateBackend
Key: FLINK-35049
URL: https://issues.apache.org/jira/browse/FLINK-35049
Project: Flink
Issue Type: S
Hangxiang Yu created FLINK-35048:
Summary: Implement all methods of AsyncKeyedStateBakend
Key: FLINK-35048
URL: https://issues.apache.org/jira/browse/FLINK-35048
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35047:
-
Summary: Introduce ForStStateBackend to manage ForSt (was: Introduce
ForStStateBackend)
> Intr
Hangxiang Yu created FLINK-35047:
Summary: Introduce ForStStateBackend
Key: FLINK-35047
URL: https://issues.apache.org/jira/browse/FLINK-35047
Project: Flink
Issue Type: Sub-task
Co
Hangxiang Yu created FLINK-35046:
Summary: Introduce New KeyedStateBackend related Async interfaces
Key: FLINK-35046
URL: https://issues.apache.org/jira/browse/FLINK-35046
Project: Flink
Issu
joyCurry30 closed pull request #2813: [cdc-cli] When using miniCluster, don't
check 'FLINK_HOME'.
URL: https://github.com/apache/flink-cdc/pull/2813
--
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
joyCurry30 commented on code in PR #2813:
URL: https://github.com/apache/flink-cdc/pull/2813#discussion_r1555290167
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java:
##
@@ -86,6 +87,18 @@ static CliExecutor createExecutor(CommandLine commandLine)
throws
Hangxiang Yu created FLINK-35045:
Summary: Introduce ForStFileSystem to support reading and writing
with ByteBuffer
Key: FLINK-35045
URL: https://issues.apache.org/jira/browse/FLINK-35045
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834799#comment-17834799
]
Zhu Zhu commented on FLINK-35009:
-
Thanks for looking into the issue. [~Weijie Guo]
So i
[
https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35044:
-
Component/s: Runtime / State Backends
> Introduce statebackend-forst module
> --
Hangxiang Yu created FLINK-35044:
Summary: Introduce statebackend-forst module
Key: FLINK-35044
URL: https://issues.apache.org/jira/browse/FLINK-35044
Project: Flink
Issue Type: Sub-task
joyCurry30 commented on code in PR #3187:
URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1555283731
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml:
##
@@ -53,3 +53,8 @@ pipeline:
name: source-database-sync-pipe
parallelism: 4
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834798#comment-17834798
]
Zhu Zhu edited comment on FLINK-32513 at 4/8/24 6:27 AM:
-
{{Tran
Hangxiang Yu created FLINK-35043:
Summary: Release beta version of ForSt
Key: FLINK-35043
URL: https://issues.apache.org/jira/browse/FLINK-35043
Project: Flink
Issue Type: Sub-task
joyCurry30 commented on code in PR #3187:
URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1555283731
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml:
##
@@ -53,3 +53,8 @@ pipeline:
name: source-database-sync-pipe
parallelism: 4
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834798#comment-17834798
]
Zhu Zhu commented on FLINK-32513:
-
{{Transformation}} is not a public interface, it is a
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2041936516
@masteryhx Thanks for your comments! Applied some suggestions, PTAL thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-33934:
Assignee: Yuan Kui
> Flink SQL Source use raw format maybe lead to data lost
> --
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555253454
##
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-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35042:
---
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58782&view=logs&
Weijie Guo created FLINK-35042:
--
Summary: Streaming File Sink s3 end-to-end test failed as TM lost
Key: FLINK-35042
URL: https://issues.apache.org/jira/browse/FLINK-35042
Project: Flink
Issue Ty
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555247481
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555245552
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software Foun
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555244839
##
flink-runtime/src/test/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionControllerTest.java:
##
@@ -0,0 +1,305 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34273:
---
Affects Version/s: 1.20.0
> git fetch fails
> ---
>
> Key: FLINK-34273
>
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834783#comment-17834783
]
Weijie Guo commented on FLINK-35023:
jdk17
https://dev.azure.com/apache-flink/apach
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834784#comment-17834784
]
Weijie Guo commented on FLINK-34273:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35041:
---
Description:
{code:java}
Apr 08 03:22:45 03:22:45.450 [ERROR]
org.apache.flink.runtime.state.Increm
Weijie Guo created FLINK-35041:
--
Summary:
IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Key: FLINK-35041
URL: https://issues.apache.org/jira/browse/FLINK-35041
Project: Flink
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555241719
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/KeyAccountingUnit.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555239594
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateExecutor.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555237399
##
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-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834779#comment-17834779
]
Jiabao Sun commented on FLINK-34955:
I have rechecked the dependency of `commons-cod
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834778#comment-17834778
]
Jiabao Sun commented on FLINK-35010:
I have rechecked the dependency of `commons-cod
[
https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834777#comment-17834777
]
Jiabao Sun commented on FLINK-35008:
I have rechecked the dependency of `commons-cod
Jiabao-Sun commented on code in PR #24580:
URL: https://github.com/apache/flink/pull/24580#discussion_r1555174874
##
flink-end-to-end-tests/flink-sql-client-test/pom.xml:
##
@@ -69,6 +69,13 @@ under the License.
kafka
test
fredia commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555208732
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
masteryhx commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555175989
##
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-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-33934:
-
Affects Version/s: 1.19.0
1.18.0
1.17.0
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834765#comment-17834765
]
Yun Tang commented on FLINK-33934:
--
I think it's easy to let data lost when using {{raw
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35040:
Description:
The performance of serializerHeavyString regresses since April 3, and had not
yet recovered
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35040:
Attachment: screenshot-1.png
> The performance of serializerHeavyString regresses since April 3
>
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2041795538
Thanks @XComp, I am going to address your suggestions. Please have a look
once you are back
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1555171619
##
.github/workflows/template.python-wheels-ci.yml:
##
@@ -0,0 +1,67 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agr
Jiabao-Sun commented on code in PR #24580:
URL: https://github.com/apache/flink/pull/24580#discussion_r1555174874
##
flink-end-to-end-tests/flink-sql-client-test/pom.xml:
##
@@ -69,6 +69,13 @@ under the License.
kafka
test
Rui Fan created FLINK-35040:
---
Summary: The performance of serializerHeavyString regresses since
April 3
Key: FLINK-35040
URL: https://issues.apache.org/jira/browse/FLINK-35040
Project: Flink
Issue
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1555166750
##
.github/workflows/template.python-wheels-ci.yml:
##
@@ -0,0 +1,67 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agr
loserwang1024 commented on code in PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#discussion_r1555165225
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator/MySqlSourceEnumerator.j
loserwang1024 commented on code in PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#discussion_r1555164983
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaEvent.java:
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834758#comment-17834758
]
ude commented on FLINK-35039:
-
[~Yu Chen] Please have a look, If my modification pla
ude created FLINK-35039:
---
Summary: Create Profiling JobManager/TaskManager Instance failed
Key: FLINK-35039
URL: https://issues.apache.org/jira/browse/FLINK-35039
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834756#comment-17834756
]
Qingsheng Ren commented on FLINK-34966:
---
[~wanghe] Could you provide some context
[
https://issues.apache.org/jira/browse/FLINK-34661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34661:
---
Assignee: Junrui Li
> TaskExecutor supports retain partitions after JM crashed.
> -
[
https://issues.apache.org/jira/browse/FLINK-33983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33983:
---
Assignee: Junrui Li
> Introduce JobEvent and JobEventStore for Batch Job Recovery
> ---
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33986:
---
Assignee: Junrui Li
> Extend shuffleMaster to support batch snapshot.
> ---
[
https://issues.apache.org/jira/browse/FLINK-33984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33984.
---
Fix Version/s: 1.20.0
Resolution: Done
master:
38255652406becbfbcb7cbec557aa5ba9a1ebbb3
558ca75da2fce
[
https://issues.apache.org/jira/browse/FLINK-35036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834755#comment-17834755
]
Qingsheng Ren commented on FLINK-35036:
---
[~fly365] Thanks for reporting the issue!
[
https://issues.apache.org/jira/browse/FLINK-34945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34945:
---
Assignee: Junrui Li
> Support recover shuffle descriptor and partition metrics from tiered storage
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834752#comment-17834752
]
Biao Geng commented on FLINK-35035:
---
I am not very familiar with adaptive scheduler, m
zhuzhurk closed pull request #24415: [FLINK-33984][runtime] Support batch
snapshot for OperatorCoordinator.
URL: https://github.com/apache/flink/pull/24415
--
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-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834751#comment-17834751
]
Weijie Guo commented on FLINK-35009:
This change can be done in a compatible way. Bu
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834751#comment-17834751
]
Weijie Guo edited comment on FLINK-35009 at 4/8/24 2:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834750#comment-17834750
]
Zhongqiang Gong commented on FLINK-34955:
-
Hi [~slfan1989] ,I apologize for the
[
https://issues.apache.org/jira/browse/FLINK-35036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834749#comment-17834749
]
Biao Geng commented on FLINK-35036:
---
Hi [~fly365], according to the attached screensho
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34573.
--
Resolution: Won't Fix
> the task is stuck on the high presure
> -
reswqa merged PR #24627:
URL: https://github.com/apache/flink/pull/24627
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirill Plugatarev closed FLINK-35006.
-
Resolution: Not A Problem
> Use try with-resource for StandaloneAutoscalerExecutor
> ---
plugatarev closed pull request #811: [FLINK-35006] Use try with-resource for
StandaloneAutoscalerExecutor
URL: https://github.com/apache/flink-kubernetes-operator/pull/811
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
plugatarev commented on code in PR #811:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/811#discussion_r1555135563
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java:
##
@@ -60,9 +60,11 @@ publi
Ufuk Celebi created FLINK-35038:
---
Summary: Bump test dependency org.yaml:snakeyaml to 2.2
Key: FLINK-35038
URL: https://issues.apache.org/jira/browse/FLINK-35038
Project: Flink
Issue Type: Tec
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041527525
@LadyForest Hi, CI passed now, Looking forward your review, Thanks very much
:)
--
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-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834685#comment-17834685
]
Feng Jin commented on FLINK-34898:
--
[~chloehe] Thank you for the update, sorry for th
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834682#comment-17834682
]
Shilun Fan edited comment on FLINK-34955 at 4/7/24 2:17 PM:
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-34898:
-
Attachment: 截屏2024-04-07 22.05.40.png
> Cannot create ARRAY of named STRUCTs
> -
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834682#comment-17834682
]
Shilun Fan commented on FLINK-34955:
[~gongzhongqiang] Of course, if upgrading is po
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834681#comment-17834681
]
Shilun Fan commented on FLINK-34955:
[~gongzhongqiang] From my personal perspective,
GOODBOY008 commented on PR #32:
URL:
https://github.com/apache/flink-connector-mongodb/pull/32#issuecomment-2041478551
@Jiabao-Sun PR updated and version to `1.26.1`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834678#comment-17834678
]
Zhongqiang Gong commented on FLINK-34955:
-
[~slfan1989] [~mbalassi] According to
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554965456
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ljz2051 commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554960979
##
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-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yisha zhou updated FLINK-35037:
---
Description:
In current Implementation, relNodes with Window type will only deliver
upsert/unique k
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yisha zhou updated FLINK-35037:
---
Description:
In current Implementation, relNodes with Window type will only deliver
upsert/unique k
yisha zhou created FLINK-35037:
--
Summary: Optimize uniqueKeys and upsertKeys inference of windows
with ROW_NUMBER
Key: FLINK-35037
URL: https://issues.apache.org/jira/browse/FLINK-35037
Project: Flink
fredia commented on PR #22973:
URL: https://github.com/apache/flink/pull/22973#issuecomment-2041450107
@Zakelly I have rebased this PR, could you please take a look if you're
free? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
PatrickRen commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1554892220
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java:
##
@@ -20,18 +20,33 @@
import org.apache.flink.cdc.common.configuration.
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041411609
@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
Zakelly commented on PR #24629:
URL: https://github.com/apache/flink/pull/24629#issuecomment-2041409660
@XComp 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 go to the sp
gong commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2041406982
> I wonder if changing `DorisEventSerializer.DATE_TIME_FORMATTER` to
`-MM-dd HH:mm:ss.SS` fixes this problem, too?
@yuxiqian I think that it can fix this problem, too.
--
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34915:
-
Attachment: image-2024-04-07-17-54-51-203.png
Description:
Describe the metadata of an existing cat
flinkbot commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041394595
## CI report:
* a1146244ce8a490c2ca1557f4c2410b59effb333 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34915:
---
Labels: pull-request-available (was: )
> Complete `DESCRIBE CATALOG` syntax
> -
liyubin117 opened a new pull request, #24630:
URL: https://github.com/apache/flink/pull/24630
## What is the purpose of the change
Describe the metadata of an existing catalog. The metadata information
includes the catalog’s name, type, and comment. If the optional EXTENDED option
is
loserwang1024 commented on code in PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204#discussion_r1554863395
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkOptions.j
slfan1989 commented on PR #24601:
URL: https://github.com/apache/flink/pull/24601#issuecomment-2041389025
@1996fanrui Thank you very much for reviewing the code!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Fly365 created FLINK-35036:
--
Summary: Flink CDC Job cancel with savepoint failed
Key: FLINK-35036
URL: https://issues.apache.org/jira/browse/FLINK-35036
Project: Flink
Issue Type: Bug
Comp
PatrickRen commented on code in PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#discussion_r1554857536
##
pom.xml:
##
@@ -462,8 +462,15 @@ under the License.
submodules, ${flink.version} will be
resolved as the actual Flink
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834639#comment-17834639
]
Weijie Guo edited comment on FLINK-35023 at 4/7/24 9:24 AM:
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834639#comment-17834639
]
Weijie Guo commented on FLINK-35023:
https://dev.azure.com/apache-flink/apache-flink
1 - 100 of 135 matches
Mail list logo
