[jira] [Created] (FLINK-6237) support RAND and RAND_INTEGER on SQL

2017-03-31 Thread godfrey he (JIRA)
godfrey he created FLINK-6237: - Summary: support RAND and RAND_INTEGER on SQL Key: FLINK-6237 URL: https://issues.apache.org/jira/browse/FLINK-6237 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-6238: - Summary: support OVER on batch SQL Key: FLINK-6238 URL: https://issues.apache.org/jira/browse/FLINK-6238 Project: Flink Issue Type: New Feature Component

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Created] (FLINK-5184) Error result of compareSerialized in RowComparator class

2016-11-28 Thread godfrey he (JIRA)
godfrey he created FLINK-5184: - Summary: Error result of compareSerialized in RowComparator class Key: FLINK-5184 URL: https://issues.apache.org/jira/browse/FLINK-5184 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5184) Error result of compareSerialized in RowComparator class

2016-11-29 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-5184: - Assignee: godfrey he > Error result of compareSerialized in RowComparator class > ---

[jira] [Created] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
godfrey he created FLINK-5342: - Summary: Setting the parallelism automatically for DataSet Operators base on cost model Key: FLINK-5342 URL: https://issues.apache.org/jira/browse/FLINK-5342 Project: Flink

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Summary: Setting the parallelism automatically for operators base on cost model (was: Setting the paral

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for Operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Summary: Setting the parallelism automatically for Operators base on cost model (was: Setting the paral

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Updated] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5342: -- Description: On Flink table API, a query will be translated to operators without parallelism. And user d

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-15 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753260#comment-15753260 ] godfrey he commented on FLINK-5342: --- take your point,there is a lot of work to do if we

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he commented on FLINK-5342: --- at present, we can use TableConfig to tune the para

[jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he edited comment on FLINK-5342 at 12/19/16 3:32 AM: -

[jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he edited comment on FLINK-5342 at 12/19/16 3:35 AM: -

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-19 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762989#comment-15762989 ] godfrey he commented on FLINK-5342: --- I think it's difficult and unintuitive about tuning

[jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762989#comment-15762989 ] godfrey he edited comment on FLINK-5342 at 12/20/16 8:51 AM: -

[jira] [Created] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread godfrey he (JIRA)
godfrey he created FLINK-6279: - Summary: the digest of VolcanoRuleMatch matched different table sources with same field names may be same Key: FLINK-6279 URL: https://issues.apache.org/jira/browse/FLINK-6279

[jira] [Updated] (FLINK-6237) support RAND and RAND_INTEGER on Table API & SQL

2017-04-08 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6237: -- Description: support RAND and RAND_INTEGER with and without seed on on Table API & SQL. like: RAND([see

[jira] [Updated] (FLINK-6237) support RAND and RAND_INTEGER on Table API & SQL

2017-04-08 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6237: -- Summary: support RAND and RAND_INTEGER on Table API & SQL (was: support RAND and RAND_INTEGER on SQL)

[jira] [Created] (FLINK-6326) add ProjectMergeRule at logical optimization stage

2017-04-19 Thread godfrey he (JIRA)
godfrey he created FLINK-6326: - Summary: add ProjectMergeRule at logical optimization stage Key: FLINK-6326 URL: https://issues.apache.org/jira/browse/FLINK-6326 Project: Flink Issue Type: New Fe

[jira] [Updated] (FLINK-6326) add ProjectMergeRule at logical optimization stage

2017-04-19 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6326: -- Description: add ProjectMergeRule to merge projections. Some SQLs can not push projection into scan wit

[jira] [Created] (FLINK-6327) Bug in CommonCalc's estimateRowCount() method

2017-04-19 Thread godfrey he (JIRA)
godfrey he created FLINK-6327: - Summary: Bug in CommonCalc's estimateRowCount() method Key: FLINK-6327 URL: https://issues.apache.org/jira/browse/FLINK-6327 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

2017-05-03 Thread godfrey he (JIRA)
godfrey he created FLINK-6436: - Summary: Bug in CommonCorrelate's generateCollector method when using udtf with udf Key: FLINK-6436 URL: https://issues.apache.org/jira/browse/FLINK-6436 Project: Flink

[jira] [Updated] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

2017-05-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6436: -- Description: When running table api code (using udtf with udf) like: {code} val env = ExecutionEnvir

[jira] [Updated] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

2017-05-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6436: -- Description: When running table api code (using udtf with udf) like: {code} val env = ExecutionEnvir

[jira] [Updated] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

2017-05-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6436: -- Description: When running table api code (using udtf with udf) like: {code} val env = ExecutionEnvir

[jira] [Assigned] (FLINK-5514) Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS

2017-05-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-5514: - Assignee: godfrey he > Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS >

[jira] [Created] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2017-05-09 Thread godfrey he (JIRA)
godfrey he created FLINK-6516: - Summary: using real row count instead of dummy row count when optimizing plan Key: FLINK-6516 URL: https://issues.apache.org/jira/browse/FLINK-6516 Project: Flink

[jira] [Assigned] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2017-05-09 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-6516: - Assignee: godfrey he > using real row count instead of dummy row count when optimizing plan > ---

[jira] [Created] (FLINK-5858) Support multiple sinks in same execution DAG

2017-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-5858: - Summary: Support multiple sinks in same execution DAG Key: FLINK-5858 URL: https://issues.apache.org/jira/browse/FLINK-5858 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-5858) Support multiple sinks in same execution DAG

2017-02-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5858: -- Description: When call writeToSink method to write the Table(with TableSource) to a TableSink, the Tabl

[jira] [Updated] (FLINK-5858) Support multiple sinks in same execution DAG

2017-02-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5858: -- Description: When call writeToSink method to write the Table(with TableSource) to a TableSink, the Tabl

[jira] [Created] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-5859: - Summary: support partition pruning on Table API & SQL Key: FLINK-5859 URL: https://issues.apache.org/jira/browse/FLINK-5859 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881999#comment-15881999 ] godfrey he commented on FLINK-5859: --- Hi, [~fhueske], Thanks for your advice. yes, partit

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15881999#comment-15881999 ] godfrey he edited comment on FLINK-5859 at 2/24/17 5:59 AM: Hi

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he commented on FLINK-5859: --- Hi, [~fhueske], Thanks for you advice. IMO, Rules

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 3:58 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 4:08 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 4:12 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 6:10 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-27 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 8:27 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-27 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 8:31 AM: Hi

[jira] [Comment Edited] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-27 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15885098#comment-15885098 ] godfrey he edited comment on FLINK-5859 at 2/27/17 8:33 AM: Hi

[jira] [Created] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

2017-01-03 Thread godfrey he (JIRA)
godfrey he created FLINK-5406: - Summary: add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase Key: FLINK-5406 URL: https://issues.apache.org/jira/

[jira] [Updated] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

2017-01-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5406: -- Description: Normalization phase is for predicate logical plan rewriting and is independent of cost mod

[jira] [Updated] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

2017-01-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5406: -- Description: Normalization phase is for predicate logical plan rewriting and is independent of cost mod

[jira] [Assigned] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

2017-01-03 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-5406: - Assignee: godfrey he > add normalization phase for predicate logical plan rewriting between > de

[jira] [Created] (FLINK-5571) add open/close methods for UserDefinedFunction in TableAPI & SQL

2017-01-18 Thread godfrey he (JIRA)
godfrey he created FLINK-5571: - Summary: add open/close methods for UserDefinedFunction in TableAPI & SQL Key: FLINK-5571 URL: https://issues.apache.org/jira/browse/FLINK-5571 Project: Flink Iss

[jira] [Updated] (FLINK-5571) add open and close methods for UserDefinedFunction in TableAPI & SQL

2017-01-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5571: -- Summary: add open and close methods for UserDefinedFunction in TableAPI & SQL (was: add open/close meth

[jira] [Updated] (FLINK-5571) add open and close methods for UserDefinedFunction in TableAPI & SQL

2017-01-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-5571: -- Description: Currently, a User Defined Function (UDF) in table API & SQL works on zero, one, or multipl

[jira] [Updated] (FLINK-7620) Supports custom optimization phase

2017-09-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7620: -- Issue Type: Improvement (was: Bug) > Supports custom optimization phase > -

[jira] [Created] (FLINK-7620) Supports custom optimization phase

2017-09-14 Thread godfrey he (JIRA)
godfrey he created FLINK-7620: - Summary: Supports custom optimization phase Key: FLINK-7620 URL: https://issues.apache.org/jira/browse/FLINK-7620 Project: Flink Issue Type: Bug Componen

[jira] [Updated] (FLINK-7620) Supports custom optimization phase

2017-09-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7620: -- Description: Currently, the optimization phases are hardcode in {{BatchTableEnvironment}} and {{StreamTa

[jira] [Updated] (FLINK-7620) Supports custom optimization phase

2017-09-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7620: -- Environment: (was: Currently, the optimization phases are hardcode in {{BatchTableEnvironment}} and

[jira] [Updated] (FLINK-7620) Supports user defined optimization phase

2017-09-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7620: -- Summary: Supports user defined optimization phase (was: Supports custom optimization phase) > Supports

[jira] [Assigned] (FLINK-5858) Support multiple sinks in same execution DAG

2017-09-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-5858: - Assignee: godfrey he > Support multiple sinks in same execution DAG > ---

[jira] [Created] (FLINK-7802) Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource

2017-10-10 Thread godfrey he (JIRA)
godfrey he created FLINK-7802: - Summary: Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource Key: FLINK-7802 URL: https://issues.apache.org/jira/browse/FLINK-7802

[jira] [Updated] (FLINK-7802) Error occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Error occur when empty field collection was pushed into TableSource (was: Bug in PushProjectI

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into CSVTableSource (was: Exception occ

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into TableSource (was: Error occur wh

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into TableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Summary: Exception occur when empty field collection was pushed into TableSource (was: Exception occur

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Description: Consider such SQL: select count(1) from csv_table. When above SQL was executed, an except

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-11 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7802: -- Description: Consider such SQL: select count(1) from csv_table. When above SQL was executed, an except

[jira] [Created] (FLINK-7834) cost model supports network cost and memory cost

2017-10-13 Thread godfrey he (JIRA)
godfrey he created FLINK-7834: - Summary: cost model supports network cost and memory cost Key: FLINK-7834 URL: https://issues.apache.org/jira/browse/FLINK-7834 Project: Flink Issue Type: New Feat

[jira] [Updated] (FLINK-7834) cost model (RelOptCost) extends network cost and memory cost

2017-10-13 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7834: -- Summary: cost model (RelOptCost) extends network cost and memory cost (was: cost model(RelOptCost) exte

[jira] [Updated] (FLINK-7834) cost model(RelOptCost) extends network cost and memory cost

2017-10-13 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-7834: -- Summary: cost model(RelOptCost) extends network cost and memory cost (was: cost model supports network

[jira] [Commented] (FLINK-11711) Add table and column stats

2019-09-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939114#comment-16939114 ] godfrey he commented on FLINK-11711: I will close this issue and will open a new iss

[jira] [Closed] (FLINK-11711) Add table and column stats

2019-09-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-11711. -- Resolution: Fixed TableStats was moved into flink-table-common in FLINK-11516 > Add table and column

[jira] [Closed] (FLINK-12348) Use TableConfig in API module to replace TableConfig in blink-planner-module

2019-09-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-12348. -- Fixed in 1.9.0: 428c7049882cfc482562b69d1a367cdb9b0eec72 > Use TableConfig in API module to replace Table

[jira] [Closed] (FLINK-13314) Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner

2019-09-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-13314. -- > Correct resultType of some PlannerExpression when operands contains > DecimalTypeInfo or BigDecimalType

[jira] [Closed] (FLINK-12810) Support to run a TableAPI query like 'table.select('a, 'b, 'c)' in Blink runner

2019-09-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-12810. -- > Support to run a TableAPI query like 'table.select('a, 'b, 'c)' in Blink > runner > ---

[jira] [Closed] (FLINK-11488) Add a basic Blink planner framework

2019-09-27 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-11488. -- Resolution: Fixed > Add a basic Blink planner framework > --- > >

[jira] [Updated] (FLINK-11488) Add a basic Blink planner framework

2019-09-27 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11488: --- Fix Version/s: 1.9.0 > Add a basic Blink planner framework > --- > >

[jira] [Created] (FLINK-12509) Introduce planner rules about non semi/anti join

2019-05-14 Thread godfrey he (JIRA)
godfrey he created FLINK-12509: -- Summary: Introduce planner rules about non semi/anti join Key: FLINK-12509 URL: https://issues.apache.org/jira/browse/FLINK-12509 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-11841) Introduce FlinkLogicalSemiJoin

2019-05-14 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-11841. -- Resolution: Resolved Release Note: resolved in FLINK-12371 > Introduce FlinkLogicalSemiJoin > --

[jira] [Created] (FLINK-12519) Introduce planner rules about semi/anti join

2019-05-15 Thread godfrey he (JIRA)
godfrey he created FLINK-12519: -- Summary: Introduce planner rules about semi/anti join Key: FLINK-12519 URL: https://issues.apache.org/jira/browse/FLINK-12519 Project: Flink Issue Type: New Feat

[jira] [Updated] (FLINK-12509) Introduce planner rules about non semi/anti join

2019-05-15 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12509: --- Description: This issue aims to introduce planner rules about non semi/anti join, rules include: 1.

[jira] [Created] (FLINK-12524) Introduce planner rules about rank

2019-05-15 Thread godfrey he (JIRA)
godfrey he created FLINK-12524: -- Summary: Introduce planner rules about rank Key: FLINK-12524 URL: https://issues.apache.org/jira/browse/FLINK-12524 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-11822) Introduce Flink metadata handlers

2019-05-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11822: --- Description: Calcite has defined various metadata handlers(e.g. {{RowCoun}}, {{Selectivity}} and pr

[jira] [Created] (FLINK-12559) Introduce metadata handlers on window aggregate

2019-05-20 Thread godfrey he (JIRA)
godfrey he created FLINK-12559: -- Summary: Introduce metadata handlers on window aggregate Key: FLINK-12559 URL: https://issues.apache.org/jira/browse/FLINK-12559 Project: Flink Issue Type: New F

[jira] [Updated] (FLINK-12559) Introduce metadata handlers on window aggregate

2019-05-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12559: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Updated] (FLINK-12559) Introduce metadata handlers on window aggregate

2019-05-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12559: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Updated] (FLINK-12559) Introduce metadata handlers on window aggregate

2019-05-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12559: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Updated] (FLINK-12559) Introduce metadata handlers on window aggregate

2019-05-20 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12559: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Created] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
godfrey he created FLINK-12575: -- Summary: Introduce planner rules to remove redundant shuffle and collation Key: FLINK-12575 URL: https://issues.apache.org/jira/browse/FLINK-12575 Project: Flink

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Updated] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation

2019-05-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12575: --- Description: {{Exchange}} and {{Sort}} is the most heavy operator, they are created in {{FlinkExpan

[jira] [Created] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode

2019-05-23 Thread godfrey he (JIRA)
godfrey he created FLINK-12600: -- Summary: Introduce planner rules to do deterministic rewriting on RelNode Key: FLINK-12600 URL: https://issues.apache.org/jira/browse/FLINK-12600 Project: Flink

[jira] [Updated] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode

2019-05-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12600: --- Description: This issue aims to introduce planner rules to to do deterministic rewriting on RelNode

[jira] [Updated] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode

2019-05-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12600: --- Description: This issue aims to introduce planner rules to to do deterministic rewriting on RelNode

[jira] [Updated] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode

2019-05-23 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12600: --- Description: This issue aims to introduce planner rules to to do deterministic rewriting on RelNode

  1   2   3   4   5   6   7   8   9   10   >