[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

[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] [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

[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] [Created] (FLINK-12487) Introduce planner rules to rewrite expression and merge calc

2019-05-10 Thread godfrey he (JIRA)
godfrey he created FLINK-12487: -- Summary: Introduce planner rules to rewrite expression and merge calc Key: FLINK-12487 URL: https://issues.apache.org/jira/browse/FLINK-12487 Project: Flink

[jira] [Created] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread godfrey he (JIRA)
godfrey he created FLINK-12424: -- Summary: Supports dag (multiple-sinks query) optimization Key: FLINK-12424 URL: https://issues.apache.org/jira/browse/FLINK-12424 Project: Flink Issue Type: New

[jira] [Created] (FLINK-12371) Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan

2019-04-29 Thread godfrey he (JIRA)
godfrey he created FLINK-12371: -- Summary: Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan Key: FLINK-12371 URL: https://issues.apache.org/jira/browse/FLINK-12371

[jira] [Created] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

2019-04-27 Thread godfrey he (JIRA)
godfrey he created FLINK-12345: -- Summary: Add support for generating optimized logical plan for stream window aggregate Key: FLINK-12345 URL: https://issues.apache.org/jira/browse/FLINK-12345 Project

[jira] [Created] (FLINK-12321) Supports sub-plan reuse

2019-04-24 Thread godfrey he (JIRA)
godfrey he created FLINK-12321: -- Summary: Supports sub-plan reuse Key: FLINK-12321 URL: https://issues.apache.org/jira/browse/FLINK-12321 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen

2019-04-22 Thread godfrey he (JIRA)
godfrey he created FLINK-12295: -- Summary: use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen Key: FLINK-12295 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-12282) re-estimate row count for batch global Rank operator

2019-04-20 Thread godfrey he (JIRA)
godfrey he created FLINK-12282: -- Summary: re-estimate row count for batch global Rank operator Key: FLINK-12282 URL: https://issues.apache.org/jira/browse/FLINK-12282 Project: Flink Issue Type

[jira] [Created] (FLINK-12192) Add support for generating optimized logical plan for grouping sets and distinct aggregate

2019-04-15 Thread godfrey he (JIRA)
godfrey he created FLINK-12192: -- Summary: Add support for generating optimized logical plan for grouping sets and distinct aggregate Key: FLINK-12192 URL: https://issues.apache.org/jira/browse/FLINK-12192

[jira] [Created] (FLINK-12185) Add support for generating optimized logical plan for join on stream

2019-04-13 Thread godfrey he (JIRA)
godfrey he created FLINK-12185: -- Summary: Add support for generating optimized logical plan for join on stream Key: FLINK-12185 URL: https://issues.apache.org/jira/browse/FLINK-12185 Project: Flink

[jira] [Created] (FLINK-12170) Add support for generating optimized logical plan for Over aggregate

2019-04-12 Thread godfrey he (JIRA)
godfrey he created FLINK-12170: -- Summary: Add support for generating optimized logical plan for Over aggregate Key: FLINK-12170 URL: https://issues.apache.org/jira/browse/FLINK-12170 Project: Flink

[jira] [Created] (FLINK-12161) Supports partial-final optimization for stream group aggregate

2019-04-11 Thread godfrey he (JIRA)
godfrey he created FLINK-12161: -- Summary: Supports partial-final optimization for stream group aggregate Key: FLINK-12161 URL: https://issues.apache.org/jira/browse/FLINK-12161 Project: Flink

[jira] [Created] (FLINK-12098) Add support for generating optimized logical plan for simple group aggregate on batch

2019-04-03 Thread godfrey he (JIRA)
godfrey he created FLINK-12098: -- Summary: Add support for generating optimized logical plan for simple group aggregate on batch Key: FLINK-12098 URL: https://issues.apache.org/jira/browse/FLINK-12098

[jira] [Created] (FLINK-12079) Add support for generating optimized logical plan for join on batch

2019-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-12079: -- Summary: Add support for generating optimized logical plan for join on batch Key: FLINK-12079 URL: https://issues.apache.org/jira/browse/FLINK-12079 Project: Flink

[jira] [Created] (FLINK-12076) Add support for generating optimized logical plan for batch simple group aggregate

2019-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-12076: -- Summary: Add support for generating optimized logical plan for batch simple group aggregate Key: FLINK-12076 URL: https://issues.apache.org/jira/browse/FLINK-12076

[jira] [Created] (FLINK-12018) Add support for generating optimized logical plan for Sort and Rank

2019-03-26 Thread godfrey he (JIRA)
godfrey he created FLINK-12018: -- Summary: Add support for generating optimized logical plan for Sort and Rank Key: FLINK-12018 URL: https://issues.apache.org/jira/browse/FLINK-12018 Project: Flink

[jira] [Created] (FLINK-11973) computeSelfCost method should not return null to avoid NPE

2019-03-20 Thread godfrey he (JIRA)
godfrey he created FLINK-11973: -- Summary: computeSelfCost method should not return null to avoid NPE Key: FLINK-11973 URL: https://issues.apache.org/jira/browse/FLINK-11973 Project: Flink Issue

[jira] [Created] (FLINK-11966) Add support for generating optimized logical plan for simple query(project, filter, values and union all)

2019-03-19 Thread godfrey he (JIRA)
godfrey he created FLINK-11966: -- Summary: Add support for generating optimized logical plan for simple query(project, filter, values and union all) Key: FLINK-11966 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-11932) Add support for generating optimized logical plan for 'select * from mytable'

2019-03-15 Thread godfrey he (JIRA)
godfrey he created FLINK-11932: -- Summary: Add support for generating optimized logical plan for 'select * from mytable' Key: FLINK-11932 URL: https://issues.apache.org/jira/browse/FLINK-11932

