[jira] [Created] (FLINK-31833) Support code-gen fusion for multiple operators

2023-04-18 Thread Godfrey He (Jira)
Godfrey He created FLINK-31833: -- Summary: Support code-gen fusion for multiple operators Key: FLINK-31833 URL: https://issues.apache.org/jira/browse/FLINK-31833 Project: Flink Issue Type:

[jira] [Created] (FLINK-31767) Improve the implementation for "analyze table" execution

2023-04-11 Thread Godfrey He (Jira)
Godfrey He created FLINK-31767: -- Summary: Improve the implementation for "analyze table" execution Key: FLINK-31767 URL: https://issues.apache.org/jira/browse/FLINK-31767 Project: Flink Issue

[jira] [Created] (FLINK-29981) Improve WatermarkAssignerChangelogNormalizeTransposeRule

2022-11-10 Thread godfrey he (Jira)
godfrey he created FLINK-29981: -- Summary: Improve WatermarkAssignerChangelogNormalizeTransposeRule Key: FLINK-29981 URL: https://issues.apache.org/jira/browse/FLINK-29981 Project: Flink Issue

[jira] [Created] (FLINK-28939) Release Testing: Verify FLIP-241 ANALYZE TABLE

2022-08-11 Thread godfrey he (Jira)
godfrey he created FLINK-28939: -- Summary: Release Testing: Verify FLIP-241 ANALYZE TABLE Key: FLINK-28939 URL: https://issues.apache.org/jira/browse/FLINK-28939 Project: Flink Issue Type:

[jira] [Created] (FLINK-28940) Release Testing: Verify FLIP-248 Dynamic Partition Prunning

2022-08-11 Thread godfrey he (Jira)
godfrey he created FLINK-28940: -- Summary: Release Testing: Verify FLIP-248 Dynamic Partition Prunning Key: FLINK-28940 URL: https://issues.apache.org/jira/browse/FLINK-28940 Project: Flink

[jira] [Created] (FLINK-28866) Use DDL instead of legacy method to register the test source in JoinITCase

2022-08-08 Thread godfrey he (Jira)
godfrey he created FLINK-28866: -- Summary: Use DDL instead of legacy method to register the test source in JoinITCase Key: FLINK-28866 URL: https://issues.apache.org/jira/browse/FLINK-28866 Project:

[jira] [Created] (FLINK-28859) FAILED pyflink/datastream/connectors/tests/test_file_system.py::FileSinkCsvBulkWriterTests::test_csv_customize_quote_char_write

2022-08-07 Thread godfrey he (Jira)
godfrey he created FLINK-28859: -- Summary: FAILED pyflink/datastream/connectors/tests/test_file_system.py::FileSinkCsvBulkWriterTests::test_csv_customize_quote_char_write Key: FLINK-28859 URL:

[jira] [Created] (FLINK-28858) Add document to describe join hints for batch sql

2022-08-07 Thread godfrey he (Jira)
godfrey he created FLINK-28858: -- Summary: Add document to describe join hints for batch sql Key: FLINK-28858 URL: https://issues.apache.org/jira/browse/FLINK-28858 Project: Flink Issue Type:

[jira] [Created] (FLINK-28821) Adjust join cost for dpp query pattern which could help more plans use dpp

2022-08-04 Thread godfrey he (Jira)
godfrey he created FLINK-28821: -- Summary: Adjust join cost for dpp query pattern which could help more plans use dpp Key: FLINK-28821 URL: https://issues.apache.org/jira/browse/FLINK-28821 Project:

[jira] [Created] (FLINK-28787) rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin

2022-08-03 Thread godfrey he (Jira)
godfrey he created FLINK-28787: -- Summary: rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin Key: FLINK-28787 URL: https://issues.apache.org/jira/browse/FLINK-28787 Project: Flink

[jira] [Created] (FLINK-28753) Improve FilterIntoJoinRule which could push some predicate to another side

