[jira] [Commented] (FLINK-3153) Support all comparisons for String type

2016-06-14 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329356#comment-15329356 ] Jark Wu commented on FLINK-3153: It seems that String Comparison has been supported ? > Support all

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

2016-06-14 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329610#comment-15329610 ] Jark Wu commented on FLINK-3580: I would happily try to work on this issue if nobody else is already

[jira] [Commented] (FLINK-4070) Support literals on left side of binary expressions

2016-06-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331429#comment-15331429 ] Jark Wu commented on FLINK-4070: This is a useful feature. I can try to work on this if nobody else is

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

2016-06-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331446#comment-15331446 ] Jark Wu commented on FLINK-4068: I tested some cases and find that tableAPI will automatically evaluate

[jira] [Commented] (FLINK-4070) Support literals on left side of binary expressions

2016-06-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331571#comment-15331571 ] Jark Wu commented on FLINK-4070: The Table API does not support literals on left side of expressions like

[jira] [Created] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?'

2016-06-22 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4109: -- Summary: Change the name of ternary condition operator 'eval' to '?' Key: FLINK-4109 URL: https://issues.apache.org/jira/browse/FLINK-4109 Project: Flink Issue

[jira] [Created] (FLINK-4111) Flink Table & SQL doesn't work in very simple example

2016-06-23 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4111: -- Summary: Flink Table & SQL doesn't work in very simple example Key: FLINK-4111 URL: https://issues.apache.org/jira/browse/FLINK-4111 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-3942) Add support for INTERSECT

2016-06-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-3942: -- Assignee: Jark Wu > Add support for INTERSECT > - > > Key:

[jira] [Commented] (FLINK-3942) Add support for INTERSECT

2016-06-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15334042#comment-15334042 ] Jark Wu commented on FLINK-3942: I can try to work on it if nobody else is already work on it. > Add

[jira] [Commented] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?'

2016-06-23 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347564#comment-15347564 ] Jark Wu commented on FLINK-4109: [~vkalavri] [~chengxiang li] [~rmetzger] what do you think ? > Change

[jira] [Assigned] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

2016-06-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4068: -- Assignee: Jark Wu > Move constant computations out of code-generated `flatMap` functions. >

[jira] [Updated] (FLINK-3577) Display anchor links when hovering over headers.

2016-03-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-3577: --- Description: This is useful to share the document url if display anchor links when hovering over headers.

[jira] [Created] (FLINK-3577) Display anchor links when hovering over headers.

2016-03-04 Thread Jark Wu (JIRA)
Jark Wu created FLINK-3577: -- Summary: Display anchor links when hovering over headers. Key: FLINK-3577 URL: https://issues.apache.org/jira/browse/FLINK-3577 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4203) Improve Table API documentation

2016-07-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389674#comment-15389674 ] Jark Wu commented on FLINK-4203: We should also improve [Table API Operators

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-07-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397004#comment-15397004 ] Jark Wu commented on FLINK-4271: The CoGroupStream will construct the following graph. {code} source ->

[jira] [Comment Edited] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-07-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397004#comment-15397004 ] Jark Wu edited comment on FLINK-4271 at 7/28/16 6:17 AM: - The CoGroupStream will

[jira] [Assigned] (FLINK-4270) 'as' in front of join does not work

2016-07-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4270: -- Assignee: Jark Wu > 'as' in front of join does not work > --- > >

[jira] [Assigned] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-07-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4271: -- Assignee: Jark Wu > There is no way to set parallelism of operators produced by CoGroupedStreams >

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-07-28 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15397187#comment-15397187 ] Jark Wu commented on FLINK-4271: Yea, SingleOutputStreamOperator can set parallelism, uid, name and so on.

[jira] [Commented] (FLINK-4250) Cannot select other than first column from Table

2016-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388780#comment-15388780 ] Jark Wu commented on FLINK-4250: I think the second exception is similar to the first, because "VALUE" is

