[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&focusedCommentId=17770637#comment-17770637 ] jirawech.s commented on FLINK-31689: [~martijnvisser] Could you help with this PR, s

[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 fails

[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&focusedCommentId=17753648#comment-17753648 ] jirawech.s commented on FLINK-31689: waiting for PR review https://github.com/apache

[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 fails

[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&focusedCommentId=17727071#comment-17727071 ] jirawech.s commented on FLINK-31689: Anyone can help me review PR pls https://githu

[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&focusedCommentId=17712595#comment-17712595 ] jirawech.s commented on FLINK-31811: [~KristoffSC] I see. It may be duplicated issue

[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&focusedCommentId=17712400#comment-17712400 ] jirawech.s commented on FLINK-31811: [~KristoffSC] I guess what you mentioned is par

[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&focusedCommentId=17712290#comment-17712290 ] jirawech.s commented on FLINK-31689: [~luoyuxia] I open [PR|https://github.com/apach

[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&focusedCommentId=17708875#comment-17708875 ] jirawech.s commented on FLINK-31689: [~luoyuxia] Is it possible that you assign me t

[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&focusedCommentId=17708271#comment-17708271 ] jirawech.s commented on FLINK-31689: [~luoyuxia] Thank you so much for detailed expl

[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&focusedCommentId=17708030#comment-17708030 ] jirawech.s commented on FLINK-31689: [~luoyuxia] I see. So, we could say that it is

[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&focusedCommentId=17707891#comment-17707891 ] jirawech.s commented on FLINK-31689: Is this normal behavior? If i use Kafka Sink, i

[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&focusedCommentId=17703828#comment-17703828 ] jirawech.s commented on FLINK-31424: [~qingyue] Thank you so much (y) > NullPointer

[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&focusedCommentId=17700249#comment-17700249 ] jirawech.s commented on FLINK-31424: [~zhengyiweng] Sure thing. Maybe you can take a

[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&focusedCommentId=17700039#comment-17700039 ] jirawech.s commented on FLINK-31424: [~zhengyiweng] I see. Thank you so much. Could

[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 Type