2022-07-30 Thread godfrey he (Jira)
godfrey he created FLINK-28753: -- Summary: Improve FilterIntoJoinRule which could push some predicate to another side Key: FLINK-28753 URL: https://issues.apache.org/jira/browse/FLINK-28753 Project:

[jira] [Created] (FLINK-28726) CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int)

2022-07-28 Thread godfrey he (Jira)
godfrey he created FLINK-28726: -- Summary: CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int) Key: FLINK-28726 URL:

[jira] [Created] (FLINK-28711) Hive connector implements SupportsDynamicFiltering interface

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28711: -- Summary: Hive connector implements SupportsDynamicFiltering interface Key: FLINK-28711 URL: https://issues.apache.org/jira/browse/FLINK-28711 Project: Flink

[jira] [Created] (FLINK-28710) Transform dpp ExecNode to StreamGraph

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28710: -- Summary: Transform dpp ExecNode to StreamGraph Key: FLINK-28710 URL: https://issues.apache.org/jira/browse/FLINK-28710 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28709) Implement dynamic filtering operators

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28709: -- Summary: Implement dynamic filtering operators Key: FLINK-28709 URL: https://issues.apache.org/jira/browse/FLINK-28709 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28708) Introduce planner rules to optimize dpp pattern

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28708: -- Summary: Introduce planner rules to optimize dpp pattern Key: FLINK-28708 URL: https://issues.apache.org/jira/browse/FLINK-28708 Project: Flink Issue Type:

[jira] [Created] (FLINK-28707) Introduce interface SupportsDynamicPartitionPruning

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28707: -- Summary: Introduce interface SupportsDynamicPartitionPruning Key: FLINK-28707 URL: https://issues.apache.org/jira/browse/FLINK-28707 Project: Flink Issue Type:

[jira] [Created] (FLINK-28706) FLIP-248: Introduce dynamic partition pruning

2022-07-27 Thread godfrey he (Jira)
godfrey he created FLINK-28706: -- Summary: FLIP-248: Introduce dynamic partition pruning Key: FLINK-28706 URL: https://issues.apache.org/jira/browse/FLINK-28706 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28493) Add document to describe "ANALYZE TABLE" syntax

2022-07-11 Thread godfrey he (Jira)
godfrey he created FLINK-28493: -- Summary: Add document to describe "ANALYZE TABLE" syntax Key: FLINK-28493 URL: https://issues.apache.org/jira/browse/FLINK-28493 Project: Flink Issue Type:

[jira] [Created] (FLINK-28492) Support "ANALYZE TABLE" execution

2022-07-11 Thread godfrey he (Jira)
godfrey he created FLINK-28492: -- Summary: Support "ANALYZE TABLE" execution Key: FLINK-28492 URL: https://issues.apache.org/jira/browse/FLINK-28492 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28491) Introduce APPROX_COUNT_DISTINCT aggregate function for batch sql

2022-07-11 Thread godfrey he (Jira)
godfrey he created FLINK-28491: -- Summary: Introduce APPROX_COUNT_DISTINCT aggregate function for batch sql Key: FLINK-28491 URL: https://issues.apache.org/jira/browse/FLINK-28491 Project: Flink

[jira] [Created] (FLINK-28490) Introduce "ANALYZE TABLE" Syntax in sql parser

2022-07-11 Thread godfrey he (Jira)
godfrey he created FLINK-28490: -- Summary: Introduce "ANALYZE TABLE" Syntax in sql parser Key: FLINK-28490 URL: https://issues.apache.org/jira/browse/FLINK-28490 Project: Flink Issue Type:

[jira] [Created] (FLINK-28489) FLIP-240: Introduce "ANALYZE TABLE" Syntax

2022-07-11 Thread godfrey he (Jira)
godfrey he created FLINK-28489: -- Summary: FLIP-240: Introduce "ANALYZE TABLE" Syntax Key: FLINK-28489 URL: https://issues.apache.org/jira/browse/FLINK-28489 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28075) get statistics for partitioned table even without partition pruning

