[jira] [Created] (FLINK-35373) Beautify Flink CDC Paimon Sink web ui

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

[jira] [Created] (FLINK-35884) Support

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

[jira] [Created] (FLINK-36559) [docs]Add elasticsearch sink to docs

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

[jira] [Created] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink

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

[jira] [Created] (FLINK-36518) Paimon Sink support per-table property configuration

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

[jira] [Created] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

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:

[jira] [Created] (FLINK-36700) Elasticsearch pipeline sink support authentication

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

[jira] [Created] (FLINK-36398) Provide tools for users to obtain Schema mapping

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

[jira] [Created] (FLINK-36309) Flink CDC Paimon Sink Commit failed should log StackTrace

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

[jira] [Created] (FLINK-36846) Composer support add custom Operator after Source

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

[jira] [Created] (FLINK-37275) MySQL source connector supports using the base module's source metric statistics

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

[jira] [Created] (FLINK-37261) Provide JSON series functions in YAML pipeline

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

[jira] [Created] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM

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:

[jira] [Created] (FLINK-37128) Skip binlog replay filter when skip backfill

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

[jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase

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

[jira] [Created] (FLINK-37677) [cdc-connector] Sink support skip create table event

JunboWang created FLINK-37677: - Summary: [cdc-connector] Sink support skip create table event Key: FLINK-37677 URL: https://issues.apache.org/jira/browse/FLINK-37677 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation

JunboWang created FLINK-37784: - Summary: [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation Key: FLINK-37784 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability.

JunboWang created FLINK-37828: - Summary: Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. Key: FLINK-37828 URL: https://issues.apache.org/jira/browse/FLINK-37828 P

[jira] [Created] (FLINK-37958) Flink CDC Sink connector support fluss

JunboWang created FLINK-37958: - Summary: Flink CDC Sink connector support fluss Key: FLINK-37958 URL: https://issues.apache.org/jira/browse/FLINK-37958 Project: Flink Issue Type: New Feature