[jira] [Commented] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

2017-03-09 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904396#comment-15904396 ] sunjincheng commented on FLINK-5995: HI, [~srichter] [~aljoscha] Thanks for your sugge

[jira] [Created] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

2017-03-09 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6018: -- Summary: Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method Key: FLINK-6018 URL: https://issues.apache.org/jira/browse/FLINK-6018 Project: Fl

[jira] [Updated] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

2017-03-09 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6018: --- Description: The code snippet currently in the `AbstractKeyedStateBackend # getPartitionedState` meth

[jira] [Updated] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

2017-03-09 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6018: --- Description: The code snippet currently in the `AbstractKeyedStateBackend # getPartitionedState` meth

[jira] [Commented] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState()

2017-03-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907455#comment-15907455 ] sunjincheng commented on FLINK-6018: Hi,[~Dragon.L] [~aljoscha] Thank you for your att

[jira] [Commented] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState()

2017-03-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924328#comment-15924328 ] sunjincheng commented on FLINK-6018: Thanks [~aljoscha], I had Open the PR. feel free

[jira] [Created] (FLINK-6055) Supported setting timers on a Non-Keyed Stream

2017-03-14 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6055: -- Summary: Supported setting timers on a Non-Keyed Stream Key: FLINK-6055 URL: https://issues.apache.org/jira/browse/FLINK-6055 Project: Flink Issue Type: New Feat

[jira] [Commented] (FLINK-6055) Supported setting timers on a Non-Keyed Stream

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927696#comment-15927696 ] sunjincheng commented on FLINK-6055: Hi, [~xiaogang.shi] [~fhueske] [~aljoscha] thanks

[jira] [Created] (FLINK-6074) Fix

2017-03-16 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6074: -- Summary: Fix Key: FLINK-6074 URL: https://issues.apache.org/jira/browse/FLINK-6074 Project: Flink Issue Type: Bug Reporter: sunjincheng -- Thi

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Summary: Fix processFunction with watermark not work well (was: Fix ) > Fix processFunction with wate

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Summary: Fix processFunction with watermark not work well in tableAPI (was: Fix processFunction with

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Description: add description later > Fix processFunction with watermark not work well in tableAPI > --

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Description: I did a simple test and found that the same `AssignerWithPunctuatedWatermarks` and` Proc

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Description: I did a simple test and found that the same `AssignerWithPunctuatedWatermarks` and` Proc

[jira] [Assigned] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6074: -- Assignee: sunjincheng > Fix processFunction with watermark not work well in tableAPI >

[jira] [Updated] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6074: --- Component/s: Table API & SQL DataStream API > Fix processFunction with watermark not

[jira] [Created] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6097: -- Summary: Guaranteed the order of the extracted field references Key: FLINK-6097 URL: https://issues.apache.org/jira/browse/FLINK-6097 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6097: --- Description: The current `ProjectionTranslator # identifyFieldReferences` method uses the` Set` tempo

[jira] [Commented] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929681#comment-15929681 ] sunjincheng commented on FLINK-6097: I thank keep `a, b, c` . > Guaranteed the order

[jira] [Updated] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6097: --- Description: The current `ProjectionTranslator # identifyFieldReferences` method uses the` Set` tempo

[jira] [Updated] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6097: --- Description: The current `ProjectionTranslator # identifyFieldReferences` method uses the` Set` tempo

[jira] [Comment Edited] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929681#comment-15929681 ] sunjincheng edited comment on FLINK-6097 at 3/17/17 10:07 AM: --

[jira] [Updated] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6097: --- Description: When we try to implement `OVER window` TableAPI, The first version of the prototype to a

[jira] [Updated] (FLINK-6097) Guaranteed the order of the extracted field references

2017-03-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6097: --- Description: When we try to implement `OVER window` TableAPI, The first version of the prototype to a

[jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-18 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931569#comment-15931569 ] sunjincheng commented on FLINK-6074: When I using more test data,I find the cause of t

[jira] [Comment Edited] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-18 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931569#comment-15931569 ] sunjincheng edited comment on FLINK-6074 at 3/19/17 4:53 AM: -

[jira] [Closed] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-5995. -- Resolution: Fixed > Get a Exception when creating the ListStateDescriptor with a TypeInformation >

[jira] [Commented] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932181#comment-15932181 ] sunjincheng commented on FLINK-6074: Hi, [~aljoscha] Agree with you. I'll close this J

[jira] [Closed] (FLINK-6074) Fix processFunction with watermark not work well in tableAPI

2017-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6074. -- Resolution: Won't Fix > Fix processFunction with watermark not work well in tableAPI > -

[jira] [Commented] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068 ] sunjincheng commented on FLINK-5990: In this JIRA. I'll definition two concepts: 1. o

[jira] [Comment Edited] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068 ] sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM: -

