[jira] [Updated] (FLINK-28820) Pulsar Connector PulsarSink performance issue when delivery guarantee is not NONE

[ https://issues.apache.org/jira/browse/FLINK-28820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Su updated FLINK-28820: - Description: Pulsar Sink writes at a speed of a dozen messages per second when At-Least-Once and Exactly

[jira] [Created] (FLINK-28820) Pulsar Connector PulsarSink performance issue when delivery guarantee is not NONE

Simon Su created FLINK-28820: Summary: Pulsar Connector PulsarSink performance issue when delivery guarantee is not NONE Key: FLINK-28820 URL: https://issues.apache.org/jira/browse/FLINK-28820 Project: Fl

[jira] [Issue Comment Deleted] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Su updated FLINK-12692: - Comment: was deleted (was: Hi Yu Li, What's the difference between this and FsStateBackend ? Does this

[jira] [Commented] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16981443#comment-16981443 ] Simon Su commented on FLINK-12692: -- Hi Yu Li, What's the difference between this and Fs

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964702#comment-16964702 ] Simon Su commented on FLINK-14319: -- Hi, are there any new update for this issue ? > Re

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964692#comment-16964692 ] Simon Su commented on FLINK-7151: - Hi, will  this feature be released in 1.10 ? or it wil

[jira] [Commented] (FLINK-9412) Add a REST-based SQL Client Gateway

[ https://issues.apache.org/jira/browse/FLINK-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905739#comment-16905739 ] Simon Su commented on FLINK-9412: - Hi Timo, where is the design document link for this Ji

[jira] [Commented] (FLINK-13411) SqlClient swallow the error when fails to submit job

[ https://issues.apache.org/jira/browse/FLINK-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903795#comment-16903795 ] Simon Su commented on FLINK-13411: -- For DDL cases if sql-client connect to a persist ca

[jira] [Comment Edited] (FLINK-6962) Add a create table SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902996#comment-16902996 ] Simon Su edited comment on FLINK-6962 at 8/8/19 1:44 PM: - Hi [~tw

[jira] [Commented] (FLINK-6962) Add a create table SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902996#comment-16902996 ] Simon Su commented on FLINK-6962: - Is there a Jira for streaming-specific DDL ? > Add a

[jira] [Commented] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

[ https://issues.apache.org/jira/browse/FLINK-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898592#comment-16898592 ] Simon Su commented on FLINK-13492: -- Yes, I have marked it as duplicated. > BoundedOutO

[jira] [Closed] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

[ https://issues.apache.org/jira/browse/FLINK-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Su closed FLINK-13492. Resolution: Fixed > BoundedOutOfOrderTimestamps cause Watermark's timestamp leak > ---

[jira] [Created] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

Simon Su created FLINK-13492: Summary: BoundedOutOfOrderTimestamps cause Watermark's timestamp leak Key: FLINK-13492 URL: https://issues.apache.org/jira/browse/FLINK-13492 Project: Flink Issue T