JunboWang created FLINK-35884:
-
Summary: Support
Key: FLINK-35884
URL: https://issues.apache.org/jira/browse/FLINK-35884
Project: Flink
Issue Type: Improvement
Components: Flink CDC
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35884:
--
Summary: Pipeline connector MySQL support snapshot.chunk.key-column (was:
Support)
> Pipeline connec
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35884:
--
Description: flink-connector-mysql-cdc `MySqlSourceOptions` supports
specifying the parameter scan.inc
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35884:
--
Summary: Pipeline connector MySQL support
scan.incremental.snapshot.chunk.key-column (was: Pipeline c
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35884:
--
Summary: Pipeline MySQL connector support
scan.incremental.snapshot.chunk.key-column (was: Pipeline c
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35884:
--
Summary: Pipeline MySQL connector supports setting chunk column key (was:
Pipeline MySQL connector su
JunboWang created FLINK-35373:
-
Summary: Beautify Flink CDC Paimon Sink web ui
Key: FLINK-35373
URL: https://issues.apache.org/jira/browse/FLINK-35373
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-35373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-35373:
--
Summary: Simplify Flink CDC Paimon Sink web ui (was: Beautify Flink CDC
Paimon Sink web ui )
> Simp
[
https://issues.apache.org/jira/browse/FLINK-36518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36518:
--
Description: As title. (was: Solved by transform table-options.)
> Paimon Sink support per-table prop
[
https://issues.apache.org/jira/browse/FLINK-36518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36518:
--
Description: Solved by transform table-options. (was: As title.)
> Paimon Sink support per-table prop
[
https://issues.apache.org/jira/browse/FLINK-36518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889392#comment-17889392
]
JunboWang commented on FLINK-36518:
---
Solved by transform table-options.
> Paimon Sink
[ https://issues.apache.org/jira/browse/FLINK-36518 ]
JunboWang deleted comment on FLINK-36518:
---
was (Author: JIRAUSER305453):
Solved by transform table-options.
> Paimon Sink support per-table property configuration
> ---
[
https://issues.apache.org/jira/browse/FLINK-36518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang closed FLINK-36518.
-
Resolution: Not A Problem
Solved by transform table-options.
> Paimon Sink support per-table property c
[
https://issues.apache.org/jira/browse/FLINK-36475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888497#comment-17888497
]
JunboWang commented on FLINK-36475:
---
Please assign this to me.
> YAML Transform suppo
[
https://issues.apache.org/jira/browse/FLINK-34825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891714#comment-17891714
]
JunboWang commented on FLINK-34825:
---
Interested in this. Please assign it to me. Thank
JunboWang created FLINK-36559:
-
Summary: [docs]Add elasticsearch sink to docs
Key: FLINK-36559
URL: https://issues.apache.org/jira/browse/FLINK-36559
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Summary: [docs]Add flink cdc elasticsearch pipeline sink to docs (was:
[docs]Add elasticsearch sink t
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Component/s: Flink CDC
(was: Documentation)
> [docs]Add elasticsearch sink to doc
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang closed FLINK-36559.
-
Resolution: Duplicate
Duplicate with FLINK-36052.
> [docs]Add flink cdc elasticsearch pipeline sink to
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Description: Duplicate with 36052.
> [docs]Add flink cdc elasticsearch pipeline sink to docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-36052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890794#comment-17890794
]
JunboWang commented on FLINK-36052:
---
Could we add Component/s as FLINK-CDC?
> add ela
[
https://issues.apache.org/jira/browse/FLINK-36052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890794#comment-17890794
]
JunboWang edited comment on FLINK-36052 at 10/18/24 5:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36559:
--
Description: (was: Duplicate with 36052.)
> [docs]Add flink cdc elasticsearch pipeline sink to doc
[
https://issues.apache.org/jira/browse/FLINK-36517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36517:
--
Description:
Same as https://issues.apache.org/jira/browse/FLINK-35938.
When job restart from failure
JunboWang created FLINK-36517:
-
Summary: Duplicate commit the same datafile in Paimon Sink
Key: FLINK-36517
URL: https://issues.apache.org/jira/browse/FLINK-36517
Project: Flink
Issue Type: Bug
JunboWang created FLINK-36518:
-
Summary: Paimon Sink support per-table property configuration
Key: FLINK-36518
URL: https://issues.apache.org/jira/browse/FLINK-36518
Project: Flink
Issue Type: Im
JunboWang created FLINK-36698:
-
Summary: Elasticsearch Pipeline Connector support index sharding
Key: FLINK-36698
URL: https://issues.apache.org/jira/browse/FLINK-36698
Project: Flink
Issue Type:
JunboWang created FLINK-36700:
-
Summary: Elasticsearch pipeline sink support authentication
Key: FLINK-36700
URL: https://issues.apache.org/jira/browse/FLINK-36700
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-36398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36398:
--
Description: Sometimes users do not want to use Flink CDC to automatically
create tables. Users want t
[
https://issues.apache.org/jira/browse/FLINK-36398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36398:
--
Summary: Provide tools for users to schema conversion (was: Provide tools
for users to obtain Schema
[
https://issues.apache.org/jira/browse/FLINK-36398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36398:
--
Summary: Provide Schema conversion tools (was: Provide tools for users to
schema conversion)
> Provi
JunboWang created FLINK-36398:
-
Summary: Provide tools for users to obtain Schema mapping
Key: FLINK-36398
URL: https://issues.apache.org/jira/browse/FLINK-36398
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-36398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36398:
--
Description: Sometimes users do not want to use Flink CDC to automatically
create tables. Users want t
[
https://issues.apache.org/jira/browse/FLINK-36309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36309:
--
Issue Type: Bug (was: Improvement)
> Flink CDC Paimon Sink Commit failed should log StackTrace
> ---
[
https://issues.apache.org/jira/browse/FLINK-36309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-36309:
--
Summary: Flink CDC Paimon Sink commit failed should log stackTrace (was:
Flink CDC Paimon Sink Commi
[
https://issues.apache.org/jira/browse/FLINK-35714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882579#comment-17882579
]
JunboWang commented on FLINK-35714:
---
Interested in this, Flink cdc now can support Aut
[
https://issues.apache.org/jira/browse/FLINK-35714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882579#comment-17882579
]
JunboWang edited comment on FLINK-35714 at 9/18/24 5:57 AM:
[
https://issues.apache.org/jira/browse/FLINK-35714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882579#comment-17882579
]
JunboWang edited comment on FLINK-35714 at 9/18/24 5:58 AM:
JunboWang created FLINK-36309:
-
Summary: Flink CDC Paimon Sink Commit failed should log StackTrace
Key: FLINK-36309
URL: https://issues.apache.org/jira/browse/FLINK-36309
Project: Flink
Issue Ty
JunboWang created FLINK-36846:
-
Summary: Composer support add custom Operator after Source
Key: FLINK-36846
URL: https://issues.apache.org/jira/browse/FLINK-36846
Project: Flink
Issue Type: Bug
JunboWang created FLINK-37275:
-
Summary: MySQL source connector supports using the base module's
source metric statistics
Key: FLINK-37275
URL: https://issues.apache.org/jira/browse/FLINK-37275
Project: F
[
https://issues.apache.org/jira/browse/FLINK-37261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37261:
--
Description:
It is reasonable to expect some functions like `JSON_VALUE(numeric[, string])`,
JSON_EXI
JunboWang created FLINK-37261:
-
Summary: Provide JSON series functions in YAML pipeline
Key: FLINK-37261
URL: https://issues.apache.org/jira/browse/FLINK-37261
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Affects Version/s: cdc-3.3.0
(was: cdc-3.2.1)
> Binlog reader skip `shouldE
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Fix Version/s: cdc-3.4.0
> Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill
>
[
https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37120:
--
Description:
When synchronizing a large table, the ending chunk is always executed last, and
splitEnd
JunboWang created FLINK-37120:
-
Summary: MySqlSnapshotSplitAssigner assign the enging chunk early
to avoid TaskManager OOM
Key: FLINK-37120
URL: https://issues.apache.org/jira/browse/FLINK-37120
Project:
[
https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37120:
--
Issue Type: Improvement (was: Bug)
> MySqlSnapshotSplitAssigner assign the enging chunk early to avoi
[
https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37120:
--
Summary: MySqlSnapshotSplitAssigner assign the ending chunk early to avoid
TaskManager OOM (was: MySq
[
https://issues.apache.org/jira/browse/FLINK-37120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37120:
--
Description: When synchronizing a large table, the ending chunk is always
executed last, and splitEnd
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Summary: Skip binlog split reader should filter when skip backfill (was:
Skip binlog replay filter wh
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Summary: Skip binlog split reader `shouldEmit` filter when skip backfill
(was: Skip binlog split read
JunboWang created FLINK-37128:
-
Summary: Skip binlog replay filter when skip backfill
Key: FLINK-37128
URL: https://issues.apache.org/jira/browse/FLINK-37128
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Summary: Skip binlog split reader `shouldEmit` filter when snapshot reader
skip backfill (was: Skip b
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Summary: Binlog split reader skip `shouldEmit` filter when snapshot reader
skip backfill (was: Skip b
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Summary: Binlog reader skip `shouldEmit` filter when snapshot reader skip
backfill (was: Binlog split
JunboWang created FLINK-37307:
-
Summary: Flink CDC CI failed due to OceanBaseE2eITCase
Key: FLINK-37307
URL: https://issues.apache.org/jira/browse/FLINK-37307
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-37307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37307:
--
Description:
[https://github.com/apache/flink-cdc/actions/runs/13260216427/job/37067737782?pr=3914|htt
[
https://issues.apache.org/jira/browse/FLINK-37307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37307:
--
Description:
[https://github.com/apache/flink-cdc/actions/runs/13260216427/job/37067737782?pr=3914|htt
59 matches
Mail list logo
