[jira] [Updated] (FLINK-6810) Add Some built-in Scalar Function supported

2018-08-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-6810: --- Description: In this JIRA, we will create some sub-tasks for adding specific scalar functions such

[jira] [Updated] (FLINK-6810) Add Some built-in Scalar Function supported

2018-08-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-6810: --- Attachment: how to add a scalar function.png > Add Some built-in Scalar Function supported >

[jira] [Updated] (FLINK-6810) Add Some built-in Scalar Function supported

2018-08-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-6810: --- Description: In this JIRA, we will create some sub-tasks for adding specific scalar functions such

[jira] [Resolved] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-9977. Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0

[jira] [Created] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException

2018-08-09 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10108: --- Summary: DATE_FORMAT function in sql test throws a NumberFormatException Key: FLINK-10108 URL: https://issues.apache.org/jira/browse/FLINK-10108 Project: Flink

[jira] [Closed] (FLINK-10103) Refine built-in-functions docs for SQL

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui closed FLINK-10103. --- Resolution: Duplicate > Refine built-in-functions docs for SQL >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Description: There exist some syntax errors or inconsistencies in documents and Scala docs of the

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Description: There exist some syntax errors or inconsistencies in documents and Scala docs of the

[jira] [Commented] (FLINK-10103) Refine built-in-functions docs for SQL

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16573350#comment-16573350 ] Xingcan Cui commented on FLINK-10103: - Yes, you are right. Thanks for reminding me of that,

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-07 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571409#comment-16571409 ] Xingcan Cui commented on FLINK-9977: Thanks for the feedback [~fhueske]. Totally agree! I'll

[jira] [Resolved] (FLINK-9928) Add LOG2 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-9928. Resolution: Fixed Fixed in 1.7.0: 93b93aa0857c75a6021d3de8910191d36a1c1c18 > Add LOG2 function

[jira] [Updated] (FLINK-9928) Add LOG2 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9928: --- Fix Version/s: 1.7.0 > Add LOG2 function for table/sql API > --- > >

[jira] [Resolved] (FLINK-9916) Add FROM_BASE64 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-9916. Resolution: Fixed Fixed in 1.7.0: 724857c3636e923037ea02131b05e03a8c7ca520 > Add FROM_BASE64

[jira] [Updated] (FLINK-9916) Add FROM_BASE64 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9916: --- Fix Version/s: 1.7.0 > Add FROM_BASE64 function for table/sql API >

[jira] [Resolved] (FLINK-9915) Add TO_BASE64 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-9915. Resolution: Fixed > Add TO_BASE64 function for table/sql API >

[jira] [Commented] (FLINK-9915) Add TO_BASE64 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568493#comment-16568493 ] Xingcan Cui commented on FLINK-9915: Fixed in 1.7.0: e4c9d97a69555072c4940007754cd8b12a339d82 > Add

[jira] [Updated] (FLINK-9915) Add TO_BASE64 function for table/sql API

2018-08-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9915: --- Fix Version/s: 1.7.0 > Add TO_BASE64 function for table/sql API >

[jira] [Created] (FLINK-10049) Unify the processing logic for NULL arguments in SQL built-in functions

2018-08-03 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10049: --- Summary: Unify the processing logic for NULL arguments in SQL built-in functions Key: FLINK-10049 URL: https://issues.apache.org/jira/browse/FLINK-10049 Project: Flink

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567813#comment-16567813 ] Xingcan Cui commented on FLINK-9977: Hi [~twalthr] and [~fhueske], I've uploaded some screenshots of

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: Scala.jpg > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: Java.jpg > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: SQL.jpg > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: SQL.jpg) > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: Java.jpg) > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: Scala.jpg) > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: SQL.jpg Scala.jpg Java.jpg > Refine the docs for

[jira] [Commented] (FLINK-10014) Fix the decimal literal parameter problem for arithmetic functions in Table

2018-08-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565027#comment-16565027 ] Xingcan Cui commented on FLINK-10014: - Copied from another JIRA. [~xccui]: Personally, I prefer the

[jira] [Created] (FLINK-10014) Fix the decimal literal parameter problem for arithmetic functions in Table

