[jira] [Comment Edited] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng edited comment on FLINK-5695 at 2/3/17 2:47 AM: Hi, [~fhueske] ,

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855633#comment-15855633 ] sunjincheng commented on FLINK-5695: Thanks [~fhueske] got your mean. I will think about it and reply

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855567#comment-15855567 ] sunjincheng commented on FLINK-5695: Hi, [~fhueske] you are right when users simply use "tableapi",

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855793#comment-15855793 ] sunjincheng commented on FLINK-5657: Hi [~Yuhong_kyo], [~rtudoran], and [~fhueske], thanks for sharing

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

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856095#comment-15856095 ] sunjincheng edited comment on FLINK-5658 at 2/7/17 2:55 PM: Hi,[~Yuhong_kyo]

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

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856095#comment-15856095 ] sunjincheng commented on FLINK-5658: Hi,[~Yuhong_kyo] I'm glad you're interested in this jira, and I'm

[jira] [Comment Edited] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng edited comment on FLINK-5695 at 2/3/17 2:48 AM: Hi, [~fhueske] ,

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850965#comment-15850965 ] sunjincheng commented on FLINK-5695: Hi, [~fhueske] , Yes, I would like to explain my purpose:

[jira] [Updated] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5695: --- Description: Optimize table type systems based on database semantics.As follows: {code}

[jira] [Created] (FLINK-5695) Optimize table type systems based on database semantics

sunjincheng created FLINK-5695: -- Summary: Optimize table type systems based on database semantics Key: FLINK-5695 URL: https://issues.apache.org/jira/browse/FLINK-5695 Project: Flink Issue

[jira] [Updated] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5695: --- Description: Optimize table type systems based on database semantics.As follows: {code}

[jira] [Updated] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5695: --- Description: Optimize table type systems based on database semantics.As follows: {code}

[jira] [Updated] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5695: --- Description: Optimize table type systems based on database semantics.As follows: {code}

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

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857711#comment-15857711 ] sunjincheng commented on FLINK-5658: Sure, [~Yuhong_kyo]. Feel free to take it. > Add event time OVER

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

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857468#comment-15857468 ] sunjincheng commented on FLINK-5658: HI, [~fhueske] Agree! It's make sense at current time. HI,

[jira] [Commented] (FLINK-5219) Add non-grouped session windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857196#comment-15857196 ] sunjincheng commented on FLINK-5219: Hi, [~fhueske][~twalthr] Very appreciate if you can help to

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

Title: Message Title sunjincheng assigned an issue to sunjincheng

[jira] [Comment Edited] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833214#comment-15833214 ] sunjincheng edited comment on FLINK-4683 at 1/22/17 1:12 AM: - Hi,[~fhueske] I

[jira] [Commented] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833214#comment-15833214 ] sunjincheng commented on FLINK-4683: Hi,[~fhueske] I picking up this issue of the reason, sliding-row

[jira] [Updated] (FLINK-5794) update the documentation about “UDF/UDTF" support have parameters constructor.

[ https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5794: --- Summary: update the documentation about “UDF/UDTF" support have parameters constructor. (was:

[jira] [Updated] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5804: --- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-5657) > Add

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

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869423#comment-15869423 ] sunjincheng commented on FLINK-5804: Hi,guys，I made a preliminary implementation of this JIRA. My

[jira] [Updated] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5804: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-5657 > Add [non-partitioned]

[jira] [Updated] (FLINK-5803) Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5803: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-5657 > Add [partitioned] processing

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869182#comment-15869182 ] sunjincheng commented on FLINK-5657: Yes, agree with you. I'll do that. > Add processing time OVER

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869473#comment-15869473 ] sunjincheng commented on FLINK-5792: HI, [~fhueske] Thanks for your attention to this JIRA. Thanks

[jira] [Commented] (FLINK-4557) Table API Stream Aggregations