2022-06-15 Thread godfrey he (Jira)
godfrey he created FLINK-28075: -- Summary: get statistics for partitioned table even without partition pruning Key: FLINK-28075 URL: https://issues.apache.org/jira/browse/FLINK-28075 Project: Flink

[jira] [Created] (FLINK-28074) display

2022-06-15 Thread godfrey he (Jira)
godfrey he created FLINK-28074: -- Summary: display Key: FLINK-28074 URL: https://issues.apache.org/jira/browse/FLINK-28074 Project: Flink Issue Type: New Feature Reporter: godfrey he

[jira] [Created] (FLINK-27990) Parquet format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27990: -- Summary: Parquet format supports reporting statistics Key: FLINK-27990 URL: https://issues.apache.org/jira/browse/FLINK-27990 Project: Flink Issue Type:

[jira] [Created] (FLINK-27991) ORC format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27991: -- Summary: ORC format supports reporting statistics Key: FLINK-27991 URL: https://issues.apache.org/jira/browse/FLINK-27991 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27989) CSV format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27989: -- Summary: CSV format supports reporting statistics Key: FLINK-27989 URL: https://issues.apache.org/jira/browse/FLINK-27989 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27988) Let HiveTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27988: -- Summary: Let HiveTableSource extend from SupportsStatisticReport Key: FLINK-27988 URL: https://issues.apache.org/jira/browse/FLINK-27988 Project: Flink Issue

[jira] [Created] (FLINK-27987) Let FileSystemTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27987: -- Summary: Let FileSystemTableSource extend from SupportsStatisticReport Key: FLINK-27987 URL: https://issues.apache.org/jira/browse/FLINK-27987 Project: Flink

[jira] [Created] (FLINK-27985) Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27985: -- Summary: Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning Key: FLINK-27985 URL:

[jira] [Created] (FLINK-27984) Introduce FileBasedStatisticsReportableDecodingFormat interface

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27984: -- Summary: Introduce FileBasedStatisticsReportableDecodingFormat interface Key: FLINK-27984 URL: https://issues.apache.org/jira/browse/FLINK-27984 Project: Flink

[jira] [Created] (FLINK-27983) Introduce SupportsStatisticsReport interface

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27983: -- Summary: Introduce SupportsStatisticsReport interface Key: FLINK-27983 URL: https://issues.apache.org/jira/browse/FLINK-27983 Project: Flink Issue Type:

[jira] [Created] (FLINK-27982) FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27982: -- Summary: FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors Key: FLINK-27982 URL: https://issues.apache.org/jira/browse/FLINK-27982

[jira] [Created] (FLINK-27817) TaskManager metaspace OOM for session cluster

2022-05-27 Thread godfrey he (Jira)
godfrey he created FLINK-27817: -- Summary: TaskManager metaspace OOM for session cluster Key: FLINK-27817 URL: https://issues.apache.org/jira/browse/FLINK-27817 Project: Flink Issue Type: New

[jira] [Created] (FLINK-27815) Improve the join reorder strategy for batch sql job

2022-05-27 Thread godfrey he (Jira)
godfrey he created FLINK-27815: -- Summary: Improve the join reorder strategy for batch sql job Key: FLINK-27815 URL: https://issues.apache.org/jira/browse/FLINK-27815 Project: Flink Issue Type:

[jira] [Created] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable

2022-05-12 Thread godfrey he (Jira)
godfrey he created FLINK-27591: -- Summary: Improve the plan for batch queries when statistics is unavailable Key: FLINK-27591 URL: https://issues.apache.org/jira/browse/FLINK-27591 Project: Flink

[jira] [Created] (FLINK-27583) Improve the plan for TPC-DS queries

2022-05-12 Thread godfrey he (Jira)
godfrey he created FLINK-27583: -- Summary: Improve the plan for TPC-DS queries Key: FLINK-27583 URL: https://issues.apache.org/jira/browse/FLINK-27583 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