[jira] [Comment Edited] (FLINK-4250) Cannot select other than first column from Table

2016-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388780#comment-15388780 ] Jark Wu edited comment on FLINK-4250 at 7/22/16 2:55 AM: - I think the second

[jira] [Comment Edited] (FLINK-4252) Table program cannot be compiled

2016-07-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389003#comment-15389003 ] Jark Wu edited comment on FLINK-4252 at 7/22/16 6:35 AM: - I debug it and find that

[jira] [Commented] (FLINK-4252) Table program cannot be compiled

2016-07-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389003#comment-15389003 ] Jark Wu commented on FLINK-4252: I debug it and find that we use {Class.getCanonicalName} to get the

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

2016-07-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15396844#comment-15396844 ] Jark Wu commented on FLINK-4263: Hi [~gallenvara_bg], thanks for your advice. But I think override

[jira] [Commented] (FLINK-4262) Consider null handling during sorting

2016-08-03 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405384#comment-15405384 ] Jark Wu commented on FLINK-4262: There is currently an open PR (https://github.com/apache/flink/pull/2282)

[jira] [Commented] (FLINK-4359) Add INTERVAL type

2016-08-10 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15415204#comment-15415204 ] Jark Wu commented on FLINK-4359: Do we have any ideas how to implement StreamSQL window? Because currently

[jira] [Commented] (FLINK-4359) Add INTERVAL type

2016-08-11 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417187#comment-15417187 ] Jark Wu commented on FLINK-4359: Okay, I see. I'm interested in this, and I'm glad if I can help

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

2016-08-11 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417208#comment-15417208 ] Jark Wu commented on FLINK-4370: Yes. We can put this files into tools folder (or other) as well as the

[jira] [Assigned] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

2016-08-10 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4366: -- Assignee: Jark Wu > Enforce parallelism=1 For AllWindowedStream >

[jira] [Assigned] (FLINK-4385) Union on Timestamp fields does not work

2016-08-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4385: -- Assignee: Jark Wu > Union on Timestamp fields does not work > ---

[jira] [Assigned] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

2016-08-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4281: -- Assignee: Jark Wu > Wrap all Calcite Exceptions in Flink Exceptions >

[jira] [Commented] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method

2016-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15387824#comment-15387824 ] Jark Wu commented on FLINK-4240: It's not a bug I think as we cannot select a column not in Group By. In

[jira] [Commented] (FLINK-4244) Field names for union operator do not have to be equal

2016-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15387851#comment-15387851 ] Jark Wu commented on FLINK-4244: Yes, we just merged [FLINK-2985] , but not update the document. I will

[jira] [Assigned] (FLINK-4244) Field names for union operator do not have to be equal

2016-07-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4244: -- Assignee: Jark Wu > Field names for union operator do not have to be equal >

[jira] [Assigned] (FLINK-4180) Create a batch SQL example

2016-07-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4180: -- Assignee: Jark Wu > Create a batch SQL example > -- > > Key:

[jira] [Assigned] (FLINK-4181) Add a basic streaming Table API example

2016-07-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4181: -- Assignee: Jark Wu > Add a basic streaming Table API example > ---

[jira] [Commented] (FLINK-4180) Create a batch SQL example

2016-07-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367808#comment-15367808 ] Jark Wu commented on FLINK-4180: I'll work on this. > Create a batch SQL example >

[jira] [Commented] (FLINK-4181) Add a basic streaming Table API example

2016-07-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367810#comment-15367810 ] Jark Wu commented on FLINK-4181: I'll work on this. > Add a basic streaming Table API example >

[jira] [Commented] (FLINK-4252) Table program cannot be compiled

2016-07-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389341#comment-15389341 ] Jark Wu commented on FLINK-4252: Do we have the JIRA? Or just modify this JIRA to track it? > Table

[jira] [Commented] (FLINK-4130) CallGenerator could generate illegal code when taking no operands

2016-06-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356537#comment-15356537 ] Jark Wu commented on FLINK-4130: It seems that cody has pulled a request for this issue:

[jira] [Commented] (FLINK-3792) RowTypeInfo equality should not depend on field names

2016-06-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356552#comment-15356552 ] Jark Wu commented on FLINK-3792: Do we need this before 1.1.0 release ? If yes, I can take up this issue.

[jira] [Assigned] (FLINK-5714) Use a builder pattern for creating CsvTableSource

2017-02-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-5714: -- Assignee: Jark Wu > Use a builder pattern for creating CsvTableSource >

[jira] [Commented] (FLINK-5714) Use a builder pattern for creating CsvTableSource

2017-02-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853887#comment-15853887 ] Jark Wu commented on FLINK-5714: I like this idea! I will work on this. > Use a builder pattern for

[jira] [Updated] (FLINK-5725) Support JOIN between two streams in the SQL API

2017-02-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-5725: --- Component/s: Table API & SQL > Support JOIN between two streams in the SQL API >

[jira] [Commented] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833003#comment-15833003 ] Jark Wu commented on FLINK-5592: Hi [~tonycox], I think it maybe a problem in your code. The first level

[jira] [Commented] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-23 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834743#comment-15834743 ] Jark Wu commented on FLINK-5592: In Table API, please use {code} // Java Table API

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

2017-01-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-5656: -- Assignee: Jark Wu > Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL >

[jira] [Commented] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

2017-01-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15843915#comment-15843915 ] Jark Wu commented on FLINK-5678: Thank you for reporting this, I will look into this. > User-defined

[jira] [Assigned] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

2017-01-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-5678: -- Assignee: Jark Wu > User-defined TableFunctions do not support all types of parameters >

[jira] [Commented] (FLINK-5589) Tumbling group windows on batch tables do not consider object reuse

2017-01-20 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831801#comment-15831801 ] Jark Wu commented on FLINK-5589: In {{DataSetTumbleTimeWindowAggReduceGroupFunction}} and

[jira] (FLINK-5662) Alias in front of output fails

2017-01-29 Thread Jark Wu (JIRA)
Title: Message Title Jark Wu commented on FLINK-5662

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

2017-02-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869404#comment-15869404 ] Jark Wu commented on FLINK-5792: Hi [~fhueske], [~sunjincheng121] has create a PR for this issue:

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

2017-02-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869029#comment-15869029 ] Jark Wu commented on FLINK-5792: +1 The serialization way will be more flexible. > Improve “UDF/UDTF" to

[jira] [Closed] (FLINK-5795) Improve UDF to support constructor with parameter

2017-02-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-5795. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0: 45e01cf2321dda58f572d8b9dbe64947c6725ad1 >

[jira] [Updated] (FLINK-5795) Improve UDF to support constructor with parameter

