[jira] [Updated] (FLINK-35452) MySQL CDC is not tracking newly added tables when a failure happens after the snapshot phase

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added

[jira] [Updated] (FLINK-35452) MySQL CDC is not tracking newly added tables when a failure happens after the snapshot phase

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Summary: MySQL CDC is not tracking newly added tables when a failure happens after the snapshot

[jira] [Updated] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added

[jira] [Updated] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added

[jira] [Created] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

Sharon Xie created FLINK-35452: -- Summary: MySQL CDC not tracking newly added tables after snapshot Key: FLINK-35452 URL: https://issues.apache.org/jira/browse/FLINK-35452 Project: Flink Issue

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[jira] [Created] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

Sharon Xie created FLINK-35147: -- Summary: SinkMaterializer throws StateMigrationException when widening the field type in the output table Key: FLINK-35147 URL: https://issues.apache.org/jira/browse/FLINK-35147

[jira] [Commented] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726479#comment-17726479 ] Sharon Xie commented on FLINK-32196: [~tzulitai]Thanks for analyzing the logs. As additional

[jira] [Comment Edited] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726405#comment-17726405 ] Sharon Xie edited comment on FLINK-32196 at 5/25/23 10:04 PM: -- Thank you

[jira] [Comment Edited] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726405#comment-17726405 ] Sharon Xie edited comment on FLINK-32196 at 5/25/23 10:04 PM: -- Thank you

[jira] [Updated] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Attachment: kafka_sink_oom_logs.csv > kafka sink under EO sometimes is unable to recover from a

[jira] [Updated] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Summary: kafka sink under EO sometimes is unable to recover from a checkpoint (was: KafkaWriter

[jira] [Updated] (FLINK-32196) kafka sink under EO sometimes is unable to recover from a checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Description: We are seeing an issue where a Flink job using kafka sink under EO is unable to

[jira] [Commented] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726405#comment-17726405 ] Sharon Xie commented on FLINK-32196: Thank you [~tzulitai] for the quick response and information.

[jira] [Updated] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Attachment: healthy_kafka_producer_thread.csv > KafkaWriter recovery doesn't abort lingering

[jira] [Updated] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Attachment: kafka_producer_network_thread_log.csv > KafkaWriter recovery doesn't abort lingering

[jira] [Created] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under EO semantic

Sharon Xie created FLINK-32196: -- Summary: KafkaWriter recovery doesn't abort lingering transactions under EO semantic Key: FLINK-32196 URL: https://issues.apache.org/jira/browse/FLINK-32196 Project:

[jira] [Updated] (FLINK-32196) KafkaWriter recovery doesn't abort lingering transactions under the EO semantic

[ https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-32196: --- Summary: KafkaWriter recovery doesn't abort lingering transactions under the EO semantic (was:

[jira] [Commented] (FLINK-28790) Incorrect KafkaProducer metrics initialization

[ https://issues.apache.org/jira/browse/FLINK-28790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626718#comment-17626718 ] Sharon Xie commented on FLINK-28790: I would add the `producer-metrics` and `producer-node-metrics`

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560591#comment-17560591 ] Sharon Xie commented on FLINK-28303: I posted this with logs in this thread:

[jira] [Updated] (FLINK-27712) Job failed to start due to "Time should be non negative"

[ https://issues.apache.org/jira/browse/FLINK-27712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-27712: --- Description: Happened intermittently. A restart made the issue go away. Stack trace: {code:java}

[jira] [Created] (FLINK-27712) Job failed to start due to "Time should be non negative"

Sharon Xie created FLINK-27712: -- Summary: Job failed to start due to "Time should be non negative" Key: FLINK-27712 URL: https://issues.apache.org/jira/browse/FLINK-27712 Project: Flink Issue

[jira] [Commented] (FLINK-10617) Restoring job fails because of slot allocation timeout

[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955652#comment-16955652 ] Sharon Xie commented on FLINK-10617: We can’t even reproduce it with the current system (1.5.5). The

[jira] [Commented] (FLINK-10617) Restoring job fails because of slot allocation timeout

[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953145#comment-16953145 ] Sharon Xie commented on FLINK-10617: I'm seeing the similar  issue with Flink 1.5.5.   We had 90