[jira] [Created] (FLINK-11896) Introduce stream physical nodes

2019-03-12 Thread godfrey he (JIRA)
godfrey he created FLINK-11896: -- Summary: Introduce stream physical nodes Key: FLINK-11896 URL: https://issues.apache.org/jira/browse/FLINK-11896 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11854) Introduce batch physical nodes

2019-03-07 Thread godfrey he (JIRA)
godfrey he created FLINK-11854: -- Summary: Introduce batch physical nodes Key: FLINK-11854 URL: https://issues.apache.org/jira/browse/FLINK-11854 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11842) Introduce FlinkLogicalMatch

2019-03-06 Thread godfrey he (JIRA)
godfrey he created FLINK-11842: -- Summary: Introduce FlinkLogicalMatch Key: FLINK-11842 URL: https://issues.apache.org/jira/browse/FLINK-11842 Project: Flink Issue Type: New Feature

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

2019-03-06 Thread godfrey he (JIRA)
godfrey he created FLINK-11841: -- Summary: Introduce FlinkLogicalSemiJoin Key: FLINK-11841 URL: https://issues.apache.org/jira/browse/FLINK-11841 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11840) Introduce FlinkLogicalSnapshot

2019-03-06 Thread godfrey he (JIRA)
godfrey he created FLINK-11840: -- Summary: Introduce FlinkLogicalSnapshot Key: FLINK-11840 URL: https://issues.apache.org/jira/browse/FLINK-11840 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11839) Introduce the rest flink logical relational nodes

2019-03-06 Thread godfrey he (JIRA)
godfrey he created FLINK-11839: -- Summary: Introduce the rest flink logical relational nodes Key: FLINK-11839 URL: https://issues.apache.org/jira/browse/FLINK-11839 Project: Flink Issue Type

[jira] [Created] (FLINK-11834) Introduce flink logical relational nodes

2019-03-06 Thread godfrey he (JIRA)
godfrey he created FLINK-11834: -- Summary: Introduce flink logical relational nodes Key: FLINK-11834 URL: https://issues.apache.org/jira/browse/FLINK-11834 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11822) Introduce Flink metadata handler

2019-03-05 Thread godfrey he (JIRA)
godfrey he created FLINK-11822: -- Summary: Introduce Flink metadata handler Key: FLINK-11822 URL: https://issues.apache.org/jira/browse/FLINK-11822 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11795) Introduce DataStream nodes and rules for batch and stream

2019-03-02 Thread godfrey he (JIRA)
godfrey he created FLINK-11795: -- Summary: Introduce DataStream nodes and rules for batch and stream Key: FLINK-11795 URL: https://issues.apache.org/jira/browse/FLINK-11795 Project: Flink Issue

[jira] [Created] (FLINK-11790) Introduce basic Flink RelNode interface

2019-03-01 Thread godfrey he (JIRA)
godfrey he created FLINK-11790: -- Summary: Introduce basic Flink RelNode interface Key: FLINK-11790 URL: https://issues.apache.org/jira/browse/FLINK-11790 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11715) Add optimize program to organize optimization phases

2019-02-21 Thread godfrey he (JIRA)
godfrey he created FLINK-11715: -- Summary: Add optimize program to organize optimization phases Key: FLINK-11715 URL: https://issues.apache.org/jira/browse/FLINK-11715 Project: Flink Issue Type

[jira] [Created] (FLINK-11714) Add cost model for both batch and streaming

2019-02-21 Thread godfrey he (JIRA)
godfrey he created FLINK-11714: -- Summary: Add cost model for both batch and streaming Key: FLINK-11714 URL: https://issues.apache.org/jira/browse/FLINK-11714 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11712) Add cost model for both batch and streaming

2019-02-21 Thread godfrey he (JIRA)
godfrey he created FLINK-11712: -- Summary: Add cost model for both batch and streaming Key: FLINK-11712 URL: https://issues.apache.org/jira/browse/FLINK-11712 Project: Flink Issue Type: New

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

2019-02-21 Thread godfrey he (JIRA)
godfrey he created FLINK-11711: -- Summary: Add table and column stats Key: FLINK-11711 URL: https://issues.apache.org/jira/browse/FLINK-11711 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11685) Add plan test infrastructure

2019-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-11685: -- Summary: Add plan test infrastructure Key: FLINK-11685 URL: https://issues.apache.org/jira/browse/FLINK-11685 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11680) make query plan easier to read

2019-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-11680: -- Summary: make query plan easier to read Key: FLINK-11680 URL: https://issues.apache.org/jira/browse/FLINK-11680 Project: Flink Issue Type: New Feature

[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

[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] [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

[jira] [Created] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
godfrey he created FLINK-7244: - Summary: Add ParquetTableSource Implementation based on ParquetInputFormat Key: FLINK-7244 URL: https://issues.apache.org/jira/browse/FLINK-7244 Project: Flink

[jira] [Created] (FLINK-7243) Add ParquetInputFormat

2017-07-23 Thread godfrey he (JIRA)
godfrey he created FLINK-7243: - Summary: Add ParquetInputFormat Key: FLINK-7243 URL: https://issues.apache.org/jira/browse/FLINK-7243 Project: Flink Issue Type: Sub-task Reporter

[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] [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:

[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

[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

[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] [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

[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-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 Fea

[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] [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: F

[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] [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

[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] [Created] (FLINK-3253) deserializeObject exception on WindowOperator

2016-01-18 Thread godfrey he (JIRA)
godfrey he created FLINK-3253: - Summary: deserializeObject exception on WindowOperator Key: FLINK-3253 URL: https://issues.apache.org/jira/browse/FLINK-3253 Project: Flink Issue Type: Bug

<    1   2   3   4   5