[jira] [Created] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

2016-10-19 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4862: - Summary: NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger Key: FLINK-4862 URL: https://issues.apache.org/jira/browse/FLINK-4862 Project: Flink

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

2016-10-19 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15590782#comment-15590782 ] Manu Zhang commented on FLINK-4862: --- A simple fix is to check for null return when looking up the

[jira] [Created] (FLINK-4863) states of merging window and trigger are set to different TimeWindows on merge

2016-10-20 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4863: - Summary: states of merging window and trigger are set to different TimeWindows on merge Key: FLINK-4863 URL: https://issues.apache.org/jira/browse/FLINK-4863 Project:

[jira] [Commented] (FLINK-4863) states of merging window and trigger are set to different TimeWindows on merge

2016-10-20 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15593811#comment-15593811 ] Manu Zhang commented on FLINK-4863: --- Found this is related to FLINK-4862.

[jira] [Closed] (FLINK-4863) states of merging window and trigger are set to different TimeWindows on merge

2016-10-20 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang closed FLINK-4863. - Resolution: Duplicate > states of merging window and trigger are set to different TimeWindows on merge >

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-22 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688654#comment-15688654 ] Manu Zhang commented on FLINK-5061: --- Agreed. Just some of my thoughts and should not block the changes.

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-21 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685244#comment-15685244 ] Manu Zhang commented on FLINK-5061: --- I mean users will want to fire before the end of event-time window

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-17 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673238#comment-15673238 ] Manu Zhang commented on FLINK-5061: --- We will always see elements with timestamp > watermark T. I think

[jira] [Created] (FLINK-4953) Allow querying time in window functions

2016-10-28 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4953: - Summary: Allow querying time in window functions Key: FLINK-4953 URL: https://issues.apache.org/jira/browse/FLINK-4953 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4952) Add Scala API for KeyedStream.flatMap

2016-10-27 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4952: - Summary: Add Scala API for KeyedStream.flatMap Key: FLINK-4952 URL: https://issues.apache.org/jira/browse/FLINK-4952 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4951) Better Javadocs for KeyedStream.flatMap

2016-10-27 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4951: - Summary: Better Javadocs for KeyedStream.flatMap Key: FLINK-4951 URL: https://issues.apache.org/jira/browse/FLINK-4951 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4838) remove STREAM keyword in StreamSQLExample

2016-10-16 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4838: - Summary: remove STREAM keyword in StreamSQLExample Key: FLINK-4838 URL: https://issues.apache.org/jira/browse/FLINK-4838 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5312) Implement Standalone Setup v2.0

2016-12-10 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-5312: - Summary: Implement Standalone Setup v2.0 Key: FLINK-5312 URL: https://issues.apache.org/jira/browse/FLINK-5312 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context

2017-03-22 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang reassigned FLINK-4953: - Assignee: Manu Zhang > Allow access to "time" in ProcessWindowFunction.Context >

[jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context

2017-03-22 Thread Manu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15937516#comment-15937516 ] Manu Zhang commented on FLINK-4953: --- [~aljoscha], yes, I'd love to. I'll assign it to myself. > Allow