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

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui commented on FLINK-1526

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

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui commented on FLINK-1526

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

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui edited a comment on FLINK-1526

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

2017-01-29 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui commented on FLINK-1526

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

2017-01-29 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui edited a comment on FLINK-1526

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

2017-02-23 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882017#comment-15882017 ] Xingcan Cui commented on FLINK-5891: Thanks for your explanation, [~greghogan]. I'm afraid my PR on

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

2017-02-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879742#comment-15879742 ] Xingcan Cui commented on FLINK-5891: Hi Greg, may I ask what does "when object reuse enabled" mean

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

2017-02-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879742#comment-15879742 ] Xingcan Cui edited comment on FLINK-5891 at 2/23/17 5:25 AM: - Hi Greg, may I

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

2017-02-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879742#comment-15879742 ] Xingcan Cui edited comment on FLINK-5891 at 2/23/17 5:38 AM: - Hi Greg, may I

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

2017-07-30 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106399#comment-16106399 ] Xingcan Cui commented on FLINK-7245: Thanks for the answer and the suggestion, [~fhueske]. I'll keep

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-04 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114196#comment-16114196 ] Xingcan Cui commented on FLINK-7337: Hi [~fhueske], sorry for the silly questions. In my mind, to

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

2017-08-04 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114167#comment-16114167 ] Xingcan Cui commented on FLINK-7245: Hi all, I'd like to throw out some basic ideas about the design.

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

2017-08-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128434#comment-16128434 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], I have accomplished a basic version of the rowtime

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

2017-08-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126895#comment-16126895 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for the response. # I'll do the

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

2017-08-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126895#comment-16126895 ] Xingcan Cui edited comment on FLINK-6233 at 8/15/17 10:48 AM: -- Hi [~fhueske],

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

2017-08-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123328#comment-16123328 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], thanks for the response. I think you are right.

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

2017-08-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121855#comment-16121855 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], I've got some new ideas about the

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

2017-08-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125182#comment-16125182 ] Xingcan Cui edited comment on FLINK-6233 at 8/14/17 8:52 AM: - Hi [~fhueske],

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

2017-08-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125182#comment-16125182 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for the previous work by you and yuhong,

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

2017-08-17 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129080#comment-16129080 ] Xingcan Cui edited comment on FLINK-6233 at 8/17/17 6:05 AM: - Hi [~fhueske], I

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

2017-07-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085352#comment-16085352 ] Xingcan Cui commented on FLINK-6936: Hi [~aljoscha], I have started a PR for that. I wonder if you

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

2017-07-20 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094634#comment-16094634 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for sharing. I totally agree to your first

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

2017-07-20 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094719#comment-16094719 ] Xingcan Cui commented on FLINK-6233: [~fhueske], thanks for the explanation. It' quite clear. There's

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

2017-07-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093298#comment-16093298 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for reminding me of the state point. I

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

2017-07-21 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096273#comment-16096273 ] Xingcan Cui commented on FLINK-6233: [~fhueske], according to your comment, we actually not change the

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

2017-07-21 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096273#comment-16096273 ] Xingcan Cui edited comment on FLINK-6233 at 7/21/17 1:50 PM: - [~fhueske],

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

2017-07-25 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16100161#comment-16100161 ] Xingcan Cui commented on FLINK-7245: Thanks, [~fhueske]. The ideas are quite helpful. I'd like to put

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

2017-07-23 Thread Xingcan Cui (JIRA)
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

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

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

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

2017-07-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103282#comment-16103282 ] Xingcan Cui edited comment on FLINK-7245 at 7/27/17 3:18 PM: - Hi [~fhueske],

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

2017-07-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103282#comment-16103282 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], it took me a little time to comprehend how the

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

2017-07-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092967#comment-16092967 ] Xingcan Cui commented on FLINK-6233: Hi, [~Yuhong_kyo], thanks for the assignment. I'll devote myself

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

2017-07-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098106#comment-16098106 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], I fully agree. There will be two preconditions for

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

2017-07-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074847#comment-16074847 ] Xingcan Cui commented on FLINK-6936: Hi [~aljoscha], sorry for the late reply. It takes me a little

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

2017-06-28 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16066532#comment-16066532 ] Xingcan Cui commented on FLINK-6936: [~aljoscha], thanks for your suggestion. The {{UnionListState}}

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

2017-04-24 Thread Xingcan Cui (JIRA)
[ 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-7337) Refactor handling of time indicator attributes

2017-08-04 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115247#comment-16115247 ] Xingcan Cui commented on FLINK-7337: Thanks for the explanation, [~fhueske]. Everything's clear to me

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

2017-08-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115441#comment-16115441 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], thanks for your responses. They are really

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109139#comment-16109139 ] Xingcan Cui commented on FLINK-7337: Hi [~fhueske], thanks for the JIRA. I just wonder if the

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

2017-08-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120145#comment-16120145 ] Xingcan Cui commented on FLINK-7245: I have made some minor changes, which can be found at

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