2018-08-01 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10014: --- Summary: Fix the decimal literal parameter problem for arithmetic functions in Table Key: FLINK-10014 URL: https://issues.apache.org/jira/browse/FLINK-10014 Project:

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-01 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564978#comment-16564978 ] Xingcan Cui commented on FLINK-9977: It seems I've found another problem of the "Arithmetic

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10008: Description: Currently, the {{LOG}} function in SQL/Table API restricts the base to be greater

[jira] [Created] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

2018-07-31 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10009: --- Summary: Fix the casting problem for function TIMESTAMPADD in Table Key: FLINK-10009 URL: https://issues.apache.org/jira/browse/FLINK-10009 Project: Flink

[jira] [Created] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

2018-07-31 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10008: --- Summary: Improve the LOG function in Table to support bases less than 1 Key: FLINK-10008 URL: https://issues.apache.org/jira/browse/FLINK-10008 Project: Flink

[jira] [Comment Edited] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-07-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16562210#comment-16562210 ] Xingcan Cui edited comment on FLINK-9977 at 7/31/18 11:26 AM: -- Hi

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-07-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563492#comment-16563492 ] Xingcan Cui commented on FLINK-9977: Thanks for the comments [~twalthr]. I will finish the remaining

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-07-30 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16562210#comment-16562210 ] Xingcan Cui commented on FLINK-9977: Hi [~twalthr], I've refined the documents for SQL built-in

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-07-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559423#comment-16559423 ] Xingcan Cui commented on FLINK-9977: [~twalthr], I also think of that since we've already got a huge

[jira] [Created] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-07-26 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-9977: -- Summary: Refine the docs for Table/SQL built-in functions Key: FLINK-9977 URL: https://issues.apache.org/jira/browse/FLINK-9977 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-9790) Add documentation for UDF in SQL Client

2018-07-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-9790: -- Assignee: Xingcan Cui > Add documentation for UDF in SQL Client >

[jira] [Updated] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-25 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8863: --- Description: This issue is a subtask of part two "Full Embedded SQL Client" of the implementation

[jira] [Updated] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-25 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8863: --- Description: This issue is a subtask of part two "Full Embedded SQL Client" of the implementation

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-05-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484226#comment-16484226 ] Xingcan Cui commented on FLINK-9219: Yes, I agree that we should expose a Flink-specific type for

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-05-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484117#comment-16484117 ] Xingcan Cui commented on FLINK-9219: Hi [~twalthr], I cannot think out why the static method

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481693#comment-16481693 ] Xingcan Cui commented on FLINK-8863: Hi [~twalthr], I got two questions during the implementation. 1.

[jira] [Comment Edited] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481693#comment-16481693 ] Xingcan Cui edited comment on FLINK-8863 at 5/19/18 5:04 PM: - Hi [~twalthr], I

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-17 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16479056#comment-16479056 ] Xingcan Cui commented on FLINK-8863: Sorry for the delay [~twalthr]. I'll try to finish it at this

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-05-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476720#comment-16476720 ] Xingcan Cui commented on FLINK-9219: Thanks for the feedback [~twalthr]! The majority of your

[jira] [Closed] (FLINK-8316) The CsvTableSink and the CsvInputFormat are not in sync

2018-05-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui closed FLINK-8316. -- Resolution: Won't Do > The CsvTableSink and the CsvInputFormat are not in sync >

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

2018-05-11 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471660#comment-16471660 ] Xingcan Cui commented on FLINK-9289: I see. Thanks for the explanation, [~fhueske]. Will fix this as

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

2018-05-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470460#comment-16470460 ] Xingcan Cui commented on FLINK-9289: Hi [~fhueske], I checked the sub-classes of

[jira] [Assigned] (FLINK-9289) Parallelism of generated operators should have max parallism of input

2018-05-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-9289: -- Assignee: Xingcan Cui > Parallelism of generated operators should have max parallism of input

[jira] [Comment Edited] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456223#comment-16456223 ] Xingcan Cui edited comment on FLINK-9219 at 4/27/18 10:49 AM: -- Hi [~twalthr] 

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16456223#comment-16456223 ] Xingcan Cui commented on FLINK-9219: Hi [~twalthr]] and [~fhueske], I‘ve tried to implement three