2022-04-16 Thread godfrey he (Jira)
godfrey he created FLINK-27272: -- Summary: The plan for query with local sort is incorrect if adaptive batch scheduler is enabled Key: FLINK-27272 URL: https://issues.apache.org/jira/browse/FLINK-27272

[jira] [Created] (FLINK-26756) Failed to deserialize for match recognize

2022-03-20 Thread godfrey he (Jira)
godfrey he created FLINK-26756: -- Summary: Failed to deserialize for match recognize Key: FLINK-26756 URL: https://issues.apache.org/jira/browse/FLINK-26756 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

2022-02-15 Thread godfrey he (Jira)
godfrey he created FLINK-26167: -- Summary: Explicitly set the partitioner for the sql operators whose shuffle and sort are removed Key: FLINK-26167 URL: https://issues.apache.org/jira/browse/FLINK-26167

[jira] [Created] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

2021-12-28 Thread godfrey he (Jira)
godfrey he created FLINK-25474: -- Summary: Idea Scala plugin can not compile RexExplainUtil Key: FLINK-25474 URL: https://issues.apache.org/jira/browse/FLINK-25474 Project: Flink Issue Type:

[jira] [Created] (FLINK-24813) Improve ImplicitTypeConversionITCase

2021-11-07 Thread godfrey he (Jira)
godfrey he created FLINK-24813: -- Summary: Improve ImplicitTypeConversionITCase Key: FLINK-24813 URL: https://issues.apache.org/jira/browse/FLINK-24813 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24676) Schema does not match if explain insert statement with partial column

2021-10-27 Thread godfrey he (Jira)
godfrey he created FLINK-24676: -- Summary: Schema does not match if explain insert statement with partial column Key: FLINK-24676 URL: https://issues.apache.org/jira/browse/FLINK-24676 Project: Flink

[jira] [Created] (FLINK-23483) Add document to describe how to submit job to different executor for sql client

2021-07-23 Thread godfrey he (Jira)
godfrey he created FLINK-23483: -- Summary: Add document to describe how to submit job to different executor for sql client Key: FLINK-23483 URL: https://issues.apache.org/jira/browse/FLINK-23483

[jira] [Created] (FLINK-23435) Improve the exception message when a query has lateral table join without 'AS' which return type is simple type

2021-07-20 Thread godfrey he (Jira)
godfrey he created FLINK-23435: -- Summary: Improve the exception message when a query has lateral table join without 'AS' which return type is simple type Key: FLINK-23435 URL:

[jira] [Created] (FLINK-23434) Inconsistent rowtypes occur in IncrementalAggregateRule

2021-07-19 Thread godfrey he (Jira)
godfrey he created FLINK-23434: -- Summary: Inconsistent rowtypes occur in IncrementalAggregateRule Key: FLINK-23434 URL: https://issues.apache.org/jira/browse/FLINK-23434 Project: Flink Issue

[jira] [Created] (FLINK-23217) Support StreamExecValues json serialization/deserialization

2021-07-02 Thread godfrey he (Jira)
godfrey he created FLINK-23217: -- Summary: Support StreamExecValues json serialization/deserialization Key: FLINK-23217 URL: https://issues.apache.org/jira/browse/FLINK-23217 Project: Flink

[jira] [Created] (FLINK-23094) encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment

2021-06-22 Thread godfrey he (Jira)
godfrey he created FLINK-23094: -- Summary: encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment Key: FLINK-23094 URL:

[jira] [Created] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

2021-05-26 Thread godfrey he (Jira)
godfrey he created FLINK-22781: -- Summary: Incorrect result for group window aggregate when mini-batch is enabled Key: FLINK-22781 URL: https://issues.apache.org/jira/browse/FLINK-22781 Project: Flink

[jira] [Created] (FLINK-22310) The result of LogicalWindowJsonDeserializer is incorrect

2021-04-16 Thread godfrey he (Jira)
godfrey he created FLINK-22310: -- Summary: The result of LogicalWindowJsonDeserializer is incorrect Key: FLINK-22310 URL: https://issues.apache.org/jira/browse/FLINK-22310 Project: Flink Issue