2017-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118491#comment-16118491 ] Xingcan Cui commented on FLINK-7245: Thanks for your responses, [~fhueske]. Actually, we were thinking

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

2017-08-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129080#comment-16129080 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], I find my approach for dealing with the

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-08-17 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131629#comment-16131629 ] Xingcan Cui commented on FLINK-7446: Now that the rowtime field is an existing one in the stream,

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-08-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133050#comment-16133050 ] Xingcan Cui commented on FLINK-7446: Thanks for the response, [~fhueske]. From my perspective, I

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

2017-05-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006520#comment-16006520 ] Xingcan Cui commented on FLINK-6542: Hi [~twalthr], it also produces an empty result in my IDE. >

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

2017-05-11 Thread Xingcan Cui (JIRA)
[ 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-6542) Non-keyed, non-windowed aggregation fails

2017-05-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006720#comment-16006720 ] Xingcan Cui commented on FLINK-6542: Hi [~twalthr], maybe we forget to call env.execute()... >

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

2017-05-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002083#comment-16002083 ] Xingcan Cui commented on FLINK-6247: Sorry for reawakening this. I know setting the dependencies with

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

2017-05-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002672#comment-16002672 ] Xingcan Cui commented on FLINK-6247: Hi [~fhueske], as long as it doesn't matter for the target jar, I

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

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

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

2017-06-16 Thread Xingcan Cui (JIRA)
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:

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

2017-06-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065817#comment-16065817 ] Xingcan Cui commented on FLINK-6936: [~aljoscha], thanks for your attention. You are right, that the

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176020#comment-16176020 ] Xingcan Cui commented on FLINK-7548: Hi [~fhueske] and [~jark], sorry for the late reply. Honestly, I

[jira] [Commented] (FLINK-7698) Join with null literals leads to NPE

2017-10-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194585#comment-16194585 ] Xingcan Cui commented on FLINK-7698: Hi [~twalthr], this problem has be addressed in

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-04 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191095#comment-16191095 ] Xingcan Cui commented on FLINK-7730: Sure. I'll consult the Calcite community for this problem. >

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16190718#comment-16190718 ] Xingcan Cui commented on FLINK-7388: Hi [~phoenixjiangnan], I think this ticket is for the

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198285#comment-16198285 ] Xingcan Cui commented on FLINK-7764: This problem may be caused by the recent refactoring of Kafka

[jira] [Comment Edited] (FLINK-7799) Improve performance of windowed joins

2017-10-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204554#comment-16204554 ] Xingcan Cui edited comment on FLINK-7799 at 10/15/17 8:11 AM: -- Hi [~fhueske],

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205239#comment-16205239 ] Xingcan Cui commented on FLINK-7730: Thanks for the discussion, [~fhueske]. I've checked that the left

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206121#comment-16206121 ] Xingcan Cui commented on FLINK-7730: Hi [~fhueske], more reasons are revealed for these issues. 1.

[jira] [Comment Edited] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206121#comment-16206121 ] Xingcan Cui edited comment on FLINK-7730 at 10/16/17 4:17 PM: -- Hi [~fhueske],

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-17 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207782#comment-16207782 ] Xingcan Cui commented on FLINK-7548: Hi [~fhueske], sorry for the late reply. I'll first share some

[jira] [Commented] (FLINK-7799) Improve performance of windowed joins

2017-10-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204554#comment-16204554 ] Xingcan Cui commented on FLINK-7799: Hi [~fhueske], I've reconsidered this problem and found a

[jira] [Assigned] (FLINK-7799) Improve performance of windowed joins

2017-10-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7799: -- Assignee: Xingcan Cui > Improve performance of windowed joins >

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200247#comment-16200247 ] Xingcan Cui commented on FLINK-7798: Hi [~fhueske], I tried to add the check logic, but encountered

[jira] [Created] (FLINK-7853) Reject table function outer joins with predicates in Table API

2017-10-16 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-7853: -- Summary: Reject table function outer joins with predicates in Table API Key: FLINK-7853 URL: https://issues.apache.org/jira/browse/FLINK-7853 Project: Flink

[jira] [Assigned] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

2017-10-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7854: -- Assignee: Xingcan Cui > Reject lateral table outer joins with predicates in SQL >

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-26 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181847#comment-16181847 ] Xingcan Cui commented on FLINK-7548: Thanks for the explanation, [~fhueske]. I was too paranoid about

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-25 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180077#comment-16180077 ] Xingcan Cui commented on FLINK-7548: Thanks for the answers, [~fhueske]. Some extra comments. About

[jira] [Assigned] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-09-30 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7730: -- Assignee: Xingcan Cui > TableFunction LEFT OUTER joins with ON predicates are broken >

[jira] [Comment Edited] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187397#comment-16187397 ] Xingcan Cui edited comment on FLINK-7730 at 10/1/17 2:26 PM: - Hi [~fhueske],

