Not able to run a simple table API file streaming sink

2022-07-11 Thread Jaya Ananthram
Hello There, I am trying to write a simple table API S3 streaming sink using flink 1.15.1 and I am facing the following exception, Caused by: org.apache.flink.util.SerializedThrowable: S3RecoverableFsDataOutputStream cannot sync state to S3. Use persist() to create a persistent recoverable interm

[jira] [Created] (FLINK-28467) AVRO Table API fails during schema evolution

2022-07-08 Thread Jaya Ananthram (Jira)
Jaya Ananthram created FLINK-28467: -- Summary: AVRO Table API fails during schema evolution Key: FLINK-28467 URL: https://issues.apache.org/jira/browse/FLINK-28467 Project: Flink Issue Type

[jira] [Created] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2022-07-12 Thread Jaya Ananthram (Jira)
Jaya Ananthram created FLINK-28513: -- Summary: Flink Table API CSV streaming sink throws SerializedThrowable exception Key: FLINK-28513 URL: https://issues.apache.org/jira/browse/FLINK-28513 Project