[
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
tables,
[
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 phas
[
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
tables,
[
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
tables,
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 Ty
[
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) ->
[
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) ->
[
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) ->
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
[
https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726479#comment-17726479
]
Sharon Xie commented on FLINK-32196:
[~tzulitai]Thanks for analyzing the logs. As ad
[
https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726405#comment-17726405
]
Sharon Xie edited comment on FLINK-32196 at 5/25/23 10:04 PM:
[
https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726405#comment-17726405
]
Sharon Xie edited comment on FLINK-32196 at 5/25/23 10:04 PM:
[
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 chec
[
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 rec
[
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
recove
[
https://issues.apache.org/jira/browse/FLINK-32196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726405#comment-17726405
]
Sharon Xie commented on FLINK-32196:
Thank you [~tzulitai] for the quick response an
[
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 transac
[
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 tra
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: Flin
[
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: Kafk
[
https://issues.apache.org/jira/browse/FLINK-28790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626718#comment-17626718
]
Sharon Xie commented on FLINK-28790:
I would add the `producer-metrics` and `produce
[
https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560591#comment-17560591
]
Sharon Xie commented on FLINK-28303:
I posted this with logs in this thread:
https:
[
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}
Ti
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955652#comment-16955652
]
Sharon Xie commented on FLINK-10617:
We can’t even reproduce it with the current sys
[
https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953145#comment-16953145
]
Sharon Xie commented on FLINK-10617:
I'm seeing the similar issue with Flink 1.5.5.
26 matches
Mail list logo