[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869418#comment-15869418 ] sunjincheng commented on FLINK-4557: [~fhueske] Thanks for converter the "FLINK-5803" & "FLINK-5804"

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

[ https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869420#comment-15869420 ] sunjincheng commented on FLINK-5803: Hi,guys，I made a preliminary implementation of this JIRA. My

[jira] [Commented] (FLINK-4557) Table API Stream Aggregations

[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869275#comment-15869275 ] sunjincheng commented on FLINK-4557: Hi,guys，I made a preliminary implementation of this JIRA. My

[jira] [Commented] (FLINK-4557) Table API Stream Aggregations

[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869276#comment-15869276 ] sunjincheng commented on FLINK-4557: Hi,guys，I made a preliminary implementation of this JIRA. My

[jira] [Updated] (FLINK-5803) Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5803: --- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-5657) > Add [partitioned]

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869488#comment-15869488 ] sunjincheng commented on FLINK-5792: BYW， when I implement the issue, I had try to use `kryo`

[jira] [Commented] (FLINK-5794) update the documentation about “UDF/UDTF" support have parameters constructor.

[ https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876091#comment-15876091 ] sunjincheng commented on FLINK-5794: HI, [~twalthr] about update the documentation, Is there

[jira] [Comment Edited] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370 ] sunjincheng edited comment on FLINK-5656 at 2/22/17 3:08 AM: - HI, [~fhueske] @

[jira] [Comment Edited] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370 ] sunjincheng edited comment on FLINK-5656 at 2/22/17 3:09 AM: - HI, [~fhueske]

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

[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877370#comment-15877370 ] sunjincheng commented on FLINK-5656: HI, [~fhueske] [~jack], IMO,In the case of `BETWEEN UNBOUNDED

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

[ https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875351#comment-15875351 ] sunjincheng commented on FLINK-5803: Hi [~fhueske] In accordance with the design I made above, I have

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

[ https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880115#comment-15880115 ] sunjincheng commented on FLINK-5803: Hi,[~fhueske] You are right. I have opened the PR. > Add

[jira] [Created] (FLINK-5792) Improve “UDF/UDTF" to support with parameter constructor

sunjincheng created FLINK-5792: -- Summary: Improve “UDF/UDTF" to support with parameter constructor Key: FLINK-5792 URL: https://issues.apache.org/jira/browse/FLINK-5792 Project: Flink Issue

[jira] [Updated] (FLINK-5792) Improve “UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Description: Currently UDTF in the codegen phase using a nonparametric constructor to create the

[jira] [Updated] (FLINK-5792) Improve “UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Description: Improved “UDTF" to support with parameter constructor. (was: Improved “UDF/UDTF" to

[jira] [Updated] (FLINK-5792) Improve “UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Summary: Improve “UDTF" to support with parameter constructor (was: Improve “UDF/UDTF" to support

[jira] [Updated] (FLINK-5794) Improve “UDF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5794: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5792 > Improve “UDF" to support with

[jira] [Created] (FLINK-5795) Improve “UDTF" to support with parameter constructor

sunjincheng created FLINK-5795: -- Summary: Improve “UDTF" to support with parameter constructor Key: FLINK-5795 URL: https://issues.apache.org/jira/browse/FLINK-5795 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5792) Improve “UDF/UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Summary: Improve “UDF/UDTF" to support with parameter constructor (was: Improve “UDTF" to support

[jira] [Updated] (FLINK-5792) Improve “UDTF" to support with parameter constructor

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Description: Currently UDF/UDTF in the codegen phase using a nonparametric constructor to create the

[jira] [Created] (FLINK-5794) Improve “UDF" to support with parameter constructor

sunjincheng created FLINK-5794: -- Summary: Improve “UDF" to support with parameter constructor Key: FLINK-5794 URL: https://issues.apache.org/jira/browse/FLINK-5794 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862176#comment-15862176 ] sunjincheng commented on FLINK-5773: HI, [~colinbreame], We can look at xx repeated scala'doc. {code}

[jira] [Comment Edited] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862176#comment-15862176 ] sunjincheng edited comment on FLINK-5773 at 2/11/17 2:54 AM: - HI,

[jira] [Updated] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5792: --- Summary: Improve “UDF/UDTF" to support constructor with parameter. (was: Improve “UDF/UDTF" to

[jira] [Updated] (FLINK-5795) Improve “UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5795: --- Summary: Improve “UDTF" to support constructor with parameter. (was: Improve “UDTF" to support with

[jira] [Updated] (FLINK-5794) Improve “UDF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5794: --- Summary: Improve “UDF" to support constructor with parameter. (was: Improve “UDF" to support with

[jira] [Created] (FLINK-5803) Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

sunjincheng created FLINK-5803: -- Summary: Add [partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-5803 URL: https://issues.apache.org/jira/browse/FLINK-5803

[jira] [Created] (FLINK-5804) Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

sunjincheng created FLINK-5804: -- Summary: Add [non-partitioned] processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-5804 URL: https://issues.apache.org/jira/browse/FLINK-5804

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5657: --- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-4557) > Add processing time

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867362#comment-15867362 ] sunjincheng commented on FLINK-5657: Hi, [~fhueske] When I splitting FLINK-5657 into the partitioned

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863303#comment-15863303 ] sunjincheng commented on FLINK-5657: Hi,guys，I made a preliminary implementation of this JIRA. My

[jira] [Comment Edited] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855633#comment-15855633 ] sunjincheng edited comment on FLINK-5695 at 2/13/17 5:52 AM: - Thanks

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863303#comment-15863303 ] sunjincheng edited comment on FLINK-5657 at 2/13/17 7:59 AM: - Hi,guys，I made a

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15863303#comment-15863303 ] sunjincheng edited comment on FLINK-5657 at 2/13/17 8:32 AM: - Hi,guys，I made a

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-5657. -- Resolution: Won't Fix Move to FLINK-5803 & FLINK-5804. > Add processing time OVER RANGE BETWEEN

[jira] [Created] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters

sunjincheng created FLINK-5776: -- Summary: Improve XXMapRunner support create instance by carrying constructor parameters Key: FLINK-5776 URL: https://issues.apache.org/jira/browse/FLINK-5776 Project:

[jira] [Commented] (FLINK-5792) Improve “UDF/UDTF" to support constructor with parameter.

[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871584#comment-15871584 ] sunjincheng commented on FLINK-5792: HI,[~clarkyzl] Thanks for your attention to this JIRA. After

[jira] [Assigned] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4683: -- Assignee: sunjincheng > Add SlideRow row-windows for batch tables >

[jira] [Updated] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5386: --- Description: Similar to the SQL, window clause is defined "as" a symbol which is explicitly used in

[jira] [Updated] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5386: --- Description: Similar to the SQL, window clause is defined "as" a symbol which is explicitly used in

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826155#comment-15826155 ] sunjincheng commented on FLINK-5386: The first approach +1 > Refactoring Window Clause >

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15825546#comment-15825546 ] sunjincheng commented on FLINK-5386: Hi [~fhueske] [~shaoxuan] thanks for the reply . [~fhueske] You

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15825955#comment-15825955 ] sunjincheng commented on FLINK-5386: Hi [~fhueske] Thank you for the detailed explanation!!! If I

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828474#comment-15828474 ] sunjincheng commented on FLINK-5386: Hi [~fhueske] sorry for the delayed reply According to our

[jira] [Commented] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

[ https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891562#comment-15891562 ] sunjincheng commented on FLINK-5740: +1 very good point， any news for this issue? [~aljoscha] > Make

[jira] [Comment Edited] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891567#comment-15891567 ] sunjincheng edited comment on FLINK-5947 at 3/2/17 3:40 AM: [~Xiaojun Jin] In

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

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891908#comment-15891908 ] sunjincheng commented on FLINK-5804: [~fhueske] IMO. when the PR(#3438) had merged, we can share

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

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891912#comment-15891912 ] sunjincheng commented on FLINK-5804: Haha,[~fhueske] we post the message at same time. :) > Add

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

[ https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891892#comment-15891892 ] sunjincheng commented on FLINK-5804: After Allow ProcessFunction on non-keyed streams,The realization

[jira] [Comment Edited] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558 ] sunjincheng edited comment on FLINK-5947 at 3/2/17 3:23 AM: Hi, @Xiaojun Jin

[jira] [Commented] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558 ] sunjincheng commented on FLINK-5947: Hi, @Xiaojun Jin thanks for reporter this issue. Can you describe

[jira] [Commented] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891567#comment-15891567 ] sunjincheng commented on FLINK-5947: [~Xiaojun Jin] In your exception information, the error line

[jira] [Commented] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891602#comment-15891602 ] sunjincheng commented on FLINK-5947: I think the reason for this problem may be for merge state.when

[jira] [Commented] (FLINK-5947) NullPointerException in ContinuousProcessingTimeTrigger.clear()

[ https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891654#comment-15891654 ] sunjincheng commented on FLINK-5947: [~Xiaojun Jin] Congratulations you solved this bug,cheers !!!

[jira] [Updated] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-4781: --- Description: (was: Will update details later) > Add User Defined Function(UDF) API for Table API

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 1:24 AM: -- User can

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 1:13 AM: -- User can

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 1:15 AM: -- User can

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 1:40 AM: -- see

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 2:11 AM: -- User can

[jira] [Commented] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng commented on FLINK-4781: User can define own functions to apply on fields. Build-in UDFs

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 1:51 AM: -- **This issue

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 2:23 AM: -- User can

[jira] [Comment Edited] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560958#comment-15560958 ] sunjincheng edited comment on FLINK-4781 at 10/10/16 2:23 AM: -- User can

[jira] [Commented] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564217#comment-15564217 ] sunjincheng commented on FLINK-4781: Thanks for taking time to check this, Fabian. when we try to

[jira] [Assigned] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4937: -- Assignee: sunjincheng > Add incremental group window aggregation for streaming Table API >

[jira] [Comment Edited] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662466#comment-15662466 ] sunjincheng edited comment on FLINK-4937 at 11/14/16 9:35 AM: -- I had thought

[jira] [Assigned] (FLINK-4680) Add SlidingRow row-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4680: -- Assignee: sunjincheng > Add SlidingRow row-windows for streaming tables >

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15668327#comment-15668327 ] sunjincheng commented on FLINK-4937: done > Add incremental group window aggregation for streaming

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15668332#comment-15668332 ] sunjincheng commented on FLINK-4937: done > Add incremental group window aggregation for streaming

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15661780#comment-15661780 ] sunjincheng commented on FLINK-4937: check all aggregates are support Partial aggregate => check

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662466#comment-15662466 ] sunjincheng commented on FLINK-4937: I had thought about calling transformToAggregateFunctions

[jira] [Assigned] (FLINK-4693) Add session group-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4693: -- Assignee: sunjincheng > Add session group-windows for batch tables >

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15668331#comment-15668331 ] sunjincheng commented on FLINK-4937: done > Add incremental group window aggregation for streaming

  1   2   3   4   5   6   7   8   9   10   >