[jira] [Comment Edited] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103282#comment-16103282 ] Xingcan Cui edited comment on FLINK-7245 at 7/27/17 3:18 PM: -

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16103282#comment-16103282 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], it took me a little time to compre

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16100161#comment-16100161 ] Xingcan Cui commented on FLINK-7245: Thanks, [~fhueske]. The ideas are quite helpful.

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099299#comment-16099299 ] Xingcan Cui commented on FLINK-7245: Sure. I'll draw up a design document for that, as

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098106#comment-16098106 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], I fully agree. There will be two p

[jira] [Created] (FLINK-7245) Enhance the operators to support holding back watermarks

Xingcan Cui created FLINK-7245: -- Summary: Enhance the operators to support holding back watermarks Key: FLINK-7245 URL: https://issues.apache.org/jira/browse/FLINK-7245 Project: Flink Issue Type

[jira] [Comment Edited] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16096273#comment-16096273 ] Xingcan Cui edited comment on FLINK-6233 at 7/21/17 1:50 PM: -

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16096273#comment-16096273 ] Xingcan Cui commented on FLINK-6233: [~fhueske], according to your comment, we actuall

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094719#comment-16094719 ] Xingcan Cui commented on FLINK-6233: [~fhueske], thanks for the explanation. It' quite

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094634#comment-16094634 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for sharing. I totally agr

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16093298#comment-16093298 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for reminding me of the st

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092967#comment-16092967 ] Xingcan Cui commented on FLINK-6233: Hi, [~Yuhong_kyo], thanks for the assignment. I'l

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085352#comment-16085352 ] Xingcan Cui commented on FLINK-6936: Hi [~aljoscha], I have started a PR for that. I w

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074847#comment-16074847 ] Xingcan Cui commented on FLINK-6936: Hi [~aljoscha], sorry for the late reply. It take

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066532#comment-16066532 ] Xingcan Cui commented on FLINK-6936: [~aljoscha], thanks for your suggestion. The {{Un

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065817#comment-16065817 ] Xingcan Cui commented on FLINK-6936: [~aljoscha], thanks for your attention. You are r

[jira] [Commented] (FLINK-6936) Add multiple targets support for custom partitioner

[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055230#comment-16055230 ] Xingcan Cui commented on FLINK-6936: For self use, I have added a {{multicast}} method

[jira] [Created] (FLINK-6936) Add multiple targets support for custom partitioner

Xingcan Cui created FLINK-6936: -- Summary: Add multiple targets support for custom partitioner Key: FLINK-6936 URL: https://issues.apache.org/jira/browse/FLINK-6936 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006720#comment-16006720 ] Xingcan Cui commented on FLINK-6542: Hi [~twalthr], maybe we forget to call env.execut

[jira] [Commented] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16006520#comment-16006520 ] Xingcan Cui commented on FLINK-6542: Hi [~twalthr], it also produces an empty result i

[jira] [Assigned] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-6542: -- Assignee: Xingcan Cui > Non-keyed, non-windowed aggregation fails > ---

[jira] [Commented] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002672#comment-16002672 ] Xingcan Cui commented on FLINK-6247: Hi [~fhueske], as long as it doesn't matter for t

[jira] [Commented] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002083#comment-16002083 ] Xingcan Cui commented on FLINK-6247: Sorry for reawakening this. I know setting the de

[jira] [Assigned] (FLINK-6368) Grouping keys in stream aggregations have wrong order

[ https://issues.apache.org/jira/browse/FLINK-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-6368: -- Assignee: Xingcan Cui > Grouping keys in stream aggregations have wrong order > ---

[jira] [Commented] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15882017#comment-15882017 ] Xingcan Cui commented on FLINK-5891: Thanks for your explanation, [~greghogan]. I'm af

[jira] [Comment Edited] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879742#comment-15879742 ] Xingcan Cui edited comment on FLINK-5891 at 2/23/17 5:38 AM: -

[jira] [Comment Edited] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879742#comment-15879742 ] Xingcan Cui edited comment on FLINK-5891 at 2/23/17 5:25 AM: -

[jira] [Commented] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879742#comment-15879742 ] Xingcan Cui commented on FLINK-5891: Hi Greg, may I ask what does "when object reuse e

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

Title: Message Title Xingcan Cui commented on FLINK-1526

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

Title: Message Title Xingcan Cui edited a comment on FLINK-1526

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

Title: Message Title Xingcan Cui commented on FLINK-1526

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

Title: Message Title Xingcan Cui edited a comment on FLINK-1526

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

Title: Message Title Xingcan Cui commented on FLINK-1526

<    1   2   3   4