[jira] [Comment Edited] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187397#comment-16187397 ] Xingcan Cui edited comment on FLINK-7730 at 10/1/17 2:24 PM: - Hi [~fhueske],

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187397#comment-16187397 ] Xingcan Cui commented on FLINK-7730: Hi [~fhueske], I've checked the implementation and got some clues

[jira] [Assigned] (FLINK-7698) Join with null literals leads to NPE

2017-09-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7698: -- Assignee: Xingcan Cui > Join with null literals leads to NPE >

[jira] [Commented] (FLINK-7698) Join with null literals leads to NPE

2017-09-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182660#comment-16182660 ] Xingcan Cui commented on FLINK-7698: Hi [~twalthr], thanks for this ticket. It seems that the null

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

2017-08-28 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144102#comment-16144102 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], the [document|https://goo.gl/VW5Gpd] has been

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

2017-08-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16139667#comment-16139667 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], since the logic is complicated, I am preparing a

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-08-29 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144836#comment-16144836 ] Xingcan Cui commented on FLINK-7548: Thanks for the issue [~jark]. I'd like to share some ideas about

[jira] [Assigned] (FLINK-7564) Fix Watermark semantics in Table API

2017-08-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7564: -- Assignee: Xingcan Cui > Fix Watermark semantics in Table API >

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

2017-09-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16150282#comment-16150282 ] Xingcan Cui commented on FLINK-6233: Hi [~fhueske], thanks for your comments. They are really helpful

[jira] [Assigned] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7764: -- Assignee: Xingcan Cui > FlinkKafkaProducer010 does not accept name, uid, or parallelism >

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199824#comment-16199824 ] Xingcan Cui commented on FLINK-7798: Hi [~fhueske], as you said, most of the related code has already

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

2017-10-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7798: -- Assignee: Xingcan Cui > Add support for windowed joins to Table API >

[jira] [Created] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

2017-10-18 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-7865: -- Summary: Remove predicate restrictions on TableFunction left outer join Key: FLINK-7865 URL: https://issues.apache.org/jira/browse/FLINK-7865 Project: Flink

[jira] [Updated] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

2017-10-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-7865: --- Description: To cover up the improper translation of lateral table left outer join (CALCITE-2004),

[jira] [Commented] (FLINK-7800) Enable window joins without equi-join predicates

2017-10-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216573#comment-16216573 ] Xingcan Cui commented on FLINK-7800: Hi [~fhueske], thanks for opening this. I got a question about

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252794#comment-16252794 ] Xingcan Cui commented on FLINK-8069: Thanks for the explanation [~twalthr] > Support empty watermark

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-11-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262178#comment-16262178 ] Xingcan Cui commented on FLINK-7797: Hi [~fhueske], I'd like to work on it. :D > Add support for

[jira] [Commented] (FLINK-8118) Allow to specify the offsets of KafkaTableSources

2017-11-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262563#comment-16262563 ] Xingcan Cui commented on FLINK-8118: Hi [~fhueske], thanks for the suggestions! Since the existing

[jira] [Commented] (FLINK-8158) Rowtime window inner join emits late data

2017-11-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267995#comment-16267995 ] Xingcan Cui commented on FLINK-8158: Hi [~hequn8128], there's a document about the stream window join

[jira] [Comment Edited] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289369#comment-16289369 ] Xingcan Cui edited comment on FLINK-8236 at 12/13/17 3:15 PM: -- Hi [~twalthr],

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289369#comment-16289369 ] Xingcan Cui commented on FLINK-8236: Hi [~twalthr], thanks for raising this. I got a question about

[jira] [Assigned] (FLINK-8278) Scala examples in Metric documentation do not compile

2017-12-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8278: -- Assignee: Xingcan Cui > Scala examples in Metric documentation do not compile >

[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295193#comment-16295193 ] Xingcan Cui commented on FLINK-8282: Hi [~twalthr], thanks for this ticket. I just wonder whether we

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290443#comment-16290443 ] Xingcan Cui commented on FLINK-8236: We need to enable the batch query configuration first. > Allow

[jira] [Created] (FLINK-8258) Enable query configuration for batch queries

2017-12-13 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8258: -- Summary: Enable query configuration for batch queries Key: FLINK-8258 URL: https://issues.apache.org/jira/browse/FLINK-8258 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism()

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8257: --- Description: The {{setParallelism()}} method exist in many components from different levels. Some of

[jira] [Created] (FLINK-8257) Unify the value checks for setParallelism()

2017-12-13 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8257: -- Summary: Unify the value checks for setParallelism() Key: FLINK-8257 URL: https://issues.apache.org/jira/browse/FLINK-8257 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289414#comment-16289414 ] Xingcan Cui commented on FLINK-8236: Hi [~twalthr], thanks for your explanation. I think that won't be

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289451#comment-16289451 ] Xingcan Cui commented on FLINK-8236: Yes, maybe we should consider unifying them since in some classes

  1   2   3   4   >