[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread huangzhenhua (JIRA)


[ 
https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16621879#comment-16621879
 ] 

huangzhenhua commented on FLINK-10373:
--

Thank you very much for your help! 

> CoGroup Window support lateness 
> 
>
> Key: FLINK-10373
> URL: https://issues.apache.org/jira/browse/FLINK-10373
> Project: Flink
>  Issue Type: Improvement
>  Components: DataStream API
>Reporter: huangzhenhua
>Priority: Critical
>  Labels: cogroup, lateness
>
> I suggest that  CoGroup Window has the lateness event   process 
> function。Inside my business,   we hope that  the window  created by  two 
> stream join can process lateness event.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread huangzhenhua (JIRA)


[ 
https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16621590#comment-16621590
 ] 

huangzhenhua commented on FLINK-10373:
--

Thank you very much, that is just i want,!    Do you know when this improvement 
can release ? 

> CoGroup Window support lateness 
> 
>
> Key: FLINK-10373
> URL: https://issues.apache.org/jira/browse/FLINK-10373
> Project: Flink
>  Issue Type: Improvement
>  Components: DataStream API
>Reporter: huangzhenhua
>Priority: Critical
>  Labels: cogroup, lateness
>
> I suggest that  CoGroup Window has the lateness event   process 
> function。Inside my business,   we hope that  the window  created by  two 
> stream join can process lateness event.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (FLINK-10373) CoGroup Window support lateness

2018-09-19 Thread huangzhenhua (JIRA)
huangzhenhua created FLINK-10373:


 Summary: CoGroup Window support lateness 
 Key: FLINK-10373
 URL: https://issues.apache.org/jira/browse/FLINK-10373
 Project: Flink
  Issue Type: Improvement
  Components: DataStream API
Reporter: huangzhenhua


I suggest that  CoGroup Window has the lateness event   process function。Inside 
my business,   we hope that  the window  created by  two stream join can 
process lateness event.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)