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
[
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
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:
[
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.
[
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
>
[
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.
[
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
[
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
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
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
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
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
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
[
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
>
[
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
15 matches
Mail list logo