[jira] [Created] (FLINK-22298) The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread godfrey he (Jira)
godfrey he created FLINK-22298: -- Summary: The ExecNode's id should always start from 1 in json plan test Key: FLINK-22298 URL: https://issues.apache.org/jira/browse/FLINK-22298 Project: Flink

[jira] [Created] (FLINK-22022) Reduce the ExecNode scan scope to improve performance when converting json plan to ExecNodeGraph

2021-03-29 Thread godfrey he (Jira)
godfrey he created FLINK-22022: -- Summary: Reduce the ExecNode scan scope to improve performance when converting json plan to ExecNodeGraph Key: FLINK-22022 URL: https://issues.apache.org/jira/browse/FLINK-22022

[jira] [Created] (FLINK-21890) Rename DAGProcessor to ExecNodeGraphProcessor

2021-03-21 Thread godfrey he (Jira)
godfrey he created FLINK-21890: -- Summary: Rename DAGProcessor to ExecNodeGraphProcessor Key: FLINK-21890 URL: https://issues.apache.org/jira/browse/FLINK-21890 Project: Flink Issue Type:

[jira] [Created] (FLINK-21869) Support StreamExecTemporalSort json serialization/deserialization

2021-03-19 Thread godfrey he (Jira)
godfrey he created FLINK-21869: -- Summary: Support StreamExecTemporalSort json serialization/deserialization Key: FLINK-21869 URL: https://issues.apache.org/jira/browse/FLINK-21869 Project: Flink

[jira] [Created] (FLINK-21861) Support StreamExecIncrementalGroupAggregate json serialization/deserialization

2021-03-18 Thread godfrey he (Jira)
godfrey he created FLINK-21861: -- Summary: Support StreamExecIncrementalGroupAggregate json serialization/deserialization Key: FLINK-21861 URL: https://issues.apache.org/jira/browse/FLINK-21861 Project:

[jira] [Created] (FLINK-21860) Support StreamExecExpand json serialization/deserialization

2021-03-18 Thread godfrey he (Jira)
godfrey he created FLINK-21860: -- Summary: Support StreamExecExpand json serialization/deserialization Key: FLINK-21860 URL: https://issues.apache.org/jira/browse/FLINK-21860 Project: Flink

[jira] [Created] (FLINK-21791) Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization

2021-03-15 Thread godfrey he (Jira)
godfrey he created FLINK-21791: -- Summary: Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization Key: FLINK-21791 URL:

[jira] [Created] (FLINK-21750) Support StreamExecWatermarkAssigner json serialization/deserialization

2021-03-12 Thread godfrey he (Jira)
godfrey he created FLINK-21750: -- Summary: Support StreamExecWatermarkAssigner json serialization/deserialization Key: FLINK-21750 URL: https://issues.apache.org/jira/browse/FLINK-21750 Project: Flink

[jira] [Created] (FLINK-21730) Introduce ExecNodeTranslator

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21730: -- Summary: Introduce ExecNodeTranslator Key: FLINK-21730 URL: https://issues.apache.org/jira/browse/FLINK-21730 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21710) FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21710: -- Summary: FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down Key: FLINK-21710 URL: https://issues.apache.org/jira/browse/FLINK-21710 Project:

[jira] [Created] (FLINK-21697) Support StreamExecMiniBatchAssigner json serialization/deserialization

2021-03-09 Thread godfrey he (Jira)
godfrey he created FLINK-21697: -- Summary: Support StreamExecMiniBatchAssigner json serialization/deserialization Key: FLINK-21697 URL: https://issues.apache.org/jira/browse/FLINK-21697 Project: Flink

[jira] [Created] (FLINK-21646) Support json serialization/deserialization for the states in StreamExecGroupAggregate

2021-03-07 Thread godfrey he (Jira)
godfrey he created FLINK-21646: -- Summary: Support json serialization/deserialization for the states in StreamExecGroupAggregate Key: FLINK-21646 URL: https://issues.apache.org/jira/browse/FLINK-21646