2017-02-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-5795: --- Summary: Improve UDF to support constructor with parameter (was: Improve “UDTF" to support constructor with

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

2017-02-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877380#comment-15877380 ] Jark Wu edited comment on FLINK-5656 at 2/22/17 3:17 AM: - [~sunjincheng121] I'm

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

2017-02-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877380#comment-15877380 ] Jark Wu commented on FLINK-5656: [~sunjingcheng] I'm fine with this as I haven't start this issue. If you

[jira] [Commented] (FLINK-5795) Improve UDF to support constructor with parameter

2017-02-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15877288#comment-15877288 ] Jark Wu commented on FLINK-5795: Fixed in 1.3.0: 45e01cf2321dda58f572d8b9dbe64947c6725ad1 > Improve UDF

[jira] [Commented] (FLINK-5780) Extend ConfigOption with descriptions

2017-02-20 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15874674#comment-15874674 ] Jark Wu commented on FLINK-5780: Hi [~uce], why do we need short and long description ? Does a

[jira] [Comment Edited] (FLINK-5780) Extend ConfigOption with descriptions

2017-02-20 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15874674#comment-15874674 ] Jark Wu edited comment on FLINK-5780 at 2/20/17 3:15 PM: - Hi [~uce], why do we

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-02-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871154#comment-15871154 ] Jark Wu commented on FLINK-5414: Hi [~wheat9], sorry for the delay. Actually, I had some problems when

[jira] [Commented] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-18 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15873429#comment-15873429 ] Jark Wu commented on FLINK-5826: The generated code is pure Java, we try to avoid add Scala relative code

[jira] [Comment Edited] (FLINK-5554) Add sql operator to table api for getting columns from HBase

2017-01-18 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829146#comment-15829146 ] Jark Wu edited comment on FLINK-5554 at 1/19/17 1:56 AM: - Flink has already

[jira] [Commented] (FLINK-5554) Add sql operator to table api for getting columns from HBase

2017-01-18 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829146#comment-15829146 ] Jark Wu commented on FLINK-5554: Flink has already supported composite types , and can access like

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823670#comment-15823670 ] Jark Wu commented on FLINK-5500: Hi [~Yuhong_kyo] , sorry, I can't reproduce your errors in my local

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823805#comment-15823805 ] Jark Wu commented on FLINK-5500: Yes. I have noticed the problems when upgrading Calcite. I will fix the

[jira] [Commented] (FLINK-5548) Move checks for DataStreamRel validity into constructor

2017-01-18 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828108#comment-15828108 ] Jark Wu commented on FLINK-5548: I think you mean {{DataSetRel}}, right? I only find {{DataSetJoin}} and

[jira] [Commented] (FLINK-4288) Make it possible to unregister tables

2016-08-03 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15407083#comment-15407083 ] Jark Wu commented on FLINK-4288: Because {{SchemaPlus}} has no {{remove}} function, we can't unregister

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

2017-03-01 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-5794. -- Resolution: Fixed Fix Version/s: 1.3.0 fixed in bf4eed144428179a2390eb67642f8ac755896fc2 > update the

[jira] [Created] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-08-24 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4469: -- Summary: Add support for user defined table function in Table API & SQL Key: FLINK-4469 URL: https://issues.apache.org/jira/browse/FLINK-4469 Project: Flink Issue

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-05 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15464832#comment-15464832 ] Jark Wu commented on FLINK-4579: +1 for adding rocksdb to the standard distribution lib. So we only need

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469402#comment-15469402 ] Jark Wu commented on FLINK-4565: I think what is confusing [~chobeat] is what's "IN" 's counterpart in

[jira] [Updated] (FLINK-4546) Remove STREAM keyword in Stream SQL

2016-09-01 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4546: --- Summary: Remove STREAM keyword in Stream SQL (was: Remove STREAM keyword and use batch sql parser for

[jira] [Updated] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs

2016-08-31 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4546: --- Issue Type: New Feature (was: Bug) > Remove STREAM keyword and use batch sql parser for stream jobs >

[jira] [Created] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs

2016-08-31 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4546: -- Summary: Remove STREAM keyword and use batch sql parser for stream jobs Key: FLINK-4546 URL: https://issues.apache.org/jira/browse/FLINK-4546 Project: Flink Issue

[jira] [Commented] (FLINK-4598) Support NULLIF in Table API

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15473200#comment-15473200 ] Jark Wu commented on FLINK-4598: You are right. We should evaluate what functions should be supported in

[jira] [Closed] (FLINK-4597) Improve Scalar Function section in Table API documentation

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-4597. -- Resolution: Duplicate > Improve Scalar Function section in Table API documentation >

[jira] [Created] (FLINK-4598) Support NULLIF in Table API

2016-09-08 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4598: -- Summary: Support NULLIF in Table API Key: FLINK-4598 URL: https://issues.apache.org/jira/browse/FLINK-4598 Project: Flink Issue Type: New Feature Components:

[jira] [Commented] (FLINK-4597) Improve Scalar Function section in Table API documentation

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15473160#comment-15473160 ] Jark Wu commented on FLINK-4597: I have a look at Calcite documentation [1] , this syntax is concise and

[jira] [Created] (FLINK-4597) Improve Scalar Function section in Table API documentation

2016-09-08 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4597: -- Summary: Improve Scalar Function section in Table API documentation Key: FLINK-4597 URL: https://issues.apache.org/jira/browse/FLINK-4597 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4579: -- Assignee: Jark Wu > Add StateBackendFactory for RocksDB Backend >

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-07 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472401#comment-15472401 ] Jark Wu commented on FLINK-4591: It seems that {{GROUP BY *}} is not allowed in SQL. Maybe we can throw a

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-08-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448024#comment-15448024 ] Jark Wu commented on FLINK-4469: Agree with that. Using a collector will be more user-friendly and can

[jira] [Comment Edited] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-08-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448024#comment-15448024 ] Jark Wu edited comment on FLINK-4469 at 8/30/16 4:51 AM: - Agree with that. Using a

[jira] [Comment Edited] (FLINK-4591) Select star does not work with grouping

2016-09-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476177#comment-15476177 ] Jark Wu edited comment on FLINK-4591 at 9/9/16 7:15 AM: Is {{.groupBy( '*

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476177#comment-15476177 ] Jark Wu commented on FLINK-4591: Is {{.groupBy( '* ).select( '* , 'a.count )}} a strong case to support

[jira] [Assigned] (FLINK-4591) Select star does not work with grouping

2016-09-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4591: -- Assignee: Jark Wu > Select star does not work with grouping > ---

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476058#comment-15476058 ] Jark Wu commented on FLINK-4591: Make sense. I will look into it. > Select star does not work with

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476147#comment-15476147 ] Jark Wu commented on FLINK-4591: Make sense... They are equal, we should encourage to use {{.distinct()}}

[jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table

2016-09-30 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535169#comment-15535169 ] Jark Wu commented on FLINK-4704: +1 Table API is still in beta, so it's not too late to do this now. >

[jira] [Commented] (FLINK-4762) Use plural in time interval units

2016-10-09 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15559531#comment-15559531 ] Jark Wu commented on FLINK-4762: How about let {{minute}} and {{minutes}} both exist like Scala's

[jira] [Closed] (FLINK-4598) Support NULLIF in Table API

2016-09-17 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-4598. -- Resolution: Won't Fix > Support NULLIF in Table API > > > Key:

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

2016-09-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515209#comment-15515209 ] Jark Wu commented on FLINK-4263: I have no idea how to code generate the values input format. So feel free

[jira] [Commented] (FLINK-4605) Add an expression that returns the return type of an expression

2016-09-23 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515702#comment-15515702 ] Jark Wu commented on FLINK-4605: Hi [~twalthr], could you explain this issue a little more detail ? What

[jira] [Commented] (FLINK-4621) Improve decimal literals of SQL API

2016-09-23 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515830#comment-15515830 ] Jark Wu commented on FLINK-4621: I think the problem is how to convert BigDecimal into relative java

[jira] [Assigned] (FLINK-4662) Bump Calcite version up to 1.9

2016-09-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4662: -- Assignee: Jark Wu > Bump Calcite version up to 1.9 > -- > >

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

2016-09-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513401#comment-15513401 ] Jark Wu commented on FLINK-4263: It seems that the data types in {{VALUES}} are always RexLiteral which

[jira] [Created] (FLINK-4420) Introduce star(*) to select all of the columns in the table

2016-08-17 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4420: -- Summary: Introduce star(*) to select all of the columns in the table Key: FLINK-4420 URL: https://issues.apache.org/jira/browse/FLINK-4420 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

2016-08-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439292#comment-15439292 ] Jark Wu commented on FLINK-4510: Hi [~uce] , I would like to contribute this issue. > Always create

[jira] [Assigned] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

2016-08-23 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4435: -- Assignee: Jark Wu > Replace Guava's VisibleForTesting annotation with Flink's annotation >

  1   2   3   4   5   6   7   8   9   10   >