[jira] [Updated] (FLINK-36182) PyFlink SQL Job Got IllegalStateException During Task Manager Shutdown

[ https://issues.apache.org/jira/browse/FLINK-36182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EMERSON WANG updated FLINK-36182: - Description: PyFlink SQL job was running in the AWS EKS cluster. When the task manager pods wer

[jira] [Created] (FLINK-36182) PyFlink SQL Job Got IllegalStateException During Task Manager Shutdown

EMERSON WANG created FLINK-36182: Summary: PyFlink SQL Job Got IllegalStateException During Task Manager Shutdown Key: FLINK-36182 URL: https://issues.apache.org/jira/browse/FLINK-36182 Project: Flink

[jira] [Comment Edited] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853204#comment-17853204 ] EMERSON WANG edited comment on FLINK-35521 at 6/7/24 4:21 PM:

[jira] [Commented] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853204#comment-17853204 ] EMERSON WANG commented on FLINK-35521: -- We ran our PyFlink SQL jobs in both AWS EKS

[jira] [Comment Edited] (FLINK-24605) org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-24605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852128#comment-17852128 ] EMERSON WANG edited comment on FLINK-24605 at 6/6/24 5:21 PM:

[jira] [Comment Edited] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852866#comment-17852866 ] EMERSON WANG edited comment on FLINK-35521 at 6/6/24 4:52 PM:

[jira] [Commented] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852866#comment-17852866 ] EMERSON WANG commented on FLINK-35521: -- @luoyuxia:   We output data using 1 minute

[jira] [Comment Edited] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852866#comment-17852866 ] EMERSON WANG edited comment on FLINK-35521 at 6/6/24 4:51 PM:

[jira] [Updated] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EMERSON WANG updated FLINK-35521: - Summary: Flink FileSystem SQL Connector Generating SUCCESS File Multiple Times (was: Flink File

[jira] [Commented] (FLINK-24605) org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

[ https://issues.apache.org/jira/browse/FLINK-24605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852128#comment-17852128 ] EMERSON WANG commented on FLINK-24605: -- We got the same exception when scan.startup

[jira] [Updated] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCESS File Multiple Times

[ https://issues.apache.org/jira/browse/FLINK-35521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EMERSON WANG updated FLINK-35521: - Description: Our Flink table SQL job received data from the Kafka streams and then sinked all p

[jira] [Created] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCESS File Multiple Times

EMERSON WANG created FLINK-35521: Summary: Flink FileSystem SQL Connector Generating SUCESS File Multiple Times Key: FLINK-35521 URL: https://issues.apache.org/jira/browse/FLINK-35521 Project: Flink