[jira] [Comment Edited] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450266#comment-16450266 ] Xingcan Cui edited comment on FLINK-9219 at 4/24/18 5:43 PM: - [~twalthr], it's

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450266#comment-16450266 ] Xingcan Cui commented on FLINK-9219: [~twalthr], it's an ESRI type wrapped by Calcite. > Add support

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450019#comment-16450019 ] Xingcan Cui commented on FLINK-9219: That's fine. Thanks for your comment, [~fhueske]. > Add support

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449889#comment-16449889 ] Xingcan Cui commented on FLINK-9219: Hi [~twalthr], I was working on this issue. Since the {{Geom}}

[jira] [Assigned] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2018-04-20 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-9219: -- Assignee: Xingcan Cui > Add support for OpenGIS features in Table & SQL API >

[jira] [Commented] (FLINK-8880) Validate configurations for SQL Client

2018-03-30 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420256#comment-16420256 ] Xingcan Cui commented on FLINK-8880: Hi [~walterddr], sorry for the late replay. I've been quite busy

[jira] [Commented] (FLINK-9021) org.apache.flink.table.codegen.CodeGenException: Unsupported call: TUMBLE

2018-03-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404738#comment-16404738 ] Xingcan Cui commented on FLINK-9021: Hi [~yizhou_liujiarui], yes, the distinct aggregate function has

[jira] [Commented] (FLINK-9021) org.apache.flink.table.codegen.CodeGenException: Unsupported call: TUMBLE

2018-03-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404691#comment-16404691 ] Xingcan Cui commented on FLINK-9021: Hi [~yizhou_liujiarui], the attribute in a tumble clause (the

[jira] [Commented] (FLINK-8952) Support setting the parallelism of individual operators of a query

2018-03-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400350#comment-16400350 ] Xingcan Cui commented on FLINK-8952: Hi [~fhueske], thanks for this ticket and I suppose it's related

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-03-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393990#comment-16393990 ] Xingcan Cui commented on FLINK-8863: Yes, I agree that there may be conflicts among different JARs

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-03-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393957#comment-16393957 ] Xingcan Cui commented on FLINK-8863: Hi [~walterddr], commonly, all the required classes are supposed

[jira] [Updated] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

