[jira] [Commented] (FLINK-6187) Cancel job failed with option -m on yarn session

2017-03-26 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942552#comment-15942552 ] Yuhong Hong commented on FLINK-6187: Yes, i have configure HA, the problem seems to be when i config

[jira] [Created] (FLINK-6187) Cancel job failed with option -m on yarn session

2017-03-25 Thread Yuhong Hong (JIRA)
Yuhong Hong created FLINK-6187: -- Summary: Cancel job failed with option -m on yarn session Key: FLINK-6187 URL: https://issues.apache.org/jira/browse/FLINK-6187 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

2017-03-17 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929476#comment-15929476 ] Yuhong Hong commented on FLINK-5725: In this issue, i mostly want to support join like follow: {code}

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-08 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902261#comment-15902261 ] Yuhong Hong commented on FLINK-5658: Hi [~sunjincheng121], i agree with you, i have already rewrite

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-28 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889387#comment-15889387 ] Yuhong Hong commented on FLINK-5658: Hi [~fhueske], as we talked before, We simply discard late

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-20 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875533#comment-15875533 ] Yuhong Hong commented on FLINK-5658: Hi [~fhueske] & [~wheat9], i saw haohui have already commit the

[jira] [Assigned] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-08 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhong Hong reassigned FLINK-5658: -- Assignee: Yuhong Hong (was: sunjincheng) > Add event time OVER RANGE BETWEEN UNBOUNDED

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-08 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857615#comment-15857615 ] Yuhong Hong commented on FLINK-5658: Got it. Thanks very much. [~sunjincheng121] i'm glad to start

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-07 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857232#comment-15857232 ] Yuhong Hong commented on FLINK-5658: HI, [~sunjincheng121] thanks for you explain. As your

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-07 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855868#comment-15855868 ] Yuhong Hong commented on FLINK-5658: Hi, [~sunjincheng121] & Fabian, i have some confuse about this

[jira] [Commented] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-06 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853890#comment-15853890 ] Yuhong Hong commented on FLINK-5657: Hi Fabian, I'm interested in implementing this issue. As

[jira] [Assigned] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-05 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhong Hong reassigned FLINK-5657: -- Assignee: sunjincheng (was: Yuhong Hong) > Add processing time OVER RANGE BETWEEN UNBOUNDED

[jira] [Assigned] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-05 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhong Hong reassigned FLINK-5657: -- Assignee: Yuhong Hong (was: sunjincheng) > Add processing time OVER RANGE BETWEEN UNBOUNDED

[jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql

2017-01-19 Thread Yuhong Hong (JIRA)
Yuhong Hong created FLINK-5584: -- Summary: Support Sliding-count row-window on streaming sql Key: FLINK-5584 URL: https://issues.apache.org/jira/browse/FLINK-5584 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823750#comment-15823750 ] Yuhong Hong commented on FLINK-5500: Yes, i'm using the latest calcite, but i test with 1.10, it also

[jira] [Created] (FLINK-5500) Error when created array literals

2017-01-16 Thread Yuhong Hong (JIRA)
Yuhong Hong created FLINK-5500: -- Summary: Error when created array literals Key: FLINK-5500 URL: https://issues.apache.org/jira/browse/FLINK-5500 Project: Flink Issue Type: Bug