[jira] [Created] (FLINK-21645) Introduce StateDeclaration

2021-03-07 Thread godfrey he (Jira)
godfrey he created FLINK-21645: -- Summary: Introduce StateDeclaration Key: FLINK-21645 URL: https://issues.apache.org/jira/browse/FLINK-21645 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21612) Support StreamExecGroupAggregate json serialization/deserialization

2021-03-04 Thread godfrey he (Jira)
godfrey he created FLINK-21612: -- Summary: Support StreamExecGroupAggregate json serialization/deserialization Key: FLINK-21612 URL: https://issues.apache.org/jira/browse/FLINK-21612 Project: Flink

[jira] [Created] (FLINK-21549) Support json serialization/deserialization for the push-down results

2021-03-01 Thread godfrey he (Jira)
godfrey he created FLINK-21549: -- Summary: Support json serialization/deserialization for the push-down results Key: FLINK-21549 URL: https://issues.apache.org/jira/browse/FLINK-21549 Project: Flink

[jira] [Created] (FLINK-21245) Support StreamExecCalc json serialization/deserialization

2021-02-02 Thread godfrey he (Jira)
godfrey he created FLINK-21245: -- Summary: Support StreamExecCalc json serialization/deserialization Key: FLINK-21245 URL: https://issues.apache.org/jira/browse/FLINK-21245 Project: Flink Issue

[jira] [Created] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

2021-01-31 Thread godfrey he (Jira)
godfrey he created FLINK-21224: -- Summary: Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge Key: FLINK-21224 URL: https://issues.apache.org/jira/browse/FLINK-21224

[jira] [Created] (FLINK-21150) Introduce ExecEdge to connect two ExecNodes

2021-01-26 Thread godfrey he (Jira)
godfrey he created FLINK-21150: -- Summary: Introduce ExecEdge to connect two ExecNodes Key: FLINK-21150 URL: https://issues.apache.org/jira/browse/FLINK-21150 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21105) Rename ExecEdge to InputProperty

2021-01-23 Thread godfrey he (Jira)
godfrey he created FLINK-21105: -- Summary: Rename ExecEdge to InputProperty Key: FLINK-21105 URL: https://issues.apache.org/jira/browse/FLINK-21105 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21097) Introduce e2e test framework for json plan test

2021-01-22 Thread godfrey he (Jira)
godfrey he created FLINK-21097: -- Summary: Introduce e2e test framework for json plan test Key: FLINK-21097 URL: https://issues.apache.org/jira/browse/FLINK-21097 Project: Flink Issue Type:

[jira] [Created] (FLINK-21096) Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph

2021-01-22 Thread godfrey he (Jira)
godfrey he created FLINK-21096: -- Summary: Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph Key: FLINK-21096 URL:

[jira] [Created] (FLINK-21094) Support StreamExecSink json serialization/deserialization

2021-01-22 Thread godfrey he (Jira)
godfrey he created FLINK-21094: -- Summary: Support StreamExecSink json serialization/deserialization Key: FLINK-21094 URL: https://issues.apache.org/jira/browse/FLINK-21094 Project: Flink Issue

[jira] [Created] (FLINK-21093) Support StreamExecTableSource json serialization/deserialization

2021-01-21 Thread godfrey he (Jira)
godfrey he created FLINK-21093: -- Summary: Support StreamExecTableSource json serialization/deserialization Key: FLINK-21093 URL: https://issues.apache.org/jira/browse/FLINK-21093 Project: Flink

[jira] [Created] (FLINK-21092) Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal

2021-01-21 Thread godfrey he (Jira)
godfrey he created FLINK-21092: -- Summary: Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal Key: FLINK-21092 URL: https://issues.apache.org/jira/browse/FLINK-21092

[jira] [Created] (FLINK-21091) Support ExecNode json serialization/deserialization

2021-01-21 Thread godfrey he (Jira)
godfrey he created FLINK-21091: -- Summary: Support ExecNode json serialization/deserialization Key: FLINK-21091 URL: https://issues.apache.org/jira/browse/FLINK-21091 Project: Flink Issue Type:

[jira] [Created] (FLINK-21041) Introduce ExecNodeGraph to wrap the ExecNode topology

2021-01-19 Thread godfrey he (Jira)
godfrey he created FLINK-21041: -- Summary: Introduce ExecNodeGraph to wrap the ExecNode topology Key: FLINK-21041 URL: https://issues.apache.org/jira/browse/FLINK-21041 Project: Flink Issue

[jira] [Created] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-14 Thread godfrey he (Jira)
godfrey he created FLINK-20989: -- Summary: Functions in ExplodeFunctionUtil should handle null data to avoid NPE Key: FLINK-20989 URL: https://issues.apache.org/jira/browse/FLINK-20989 Project: Flink

[jira] [Created] (FLINK-20968) Remove legacy exec nodes

2021-01-14 Thread godfrey he (Jira)
godfrey he created FLINK-20968: -- Summary: Remove legacy exec nodes Key: FLINK-20968 URL: https://issues.apache.org/jira/browse/FLINK-20968 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20966) Rename StreamExecIntermediateTableScan to StreamPhysicalIntermediateTableScan

2021-01-13 Thread godfrey he (Jira)
godfrey he created FLINK-20966: -- Summary: Rename StreamExecIntermediateTableScan to StreamPhysicalIntermediateTableScan Key: FLINK-20966 URL: https://issues.apache.org/jira/browse/FLINK-20966 Project:

[jira] [Created] (FLINK-20949) Separate the implementation of sink nodes

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20949: -- Summary: Separate the implementation of sink nodes Key: FLINK-20949 URL: https://issues.apache.org/jira/browse/FLINK-20949 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20948) Separate the implementation of StreamExecDeduplicate

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20948: -- Summary: Separate the implementation of StreamExecDeduplicate Key: FLINK-20948 URL: https://issues.apache.org/jira/browse/FLINK-20948 Project: Flink Issue Type:

[jira] [Created] (FLINK-20941) Separate the implementation of StreamExecMatch

2021-01-12 Thread godfrey he (Jira)
godfrey he created FLINK-20941: -- Summary: Separate the implementation of StreamExecMatch Key: FLINK-20941 URL: https://issues.apache.org/jira/browse/FLINK-20941 Project: Flink Issue Type:

[jira] [Created] (FLINK-20924) Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java

2021-01-11 Thread godfrey he (Jira)
godfrey he created FLINK-20924: -- Summary: Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java Key: FLINK-20924 URL: https://issues.apache.org/jira/browse/FLINK-20924 Project:

[jira] [Created] (FLINK-20899) encounter ClassCastException when calculating cost in HepPlanner

2021-01-08 Thread godfrey he (Jira)
godfrey he created FLINK-20899: -- Summary: encounter ClassCastException when calculating cost in HepPlanner Key: FLINK-20899 URL: https://issues.apache.org/jira/browse/FLINK-20899 Project: Flink

[jira] [Created] (FLINK-20883) Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate

2021-01-07 Thread godfrey he (Jira)
godfrey he created FLINK-20883: -- Summary: Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate Key: FLINK-20883 URL: https://issues.apache.org/jira/browse/FLINK-20883

[jira] [Created] (FLINK-20879) Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-07 Thread godfrey he (Jira)
godfrey he created FLINK-20879: -- Summary: Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions Key: FLINK-20879 URL: https://issues.apache.org/jira/browse/FLINK-20879

[jira] [Created] (FLINK-20857) Separate the implementation of batch window aggregate nodes

2021-01-05 Thread godfrey he (Jira)
godfrey he created FLINK-20857: -- Summary: Separate the implementation of batch window aggregate nodes Key: FLINK-20857 URL: https://issues.apache.org/jira/browse/FLINK-20857 Project: Flink

[jira] [Created] (FLINK-20858) Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java