[jira] [Comment Edited] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068 ] sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM: -

[jira] [Comment Edited] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068 ] sunjincheng edited comment on FLINK-5990 at 3/21/17 4:29 AM: -

[jira] [Created] (FLINK-6138) Improve UnboundedNonPartitionedProcessingOverProcessFunction

2017-03-20 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6138: -- Summary: Improve UnboundedNonPartitionedProcessingOverProcessFunction Key: FLINK-6138 URL: https://issues.apache.org/jira/browse/FLINK-6138 Project: Flink Issue

[jira] [Updated] (FLINK-5990) Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5990: --- Summary: Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL (was: Add even

[jira] [Updated] (FLINK-5990) Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5990: --- Description: The goal of this issue is to add support for OVER ROWS aggregations on event time stream

[jira] [Created] (FLINK-6145) Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-21 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6145: -- Summary: Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL Key: FLINK-6145 URL: https://issues.apache.org/jira/browse/FLINK-6145 Project:

[jira] [Updated] (FLINK-5990) Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5990: --- Description: The goal of this issue is to add support for OVER ROWS aggregations on event time stream

[jira] [Closed] (FLINK-6145) Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-24 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6145. -- Resolution: Fixed > Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to > SQL

[jira] [Commented] (FLINK-6145) Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-24 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941007#comment-15941007 ] sunjincheng commented on FLINK-6145: Fixed by [7a9d39f|https://github.com/apache/flin

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

2017-03-27 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6200: -- Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-6200 URL: https://issues.apache.org/jira/browse/FLINK-6200 Project: Flink

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

2017-03-27 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6200: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-4557 > Add event time OVER RANGE BETWEE

[jira] [Created] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-28 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6204: -- Summary: Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-6204 URL: https://issues.apache.org/jira/browse/FLINK-6204 Project: Flink

[jira] [Updated] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6204: --- Description: Currently `event time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL` impleme

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945104#comment-15945104 ] sunjincheng commented on FLINK-6204: [~fhueske] is right,list does not ensure the fail

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945183#comment-15945183 ] sunjincheng commented on FLINK-6204: [~Yuhong_kyo] Actually just like I comment in FLI

[jira] [Commented] (FLINK-6055) Supported setting timers on a Non-Keyed Stream

2017-03-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945191#comment-15945191 ] sunjincheng commented on FLINK-6055: In the OVER scene, we use NullByteKeySelector to

[jira] [Comment Edited] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945183#comment-15945183 ] sunjincheng edited comment on FLINK-6204 at 3/29/17 2:02 AM: -

[jira] [Closed] (FLINK-6055) Supported setting timers on a Non-Keyed Stream

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6055. -- Resolution: Won't Fix > Supported setting timers on a Non-Keyed Stream > ---

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946896#comment-15946896 ] sunjincheng commented on FLINK-6204: [~shijinkui] thanks for pay attention on this. A

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

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948097#comment-15948097 ] sunjincheng commented on FLINK-6200: Hi [~Yuhong_kyo] do you want take this JIRA.? If

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

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

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

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6200: -- Assignee: sunjincheng > Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQ

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

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948283#comment-15948283 ] sunjincheng commented on FLINK-6200: [~Yuhong_kyo] cool, I had assign this JIRA. to yo

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948373#comment-15948373 ] sunjincheng commented on FLINK-6204: Hi [~Yuhong_kyo], I once again considered LinkedL

[jira] [Commented] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948717#comment-15948717 ] sunjincheng commented on FLINK-6204: Yes, That's My meaning. This JIRA. will do the se

[jira] [Comment Edited] (FLINK-6204) Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948717#comment-15948717 ] sunjincheng edited comment on FLINK-6204 at 3/30/17 9:10 AM: -

[jira] [Updated] (FLINK-6204) Update all OVER window ProcessFunction implementations to use the SortedQueueState

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6204: --- Summary: Update all OVER window ProcessFunction implementations to use the SortedQueueState (was: Im

[jira] [Updated] (FLINK-6204) Update all OVER window ProcessFunction implementations to use the SortedQueueState

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6204: --- Description: Currently `event time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL` impleme

[jira] [Created] (FLINK-6219) Add a state backend which supports sorting

2017-03-30 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6219: -- Summary: Add a state backend which supports sorting Key: FLINK-6219 URL: https://issues.apache.org/jira/browse/FLINK-6219 Project: Flink Issue Type: New Feature

[jira] [Comment Edited] (FLINK-6204) Update all OVER window ProcessFunction implementations to use the SortedQueueState

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948717#comment-15948717 ] sunjincheng edited comment on FLINK-6204 at 3/30/17 9:46 AM: -

[jira] [Comment Edited] (FLINK-6204) Update all OVER window ProcessFunction implementations to use the SortedQueueState

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948717#comment-15948717 ] sunjincheng edited comment on FLINK-6204 at 3/30/17 9:46 AM: -

[jira] [Commented] (FLINK-4680) Add SlidingRow row-windows to Table API

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950165#comment-15950165 ] sunjincheng commented on FLINK-4680: Hi[~fhueske], Most of the SQL over has been merge

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174 ] sunjincheng commented on FLINK-5994: Hi [~twalthr] Recently I was working on FLIP 11 S

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 1:54 AM: -

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 1:53 AM: -

[jira] [Commented] (FLINK-6219) Add a state backend which supports sorting

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950504#comment-15950504 ] sunjincheng commented on FLINK-6219: Hi,[~xiaogang.shi] thanks for sharing this to us.

[jira] [Updated] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5994: --- Component/s: Distributed Coordination > Add Janino to flink-table JAR file > -

[jira] [Updated] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5994: --- Component/s: (was: Distributed Coordination) > Add Janino to flink-table JAR file > --

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng commented on FLINK-5994: Hi, [~twalthr] I have opened the PR.I took the u

[jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950555#comment-15950555 ] sunjincheng commented on FLINK-5227: Hi,[~fhueske] Maybe we can add `flink-table` depe

[jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950568#comment-15950568 ] sunjincheng commented on FLINK-5227: [~fhueske] So, Can I take this JIRA. and fix it?

[jira] [Created] (FLINK-6228) Integrating the OVER windows in the Table API

2017-03-31 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6228: -- Summary: Integrating the OVER windows in the Table API Key: FLINK-6228 URL: https://issues.apache.org/jira/browse/FLINK-6228 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , ..

[jira] [Closed] (FLINK-4680) Add SlidingRow row-windows to Table API

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-4680. -- Resolution: Duplicate > Add SlidingRow row-windows to Table API > --

[jira] [Commented] (FLINK-4680) Add SlidingRow row-windows to Table API

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950589#comment-15950589 ] sunjincheng commented on FLINK-4680: I had created FLINK-6228. > Add SlidingRow row-w

[jira] [Comment Edited] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950568#comment-15950568 ] sunjincheng edited comment on FLINK-5227 at 3/31/17 9:26 AM: -

[jira] [Issue Comment Deleted] (FLINK-4557) Table API Stream Aggregations

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-4557: --- Comment: was deleted (was: [~fhueske] Thanks for converter the "FLINK-5803" & "FLINK-5804" to FLINK-4

[jira] [Comment Edited] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950568#comment-15950568 ] sunjincheng edited comment on FLINK-5227 at 3/31/17 10:03 AM: --

[jira] [Comment Edited] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950568#comment-15950568 ] sunjincheng edited comment on FLINK-5227 at 3/31/17 10:06 AM: --

[jira] [Assigned] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-5227: -- Assignee: sunjincheng > Add warning to include flink-table in job fat jars > --

[jira] [Commented] (FLINK-5227) Add warning to include flink-table in job fat jars

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950645#comment-15950645 ] sunjincheng commented on FLINK-5227: Yes, Agree! I got you. > Add warning to include

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 12:00 PM: --

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 12:01 PM: --

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 12:03 PM: --

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 12:21 PM: --

[jira] [Comment Edited] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950541#comment-15950541 ] sunjincheng edited comment on FLINK-5994 at 3/31/17 12:22 PM: --

[jira] [Created] (FLINK-6259) Fix a small spelling error

2017-04-03 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6259: -- Summary: Fix a small spelling error Key: FLINK-6259 URL: https://issues.apache.org/jira/browse/FLINK-6259 Project: Flink Issue Type: Bug Components: Ge

[jira] [Updated] (FLINK-6259) Fix a small spelling error

2017-04-03 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6259: --- Description: flink-gelly-scala/pom.xml {{har-with-dependencies}} -> {{jar-with-dependencies}} (was:

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956221#comment-15956221 ] sunjincheng commented on FLINK-6257: Hi [~fhueske] I like this proposal very much. We

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Updated] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6228: --- Description: Syntax: {code} table .overWindows( (Rows|Range [ partitionBy value_expression , .

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-04 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956393#comment-15956393 ] sunjincheng commented on FLINK-6228: Hi, [~fhueske] about {{orderBy}} clause the time

[jira] [Created] (FLINK-6266) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6266: -- Summary: Remove the useless import in FlinkRelBuilder Key: FLINK-6266 URL: https://issues.apache.org/jira/browse/FLINK-6266 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-6267) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6267: -- Summary: Remove the useless import in FlinkRelBuilder Key: FLINK-6267 URL: https://issues.apache.org/jira/browse/FLINK-6267 Project: Flink Issue Type: Improvemen

  1   2   3   4   5   6   7   8   9   10   >