[jira] [Updated] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36648: -- Affects Version/s: 2.0.0 > Release flink-connector-kafka v4.0.0 for Flink 2.0 > --

[jira] [Updated] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36648: -- Summary: Release flink-connector-kafka v4.0.0 for Flink 2.0 (was: bump flink version to 2.0-preview1

[jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0

LvYanquan created FLINK-36660: - Summary: Release flink-connector-elasticsearch vx.x.x for Flink 2.0 Key: FLINK-36660 URL: https://issues.apache.org/jira/browse/FLINK-36660 Project: Flink Issue Ty

[jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0

LvYanquan created FLINK-36658: - Summary: Support and Release Connectors for Flink 2.0 Key: FLINK-36658 URL: https://issues.apache.org/jira/browse/FLINK-36658 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36648: -- Parent: FLINK-36658 Issue Type: Sub-task (was: Improvement) > bump flink version to 2.0-previ

[jira] [Updated] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36659: -- Description: Release a version of flink-connector-jdbc connector that bumped Flink 2.0 (was: Release

[jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

LvYanquan created FLINK-36659: - Summary: Release flink-connector-jdbc vx.x.x for Flink 2.0 Key: FLINK-36659 URL: https://issues.apache.org/jira/browse/FLINK-36659 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector

LvYanquan created FLINK-36648: - Summary: bump flink version to 2.0-preview1 for Kafka connector Key: FLINK-36648 URL: https://issues.apache.org/jira/browse/FLINK-36648 Project: Flink Issue Type:

[jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20

LvYanquan created FLINK-36641: - Summary: Support and Release Connectors for Flink 1.20 Key: FLINK-36641 URL: https://issues.apache.org/jira/browse/FLINK-36641 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-36621) Build failure: StatefulSink not found

[ https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893812#comment-17893812 ] LvYanquan commented on FLINK-36621: --- This issue should be related to a bug https://yo

[jira] [Commented] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893798#comment-17893798 ] LvYanquan commented on FLINK-36245: --- Hi, Piotr. Kafka connector has not yet been adapt

[jira] [Commented] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase

[ https://issues.apache.org/jira/browse/FLINK-36614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893698#comment-17893698 ] LvYanquan commented on FLINK-36614: --- looks like this issue is the same with  https://i

[jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink

LvYanquan created FLINK-36611: - Summary: Add schema info to output of Kafka sink Key: FLINK-36611 URL: https://issues.apache.org/jira/browse/FLINK-36611 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters

LvYanquan created FLINK-36581: - Summary: Allow passing Flink configuration by yaml job file or command line parameters Key: FLINK-36581 URL: https://issues.apache.org/jira/browse/FLINK-36581 Project: Flin

[jira] [Commented] (FLINK-36541) Occasional met commit conflict problem in PaimonSink.

[ https://issues.apache.org/jira/browse/FLINK-36541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890800#comment-17890800 ] LvYanquan commented on FLINK-36541: --- I would like to try to fix it. > Occasional met

[jira] [Created] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator

LvYanquan created FLINK-36566: - Summary: Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator Key: FLINK-36566 URL: https://issues.apache.org/jira/browse/FLINK-36566 Pro

[jira] [Commented] (FLINK-36562) Running CI in random timezone to expose more time related bugs

[ https://issues.apache.org/jira/browse/FLINK-36562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890773#comment-17890773 ] LvYanquan commented on FLINK-36562: --- Closed as this is duplicated with FLINK-36564 >

[jira] [Closed] (FLINK-36562) Running CI in random timezone to expose more time related bugs

[ https://issues.apache.org/jira/browse/FLINK-36562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan closed FLINK-36562. - Release Note: Duplicated with FLINK-36564. Resolution: Duplicate > Running CI in random timezone

[jira] [Closed] (FLINK-36563) Running CI in random timezone to expose more time related bugs

[ https://issues.apache.org/jira/browse/FLINK-36563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan closed FLINK-36563. - Resolution: Duplicate > Running CI in random timezone to expose more time related bugs > -

[jira] [Commented] (FLINK-36563) Running CI in random timezone to expose more time related bugs

[ https://issues.apache.org/jira/browse/FLINK-36563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890772#comment-17890772 ] LvYanquan commented on FLINK-36563: --- Closed as this is duplicated with FLINK-36564. >

[jira] [Created] (FLINK-36564) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36564: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36564 URL: https://issues.apache.org/jira/browse/FLINK-36564 Project: Flink Is

[jira] [Created] (FLINK-36563) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36563: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36563 URL: https://issues.apache.org/jira/browse/FLINK-36563 Project: Flink I

[jira] [Created] (FLINK-36562) Running CI in random timezone to expose more time related bugs

LvYanquan created FLINK-36562: - Summary: Running CI in random timezone to expose more time related bugs Key: FLINK-36562 URL: https://issues.apache.org/jira/browse/FLINK-36562 Project: Flink I

[jira] [Commented] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

[ https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890385#comment-17890385 ] LvYanquan commented on FLINK-36560: --- I've found the issue in code, and willing to fix

[jira] [Created] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

LvYanquan created FLINK-36560: - Summary: Fix the issue of timestamp_ltz increasing by 8 hours in Paimon Key: FLINK-36560 URL: https://issues.apache.org/jira/browse/FLINK-36560 Project: Flink Iss

[jira] [Commented] (FLINK-36546) Handle batch sources in DataSinkTranslator

[ https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889947#comment-17889947 ] LvYanquan commented on FLINK-36546: --- Hi Morozov, thanks for this optimization. I sugg

[jira] [Created] (FLINK-36541) Occasional met commit conflict problem in PaimonSink.

LvYanquan created FLINK-36541: - Summary: Occasional met commit conflict problem in PaimonSink. Key: FLINK-36541 URL: https://issues.apache.org/jira/browse/FLINK-36541 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-36475) YAML Transform supports case-insensitive column names conversion

[ https://issues.apache.org/jira/browse/FLINK-36475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889553#comment-17889553 ] LvYanquan commented on FLINK-36475: --- We can support uppercase in Paimon with catalog o

[jira] [Commented] (FLINK-36524) upgrade paimon 0.9.0

[ https://issues.apache.org/jira/browse/FLINK-36524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889535#comment-17889535 ] LvYanquan commented on FLINK-36524: --- I'm willing to do this. Please assign to me. > u

[jira] [Created] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372

LvYanquan created FLINK-36516: - Summary: Migrate deprecated SinkV2 API to new API introduced in FLIP-372 Key: FLINK-36516 URL: https://issues.apache.org/jira/browse/FLINK-36516 Project: Flink

[jira] [Commented] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink.

[ https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888509#comment-17888509 ] LvYanquan commented on FLINK-36509: --- I've found the resolution and would like to fix i

[jira] [Created] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink.

LvYanquan created FLINK-36509: - Summary: Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink. Key: FLINK-36509 URL: https://issues.apache.org/jira/browse/FLINK-36509 Project: Flink

[jira] [Commented] (FLINK-36414) NoSuchMethodError while trying flink cdc

[ https://issues.apache.org/jira/browse/FLINK-36414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888148#comment-17888148 ] LvYanquan commented on FLINK-36414: --- I would like to fix the compatiblity with flink-1

[jira] [Created] (FLINK-36459) Add document to guide user to configure debezium properties

LvYanquan created FLINK-36459: - Summary: Add document to guide user to configure debezium properties Key: FLINK-36459 URL: https://issues.apache.org/jira/browse/FLINK-36459 Project: Flink Issue

[jira] [Created] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading

LvYanquan created FLINK-36452: - Summary: Avoid EOFException when reading binlog after a large table has just completed snapshot reading Key: FLINK-36452 URL: https://issues.apache.org/jira/browse/FLINK-36452

[jira] [Commented] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887485#comment-17887485 ] LvYanquan commented on FLINK-33747: --- Removed together in the associated PR of this Jir

[jira] [Created] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated.

LvYanquan created FLINK-36413: - Summary: Reenable the test case that related to Source/Sink APi deprecated. Key: FLINK-36413 URL: https://issues.apache.org/jira/browse/FLINK-36413 Project: Flink

[jira] [Created] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink

LvYanquan created FLINK-36263: - Summary: Include only changed columns in old for canal format in Kakfa Sink Key: FLINK-36263 URL: https://issues.apache.org/jira/browse/FLINK-36263 Project: Flink

[jira] [Commented] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880826#comment-17880826 ] LvYanquan commented on FLINK-36245: --- Sure, I'm willing to take this, please assign to

[jira] [Created] (FLINK-36222) Support the use of LLM models for data processing in the transform module.

LvYanquan created FLINK-36222: - Summary: Support the use of LLM models for data processing in the transform module. Key: FLINK-36222 URL: https://issues.apache.org/jira/browse/FLINK-36222 Project: Flink

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent correctly.

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Summary: Parse CREATE TABLE LIKE to CreateTableEvent correctly. (was: Parse CREATE TABLE LIKE to Cre

[jira] [Commented] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877657#comment-17877657 ] LvYanquan commented on FLINK-36178: --- I'm willing to fix this. > Parse CREATE TABLE LI

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Component/s: Flink CDC > Parse CREATE TABLE LIKE to CreateTableEvent > --

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Labels: (was: cdc) > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Description: Currently, {{CREATE TABLE `user_log_copy_2` LIKE `user_log` SQL is not correctly parsed,

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Labels: cdc (was: ) > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Affects Version/s: cdc-3.2.0 > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Fix Version/s: cdc-3.2.0 > Parse CREATE TABLE LIKE to CreateTableEvent >

[jira] [Updated] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

[ https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36178: -- Summary: Parse CREATE TABLE LIKE to CreateTableEvent (was: Parse CREATE TABLE LIKE to CreateTableEve

[jira] [Created] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent

LvYanquan created FLINK-36178: - Summary: Parse CREATE TABLE LIKE to CreateTableEvent Key: FLINK-36178 URL: https://issues.apache.org/jira/browse/FLINK-36178 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

[ https://issues.apache.org/jira/browse/FLINK-36148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876398#comment-17876398 ] LvYanquan commented on FLINK-36148: --- I'm willing to fix this. > Support parsing DDL t

[jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

LvYanquan created FLINK-36148: - Summary: Support parsing DDL to new CreateTableEvent in binlog reading phase. Key: FLINK-36148 URL: https://issues.apache.org/jira/browse/FLINK-36148 Project: Flink

[jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876200#comment-17876200 ] LvYanquan commented on FLINK-36141: --- Thanks for reporting this, fixed in https://gith

[jira] [Commented] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage.

[ https://issues.apache.org/jira/browse/FLINK-36115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875353#comment-17875353 ] LvYanquan commented on FLINK-36115: --- I'm willing to support it. > Allow to scan newly

[jira] [Created] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage.

LvYanquan created FLINK-36115: - Summary: Allow to scan newly table DDL during incremental reading stage. Key: FLINK-36115 URL: https://issues.apache.org/jira/browse/FLINK-36115 Project: Flink Is

[jira] [Updated] (FLINK-36088) Fix NopointException in PaimonDataSink.

[ https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36088: -- Description: Fix NoPointException in BucketAssignOperator when job restarted. (was: Fix NopointExcept

[jira] [Closed] (FLINK-36087) Fix

[ https://issues.apache.org/jira/browse/FLINK-36087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan closed FLINK-36087. - Resolution: Fixed > Fix > --- > > Key: FLINK-36087 > URL: https://issues

[jira] [Created] (FLINK-36088) Fix NopointException in PaimonDataSink.

LvYanquan created FLINK-36088: - Summary: Fix NopointException in PaimonDataSink. Key: FLINK-36088 URL: https://issues.apache.org/jira/browse/FLINK-36088 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-36087) Fix

LvYanquan created FLINK-36087: - Summary: Fix Key: FLINK-36087 URL: https://issues.apache.org/jira/browse/FLINK-36087 Project: Flink Issue Type: Bug Reporter: LvYanquan -- This m

[jira] [Commented] (FLINK-36082) Fix NotSerializableException for KafkaDataSink

[ https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874601#comment-17874601 ] LvYanquan commented on FLINK-36082: --- I've found that it may related to lambda class in

[jira] [Created] (FLINK-36082) Fix NotSerializableException for KafkaDataSink

LvYanquan created FLINK-36082: - Summary: Fix NotSerializableException for KafkaDataSink Key: FLINK-36082 URL: https://issues.apache.org/jira/browse/FLINK-36082 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35938) Avoid commit the same datafile again in Paimon Sink.

LvYanquan created FLINK-35938: - Summary: Avoid commit the same datafile again in Paimon Sink. Key: FLINK-35938 URL: https://issues.apache.org/jira/browse/FLINK-35938 Project: Flink Issue Type: Te

[jira] [Created] (FLINK-35893) Add state compatibility for Serializer of TableChangeInfo

LvYanquan created FLINK-35893: - Summary: Add state compatibility for Serializer of TableChangeInfo Key: FLINK-35893 URL: https://issues.apache.org/jira/browse/FLINK-35893 Project: Flink Issue Ty

[jira] [Created] (FLINK-35891) Support writing dynamic bucket table of Paimon

LvYanquan created FLINK-35891: - Summary: Support writing dynamic bucket table of Paimon Key: FLINK-35891 URL: https://issues.apache.org/jira/browse/FLINK-35891 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-35888) Add e2e test for paimon DataSink

LvYanquan created FLINK-35888: - Summary: Add e2e test for paimon DataSink Key: FLINK-35888 URL: https://issues.apache.org/jira/browse/FLINK-35888 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-35873) Add HashFunctionProvider for Paimon DataSink.

LvYanquan created FLINK-35873: - Summary: Add HashFunctionProvider for Paimon DataSink. Key: FLINK-35873 URL: https://issues.apache.org/jira/browse/FLINK-35873 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-35871) Add document for SNAPSHOT startup option mode

LvYanquan created FLINK-35871: - Summary: Add document for SNAPSHOT startup option mode Key: FLINK-35871 URL: https://issues.apache.org/jira/browse/FLINK-35871 Project: Flink Issue Type: Technica

[jira] [Created] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.

LvYanquan created FLINK-35834: - Summary: Update Doris Dependency to 1.6.2 to use group commit. Key: FLINK-35834 URL: https://issues.apache.org/jira/browse/FLINK-35834 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-35802) Deadlock may happen after adding new tables

[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864522#comment-17864522 ] LvYanquan commented on FLINK-35802: --- Thanks, Please go ahead. > Deadlock may happen a

[jira] [Created] (FLINK-35802) Deadlock may happen after adding new tables

LvYanquan created FLINK-35802: - Summary: Deadlock may happen after adding new tables Key: FLINK-35802 URL: https://issues.apache.org/jira/browse/FLINK-35802 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35791) Add database and table infos to Kafka json output.

LvYanquan created FLINK-35791: - Summary: Add database and table infos to Kafka json output. Key: FLINK-35791 URL: https://issues.apache.org/jira/browse/FLINK-35791 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-35758) [Doc] add scan.startup.timestamp-millis options to MySQL connector docs.

LvYanquan created FLINK-35758: - Summary: [Doc] add scan.startup.timestamp-millis options to MySQL connector docs. Key: FLINK-35758 URL: https://issues.apache.org/jira/browse/FLINK-35758 Project: Flink

[jira] [Created] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException.

LvYanquan created FLINK-35718: - Summary: Cherrypick DBZ-5333 to fix frequently failover by EOFException. Key: FLINK-35718 URL: https://issues.apache.org/jira/browse/FLINK-35718 Project: Flink Is

[jira] [Created] (FLINK-35684) Add missing option for DataSource and DataSink

LvYanquan created FLINK-35684: - Summary: Add missing option for DataSource and DataSink Key: FLINK-35684 URL: https://issues.apache.org/jira/browse/FLINK-35684 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart.

LvYanquan created FLINK-35627: - Summary: Avoid conflict when pipeline job that used Paimon as sink restart. Key: FLINK-35627 URL: https://issues.apache.org/jira/browse/FLINK-35627 Project: Flink

[jira] [Created] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions

LvYanquan created FLINK-35589: - Summary: Support MemorySize type in FlinkCDC ConfigOptions Key: FLINK-35589 URL: https://issues.apache.org/jira/browse/FLINK-35589 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854655#comment-17854655 ] LvYanquan commented on FLINK-35237: --- I've met the same demand in Paimon Sink, and I ag

[jira] [Created] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1

LvYanquan created FLINK-35586: - Summary: Detected conflict when using Paimon as pipeline sink with parallelism > 1 Key: FLINK-35586 URL: https://issues.apache.org/jira/browse/FLINK-35586 Project: Flink

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35430: -- Fix Version/s: cdc-3.1.1 (was: cdc-3.2.0) > ZoneId is not passed to DebeziumJso

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35430: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > ZoneId is not passed to Deb

[jira] [Updated] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35325: -- Affects Version/s: cdc-3.1.1 (was: cdc-3.2.0) > Paimon connector miss the p

[jira] [Updated] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

[ https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35325: -- Fix Version/s: cdc-3.1.1 (was: cdc-3.2.0) > Paimon connector miss the position

[jira] [Created] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

LvYanquan created FLINK-35444: - Summary: Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Key: FLINK-35444 URL: https://issues.apache.org/jira/browse/FLINK-35444 Pro

[jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism

LvYanquan created FLINK-35442: - Summary: Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism Key: FLINK-35442 URL: https://issues.apache.org/jira/browse/FLINK-35442

[jira] [Created] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

LvYanquan created FLINK-35430: - Summary: ZoneId is not passed to DebeziumJsonSerializationSchema Key: FLINK-35430 URL: https://issues.apache.org/jira/browse/FLINK-35430 Project: Flink Issue Type:

[jira] [Commented] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout

[ https://issues.apache.org/jira/browse/FLINK-35421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848788#comment-17848788 ] LvYanquan commented on FLINK-35421: --- Thanks for pointing out this issue. I am willing

[jira] [Commented] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847748#comment-17847748 ] LvYanquan commented on FLINK-35391: --- Thanks for taking this, please go ahead, I am wil

[jira] [Updated] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-35391: -- Description: Apache Paimon has [released 0.8|https://paimon.apache.org/releases/release-0.8/] recently

[jira] [Created] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

LvYanquan created FLINK-35391: - Summary: Bump dependency of Paimon Pipeline connector to 0.8.0 Key: FLINK-35391 URL: https://issues.apache.org/jira/browse/FLINK-35391 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847138#comment-17847138 ] LvYanquan commented on FLINK-34614: --- done in pull-request https://github.com/apache/fl

[jira] [Created] (FLINK-35325) Paimon connector miss the position of AddColumnEvent

LvYanquan created FLINK-35325: - Summary: Paimon connector miss the position of AddColumnEvent Key: FLINK-35325 URL: https://issues.apache.org/jira/browse/FLINK-35325 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-35303) Support logical deletion of data

[ https://issues.apache.org/jira/browse/FLINK-35303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844224#comment-17844224 ] LvYanquan commented on FLINK-35303: --- Currently, we can add a metadata column from row_

[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar

LvYanquan created FLINK-35235: - Summary: Fix missing dependencies in the uber jar Key: FLINK-35235 URL: https://issues.apache.org/jira/browse/FLINK-35235 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35213) A potential inconsistent table structure issue

LvYanquan created FLINK-35213: - Summary: A potential inconsistent table structure issue Key: FLINK-35213 URL: https://issues.apache.org/jira/browse/FLINK-35213 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837975#comment-17837975 ] LvYanquan commented on FLINK-34752: --- [~siriusfan] Thanks for taking this, I don't have

[jira] [Created] (FLINK-34770) Unify download links of legacy connector to fat jar

LvYanquan created FLINK-34770: - Summary: Unify download links of legacy connector to fat jar Key: FLINK-34770 URL: https://issues.apache.org/jira/browse/FLINK-34770 Project: Flink Issue Type: Sub

[jira] [Commented] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation existed in 2.x version.

[ https://issues.apache.org/jira/browse/FLINK-34740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828660#comment-17828660 ] LvYanquan commented on FLINK-34740: --- Sorry for [~loserwang1024], I didn't notice that

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34748: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34750: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-34750: -- Description: Translate legacy-flink-cdc-sources pages of https://github.com/apache/flink-cdc/blob/mast

  1   2   >