2018-03-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8897: --- Description: As raised in [this

[jira] [Created] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

2018-03-08 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8897: -- Summary: Rowtime materialization causes "mismatched type" AssertionError Key: FLINK-8897 URL: https://issues.apache.org/jira/browse/FLINK-8897 Project: Flink

[jira] [Assigned] (FLINK-8863) Add user-defined function support in SQL Client

2018-03-07 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8863: -- Assignee: Xingcan Cui > Add user-defined function support in SQL Client >

[jira] [Updated] (FLINK-8880) Validate configurations for SQL Client

2018-03-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8880: --- Component/s: Table API & SQL > Validate configurations for SQL Client >

[jira] [Created] (FLINK-8880) Validate configurations for SQL Client

2018-03-06 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8880: -- Summary: Validate configurations for SQL Client Key: FLINK-8880 URL: https://issues.apache.org/jira/browse/FLINK-8880 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-8861) Add support for batch queries in SQL Client

2018-03-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8861: -- Assignee: Xingcan Cui > Add support for batch queries in SQL Client >

[jira] [Commented] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

2018-03-04 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385476#comment-16385476 ] Xingcan Cui commented on FLINK-8855: Hi [~fhueske], I'd like to look into this. Could you share more

[jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-02-28 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380563#comment-16380563 ] Xingcan Cui commented on FLINK-8537: Hi [~twalthr] , I added an {{Avro}} descriptor in the

[jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-02-22 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372948#comment-16372948 ] Xingcan Cui commented on FLINK-8537: Hi [~twalthr], I've implemented this Avro table source factory.

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16366956#comment-16366956 ] Xingcan Cui commented on FLINK-8538: Sorry for the late PR [~twalthr]. I was just here waiting for the

[jira] [Assigned] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-02-16 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8537: -- Assignee: Xingcan Cui > Add a Kafka table source factory with Avro format support >

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363802#comment-16363802 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr], I think Friday will be fine. Thought looks

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363700#comment-16363700 ] Xingcan Cui commented on FLINK-8538: BTW, it may not be a good idea to implement them in Java since

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360725#comment-16360725 ] Xingcan Cui commented on FLINK-8538: Thanks for the comments, [~twalthr] and [~fhueske]. Yes, the

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360559#comment-16360559 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr] and [~fhueske], I committed a WIP branch to my

[jira] [Updated] (FLINK-8630) To support JSON schema to TypeInformation conversion

2018-02-10 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8630: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-8558 > To support JSON schema to

[jira] [Created] (FLINK-8630) To support JSON schema to TypeInformation conversion

2018-02-10 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8630: -- Summary: To support JSON schema to TypeInformation conversion Key: FLINK-8630 URL: https://issues.apache.org/jira/browse/FLINK-8630 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358494#comment-16358494 ] Xingcan Cui commented on FLINK-8538: Thanks for the comments [~twalthr] and [~fhueske]. Actually, I've

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358286#comment-16358286 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr], I think we need a converter to transform a

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-07 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355511#comment-16355511 ] Xingcan Cui commented on FLINK-8538: If I understood correctly, maybe we should create a new module

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-07 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355468#comment-16355468 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr] and [~fhueske], it's still a question about the

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353508#comment-16353508 ] Xingcan Cui commented on FLINK-8538: Thanks for your reply, [~fhueske]. I'll think it over. > Add a

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352634#comment-16352634 ] Xingcan Cui commented on FLINK-8538: Thanks for the explanation [~twalthr]. I've glanced over the PR

[jira] [Resolved] (FLINK-7797) Add support for windowed outer joins for streaming tables

2018-02-05 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-7797. Resolution: Fixed Fix Version/s: 1.5.0 > Add support for windowed outer joins for streaming

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-03 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351405#comment-16351405 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr], thanks for opening this. I just got one little

[jira] [Assigned] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-01-31 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8538: -- Assignee: Xingcan Cui > Add a Kafka table source factory with JSON format support >

[jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden

2018-01-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337561#comment-16337561 ] Xingcan Cui commented on FLINK-8407: Yes, there's no {{setParallelism()}} method in

[jira] [Updated] (FLINK-8457) Documentation for Building from Source is broken

2018-01-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8457: --- Description: The documentation for how to build Flink from source is broken for all released

[jira] [Updated] (FLINK-8457) Documentation for Building from Source is broken

2018-01-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8457: --- Environment: (was: The documentation for how to build Flink from source is broken for all

[jira] [Assigned] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden

2018-01-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8407: -- Assignee: Xingcan Cui > Setting the parallelism after a partitioning operation should be

[jira] [Created] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden

2018-01-10 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8407: -- Summary: Setting the parallelism after a partitioning operation should be forbidden Key: FLINK-8407 URL: https://issues.apache.org/jira/browse/FLINK-8407 Project: Flink

[jira] [Created] (FLINK-8316) The CsvTableSink and the CsvInputFormat are not in sync

2017-12-23 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8316: -- Summary: The CsvTableSink and the CsvInputFormat are not in sync Key: FLINK-8316 URL: https://issues.apache.org/jira/browse/FLINK-8316 Project: Flink Issue

[jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism()

2017-12-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-8257: --- Description: The {{setParallelism()}} method exist in many components from different levels. Some of

[jira] [Assigned] (FLINK-8257) Unify the value checks for setParallelism()

2017-12-19 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8257: -- Assignee: Xingcan Cui > Unify the value checks for setParallelism() >

[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295193#comment-16295193 ] Xingcan Cui commented on FLINK-8282: Hi [~twalthr], thanks for this ticket. I just wonder whether we

[jira] [Assigned] (FLINK-8278) Scala examples in Metric documentation do not compile

2017-12-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8278: -- Assignee: Xingcan Cui > Scala examples in Metric documentation do not compile >

[jira] [Commented] (FLINK-8236) Allow to set the parallelism of table queries

2017-12-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290443#comment-16290443 ] Xingcan Cui commented on FLINK-8236: We need to enable the batch query configuration first. > Allow

<    1   2   3   4   >