[
https://issues.apache.org/jira/browse/FLINK-37292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-37292:
--
Description:
The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is
incompati
[
https://issues.apache.org/jira/browse/FLINK-37292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-37292:
--
Description:
The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is
incompati
Wenkai Qi created FLINK-37292:
-
Summary: The Flink-Kubernetes dependency embedded in the packaging
of flink-cdc-dist is incompatible with Flink 1.20.
Key: FLINK-37292
URL: https://issues.apache.org/jira/browse/FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-37201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-37201:
--
Description:
FlinkCDC Pipeline transform arithmetic functions can not support parameters of
null and
Wenkai Qi created FLINK-37201:
-
Summary: FlinkCDC Pipeline transform arithmetic functions support
parameters of null and more numerical types.
Key: FLINK-37201
URL: https://issues.apache.org/jira/browse/FLINK-37201
[
https://issues.apache.org/jira/browse/FLINK-37123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912945#comment-17912945
]
Wenkai Qi commented on FLINK-37123:
---
[~leonard] thx. I want to shade Apache Calcite to
Wenkai Qi created FLINK-37123:
-
Summary: FlinkCDC YAML supports TIMESTAMP_TZ
Key: FLINK-37123
URL: https://issues.apache.org/jira/browse/FLINK-37123
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-37123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-37123:
--
Description:
[https://github.com/apache/flink-cdc/pull/3698]
Upgrade Apache Calcite into 1.37.0 to
Wenkai Qi created FLINK-37105:
-
Summary: Shade Apache Calcite in Flink CDC
Key: FLINK-37105
URL: https://issues.apache.org/jira/browse/FLINK-37105
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-37104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-37104:
--
Description:
Code simplification and cleaning related to Flink CDC YAML Transform.
For example:
Tas
Wenkai Qi created FLINK-37104:
-
Summary: Code simplification and cleaning related to Flink CDC
YAML Transform
Key: FLINK-37104
URL: https://issues.apache.org/jira/browse/FLINK-37104
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-36981:
--
Description:
h1. situation
In FlinkPipelineComposerITCase.testTransformMergingWithRoute:
{code:jav
[
https://issues.apache.org/jira/browse/FLINK-36981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-36981:
--
Description:
h1. situation
In FlinkPipelineComposerITCase.testTransformMergingWithRoute:
{code:jav
[
https://issues.apache.org/jira/browse/FLINK-36981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-36981:
--
Description:
h1. situation
In FlinkPipelineComposerITCase.testTransformMergingWithRoute:
{code:jav
[
https://issues.apache.org/jira/browse/FLINK-36981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-36981:
--
Description:
situation
In FlinkPipelineComposerITCase.testTransformMergingWithRoute:
{code:java}
/
Wenkai Qi created FLINK-36981:
-
Summary: The bug of transform merging with route in YAML task
Key: FLINK-36981
URL: https://issues.apache.org/jira/browse/FLINK-36981
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-36931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-36931:
--
Description:
h1. Background
MysqlCDC in Flink CDC supports *StartupMode.SNAPSHOT* and is of
{*}Bound
Wenkai Qi created FLINK-36931:
-
Summary: FlinkCDC YAML supports synchronizing the full amount of
data of the entire database in Batch mode
Key: FLINK-36931
URL: https://issues.apache.org/jira/browse/FLINK-36931
[
https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902293#comment-17902293
]
Wenkai Qi commented on FLINK-36647:
---
[~ruanhang1993] Hi. thx.
No. They only have diff
Wenkai Qi created FLINK-36741:
-
Summary: The precision of Decimal has been lost when use FlinkCDC
transform
Key: FLINK-36741
URL: https://issues.apache.org/jira/browse/FLINK-36741
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894746#comment-17894746
]
Wenkai Qi commented on FLINK-36647:
---
[~leonard]. I would like to hear your suggestion.
Wenkai Qi created FLINK-36647:
-
Summary: Support TimestampDiff function in cdc pipeline transform
Key: FLINK-36647
URL: https://issues.apache.org/jira/browse/FLINK-36647
Project: Flink
Issue Type
Wenkai Qi created FLINK-36636:
-
Summary: Timestamp data can not be compared in cdc pipeline
transform
Key: FLINK-36636
URL: https://issues.apache.org/jira/browse/FLINK-36636
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894499#comment-17894499
]
Wenkai Qi commented on FLINK-36636:
---
[~leonard] I have fixed and will submit the code
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894489#comment-17894489
]
Wenkai Qi edited comment on FLINK-36636 at 10/31/24 8:37 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894489#comment-17894489
]
Wenkai Qi commented on FLINK-36636:
---
Yeah. I am fixing this bug. I plan to implement a
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894484#comment-17894484
]
Wenkai Qi commented on FLINK-36636:
---
{code:java}
@Test
void testTimestampCompare() thr
Wenkai Qi created FLINK-35774:
-
Summary: The cache of transform is not updated after process
schema change event
Key: FLINK-35774
URL: https://issues.apache.org/jira/browse/FLINK-35774
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenkai Qi updated FLINK-35743:
--
Description: The time zone configuration for temporal functions is not
effective, including now() and
Wenkai Qi created FLINK-35743:
-
Summary: The time zone configuration for temporal functions is not
effective
Key: FLINK-35743
URL: https://issues.apache.org/jira/browse/FLINK-35743
Project: Flink
Wenkai Qi created FLINK-35730:
-
Summary: PipelineDefinitionParser add parse string method
Key: FLINK-35730
URL: https://issues.apache.org/jira/browse/FLINK-35730
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-34879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854311#comment-17854311
]
Wenkai Qi commented on FLINK-34879:
---
https://issues.apache.org/jira/browse/FLINK-35242
[
https://issues.apache.org/jira/browse/FLINK-35261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854300#comment-17854300
]
Wenkai Qi commented on FLINK-35261:
---
[[FLINK-34877][cdc] Flink CDC pipeline transform
Wenkai Qi created FLINK-35323:
-
Summary: Only the schema of the first hit table is recorded when
the source-table of the transformer hits multiple tables
Key: FLINK-35323
URL: https://issues.apache.org/jira/browse/FLI
Wenkai Qi created FLINK-35314:
-
Summary: Add Flink CDC pipeline transform user document
Key: FLINK-35314
URL: https://issues.apache.org/jira/browse/FLINK-35314
Project: Flink
Issue Type: New Feat
Wenkai Qi created FLINK-35259:
-
Summary: FlinkCDC Pipeline transform can't deal timestamp field
Key: FLINK-35259
URL: https://issues.apache.org/jira/browse/FLINK-35259
Project: Flink
Issue Type:
wen qi created FLINK-23016:
--
Summary: Job client must be a Coordination Request Gateway when
submit a job on web ui
Key: FLINK-23016
URL: https://issues.apache.org/jira/browse/FLINK-23016
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267625#comment-17267625
]
Zhi Qi commented on FLINK-21002:
[~jark] I want to do this, could you assign it to me?
[
https://issues.apache.org/jira/browse/FLINK-12113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071758#comment-17071758
]
bruce qi commented on FLINK-12113:
---
yeah ,we now find the same problem occurs again i
[
https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923094#comment-16923094
]
Qi commented on FLINK-10231:
Hi [~phoenixjiangnan] [~danny0405] are you already working on t
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921217#comment-16921217
]
Qi commented on FLINK-10644:
Thank you [~till.rohrmann] for the update. I will look into it
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914209#comment-16914209
]
Qi commented on FLINK-10644:
Any update on this? This is a commonly needed feature in batch
[
https://issues.apache.org/jira/browse/FLINK-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894882#comment-16894882
]
Qi commented on FLINK-13372:
This is a long existing issue which affects all SQL timestamp a
[
https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883040#comment-16883040
]
Qi commented on FLINK-13184:
Below are the TM error log in this case:
——
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855306#comment-16855306
]
Qi commented on FLINK-12426:
[~sunhaibotb] Sure, closed.
> TM occasionally hang in deployin
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qi closed FLINK-12426.
--
Resolution: Duplicate
> TM occasionally hang in deploying state
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848314#comment-16848314
]
Qi commented on FLINK-12426:
[~till.rohrmann] Thank you for referring to that issue. Yes tha
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848313#comment-16848313
]
Qi commented on FLINK-12547:
Hi Haibo,
We had added SO_TIMEOUT to the blob socket (SO_TI
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847441#comment-16847441
]
Qi commented on FLINK-12426:
[~till.rohrmann] thanks for looking into this. This issue rarel
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837134#comment-16837134
]
Qi commented on FLINK-12426:
[~Zentol] I'm afraid not. In our case we were requesting for 20
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qi updated FLINK-12426:
---
Description:
Hi all,
We use Flink batch and start thousands of jobs per day. Occasionally we
observed some stuc
Qi created FLINK-12426:
--
Summary: TM occasionally hang in deploying state
Key: FLINK-12426
URL: https://issues.apache.org/jira/browse/FLINK-12426
Project: Flink
Issue Type: Bug
Reporter: Qi
[
https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741741#comment-16741741
]
Qi commented on FLINK-10941:
Hi Zhijiang/Till,
Could you help to see any other issues on my
[
https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724729#comment-16724729
]
Qi commented on FLINK-11143:
Hi Alex,
I've just found another parameter which may affect jo
[
https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16719694#comment-16719694
]
Qi commented on FLINK-11143:
The hard code I’ve found is [1] and [2]. I think they should be
[
https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701679#comment-16701679
]
Qi commented on FLINK-10941:
Hi [~till.rohrmann] and [~zjwang],
Before the external shuffle
[
https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694247#comment-16694247
]
Qi commented on FLINK-10941:
Thanks [~zjwang]! We will keep an eye on that.
> Slots prematu
[
https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693026#comment-16693026
]
Qi commented on FLINK-10941:
Thank you [~zjwang] and [~till.rohrmann] for following up on th
[
https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692890#comment-16692890
]
Qi commented on FLINK-10941:
[~till.rohrmann] mentioned that increasing the slot idle timeou
Qi created FLINK-10941:
--
Summary: Slots prematurely released which still contain unconsumed
data
Key: FLINK-10941
URL: https://issues.apache.org/jira/browse/FLINK-10941
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Qi reassigned FLINK-1472:
---
Assignee: Mingliang Qi
> Web frontend config overview shows wrong value
> ---
[
https://issues.apache.org/jira/browse/FLINK-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Qi reassigned FLINK-1519:
---
Assignee: Mingliang Qi
> Web frontend task state mismatch when cancelling
> -
[
https://issues.apache.org/jira/browse/FLINK-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291941#comment-14291941
]
Mingliang Qi commented on FLINK-1454:
-
isn't it because akka timeout is set to 100s?
[
https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291921#comment-14291921
]
Mingliang Qi commented on FLINK-1430:
-
I saw some methods like setConfig, getConfig, g
[
https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Qi reassigned FLINK-1430:
---
Assignee: Mingliang Qi
> Add test for streaming scala api completeness
>
Mingliang Qi created FLINK-1403:
---
Summary: Streaming api doesn't support output file named with
"file://" prefix
Key: FLINK-1403
URL: https://issues.apache.org/jira/browse/FLINK-1403
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14276984#comment-14276984
]
Mingliang Qi commented on FLINK-1381:
-
Is there any problem of moving the split functi
67 matches
Mail list logo
