[jira] [Created] (FLINK-37848) After timestamp mode is enabled, newly added tables will not have all their data synchronized.

2025-05-25 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-37848: - Summary: After timestamp mode is enabled, newly added tables will not have all their data synchronized. Key: FLINK-37848 URL: https://issues.apache.org/jira/browse/FLINK-37848

[jira] [Created] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level

2023-11-08 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-33484: - Summary: Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Key: FLINK-33484 URL: https://issues.apache.org/jira/browse/FLINK-33484

[jira] [Created] (FLINK-33239) After enabling exactly-once in the Flink Kafka sink, the Kafka broker's memory keeps increasing, eventually causing the Kafka broker to crash.

2023-10-11 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-33239: - Summary: After enabling exactly-once in the Flink Kafka sink, the Kafka broker's memory keeps increasing, eventually causing the Kafka broker to crash. Key: FLINK-33239 URL: https://is

[jira] [Created] (FLINK-27332) org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint

2022-04-20 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-27332: - Summary: org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint Key: FLINK-27332 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21839) SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint

2021-03-16 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-21839: - Summary: SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint Key: FLINK-21839 URL: https://issues.apache.org/jira/browse/FLINK-21839

[jira] [Created] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

2019-12-26 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-15406: - Summary: The savepoint is writted by "State Processor API" can't be restore by map or flatmap Key: FLINK-15406 URL: https://issues.apache.org/jira/browse/FLINK-15406 Projec