2021-01-05 Thread godfrey he (Jira)
godfrey he created FLINK-20858: -- Summary: Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java Key: FLINK-20858 URL: https://issues.apache.org/jira/browse/FLINK-20858

[jira] [Created] (FLINK-20856) Separate the implementation of stream window aggregate nodes

2021-01-05 Thread godfrey he (Jira)
godfrey he created FLINK-20856: -- Summary: Separate the implementation of stream window aggregate nodes Key: FLINK-20856 URL: https://issues.apache.org/jira/browse/FLINK-20856 Project: Flink

[jira] [Created] (FLINK-20821) `select row(map[1,2],'ab')` parses failed

2020-12-30 Thread godfrey he (Jira)
godfrey he created FLINK-20821: -- Summary: `select row(map[1,2],'ab')` parses failed Key: FLINK-20821 URL: https://issues.apache.org/jira/browse/FLINK-20821 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20751) Port batch python aggregate nodes to Java

2020-12-23 Thread godfrey he (Jira)
godfrey he created FLINK-20751: -- Summary: Port batch python aggregate nodes to Java Key: FLINK-20751 URL: https://issues.apache.org/jira/browse/FLINK-20751 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20750) Port stream python aggregate nodes to Java

2020-12-23 Thread godfrey he (Jira)
godfrey he created FLINK-20750: -- Summary: Port stream python aggregate nodes to Java Key: FLINK-20750 URL: https://issues.apache.org/jira/browse/FLINK-20750 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20738) Separate the implementation of batch aggregate nodes

2020-12-22 Thread godfrey he (Jira)
godfrey he created FLINK-20738: -- Summary: Separate the implementation of batch aggregate nodes Key: FLINK-20738 URL: https://issues.apache.org/jira/browse/FLINK-20738 Project: Flink Issue Type:

[jira] [Created] (FLINK-20737) Separate the implementation of stream aggregate nodes

2020-12-22 Thread godfrey he (Jira)
godfrey he created FLINK-20737: -- Summary: Separate the implementation of stream aggregate nodes Key: FLINK-20737 URL: https://issues.apache.org/jira/browse/FLINK-20737 Project: Flink Issue

[jira] [Created] (FLINK-20719) Change BatchExecNode & StreamExecNode to interface and make each node extended from ExecNodeBase directly

2020-12-22 Thread godfrey he (Jira)
godfrey he created FLINK-20719: -- Summary: Change BatchExecNode & StreamExecNode to interface and make each node extended from ExecNodeBase directly Key: FLINK-20719 URL:

[jira] [Created] (FLINK-20709) Separate the implementation of StreamExecMiniBatchAssigner

2020-12-21 Thread godfrey he (Jira)
godfrey he created FLINK-20709: -- Summary: Separate the implementation of StreamExecMiniBatchAssigner Key: FLINK-20709 URL: https://issues.apache.org/jira/browse/FLINK-20709 Project: Flink Issue

[jira] [Created] (FLINK-20708) Separate the implementation of StreamExecDropUpdateBefore

2020-12-21 Thread godfrey he (Jira)
godfrey he created FLINK-20708: -- Summary: Separate the implementation of StreamExecDropUpdateBefore Key: FLINK-20708 URL: https://issues.apache.org/jira/browse/FLINK-20708 Project: Flink Issue

[jira] [Created] (FLINK-20707) Separate the implementation of BatchExecExpand and StreamExecExpand

2020-12-21 Thread godfrey he (Jira)
godfrey he created FLINK-20707: -- Summary: Separate the implementation of BatchExecExpand and StreamExecExpand Key: FLINK-20707 URL: https://issues.apache.org/jira/browse/FLINK-20707 Project: Flink

[jira] [Created] (FLINK-20706) Separate the implementation of BatchExecUnion and StreamExecUnion

2020-12-21 Thread godfrey he (Jira)
godfrey he created FLINK-20706: -- Summary: Separate the implementation of BatchExecUnion and StreamExecUnion Key: FLINK-20706 URL: https://issues.apache.org/jira/browse/FLINK-20706 Project: Flink

  1   2   3   >