[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770637#comment-17770637 ] jirawech.s commented on FLINK-31689: [~martijnvisser] Could you help with this PR, seems like no one

[jira] [Updated] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31689: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Filesystem sink

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753648#comment-17753648 ] jirawech.s commented on FLINK-31689: waiting for PR review

[jira] [Updated] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31689: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Filesystem sink

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727071#comment-17727071 ] jirawech.s commented on FLINK-31689: Anyone can help me review PR pls

[jira] [Commented] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712595#comment-17712595 ] jirawech.s commented on FLINK-31811: [~KristoffSC] I see. It may be duplicated issue, yet i see

[jira] [Commented] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712400#comment-17712400 ] jirawech.s commented on FLINK-31811: [~KristoffSC] I guess what you mentioned is parquet reader. I

[jira] [Created] (FLINK-31811) Unsupported complex data type for Flink SQL

jirawech.s created FLINK-31811: -- Summary: Unsupported complex data type for Flink SQL Key: FLINK-31811 URL: https://issues.apache.org/jira/browse/FLINK-31811 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712290#comment-17712290 ] jirawech.s commented on FLINK-31689: [~luoyuxia] I open

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708875#comment-17708875 ] jirawech.s commented on FLINK-31689: [~luoyuxia] Is it possible that you assign me to do this task?

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708271#comment-17708271 ] jirawech.s commented on FLINK-31689: [~luoyuxia] Thank you so much for detailed explanation. What

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708030#comment-17708030 ] jirawech.s commented on FLINK-31689: [~luoyuxia] I see. So, we could say that it is normal behaviour

[jira] [Commented] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

[ https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707891#comment-17707891 ] jirawech.s commented on FLINK-31689: Is this normal behavior? If i use Kafka Sink, i am able to

[jira] [Created] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

jirawech.s created FLINK-31689: -- Summary: Filesystem sink fails when parallelism of compactor operator changed Key: FLINK-31689 URL: https://issues.apache.org/jira/browse/FLINK-31689 Project: Flink

[jira] [Commented] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703828#comment-17703828 ] jirawech.s commented on FLINK-31424: [~qingyue] Thank you so much (y) > NullPointer when using

[jira] [Commented] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700249#comment-17700249 ] jirawech.s commented on FLINK-31424: [~zhengyiweng] Sure thing. Maybe you can take a look first and

[jira] [Commented] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700039#comment-17700039 ] jirawech.s commented on FLINK-31424: [~zhengyiweng] I see. Thank you so much. Could you mind walk me

[jira] [Updated] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31424: --- Description: I got following error when i tried to execute multiple sinks using StatementSet. I am

[jira] [Updated] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31424: --- Description: I got following error when i tried to execute multiple sinks using StatementSet. I am

[jira] [Created] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

jirawech.s created FLINK-31424: -- Summary: NullPointer when using StatementSet for multiple sinks Key: FLINK-31424 URL: https://issues.apache.org/jira/browse/FLINK-31424 Project: Flink Issue