[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: Sub-ta

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

[jira] [Created] (FLINK-20255) Nested decorrelate failed

2020-11-19 Thread godfrey he (Jira)
godfrey he created FLINK-20255: -- Summary: Nested decorrelate failed Key: FLINK-20255 URL: https://issues.apache.org/jira/browse/FLINK-20255 Project: Flink Issue Type: Bug Components: T

[jira] [Created] (FLINK-20293) Remove the useless constructor of ContinuousFileMonitoringFunction

2020-11-23 Thread godfrey he (Jira)
godfrey he created FLINK-20293: -- Summary: Remove the useless constructor of ContinuousFileMonitoringFunction Key: FLINK-20293 URL: https://issues.apache.org/jira/browse/FLINK-20293 Project: Flink

[jira] [Created] (FLINK-20322) Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint.enabled

2020-11-24 Thread godfrey he (Jira)
godfrey he created FLINK-20322: -- Summary: Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint.enabled Key: FLINK-20322 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-20435) Refactor ExecNode

2020-11-30 Thread godfrey he (Jira)
godfrey he created FLINK-20435: -- Summary: Refactor ExecNode Key: FLINK-20435 URL: https://issues.apache.org/jira/browse/FLINK-20435 Project: Flink Issue Type: Improvement Reporter: g

[jira] [Created] (FLINK-20436) Simplify type parameter of ExecNod

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20436: -- Summary: Simplify type parameter of ExecNod Key: FLINK-20436 URL: https://issues.apache.org/jira/browse/FLINK-20436 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20437) Port ExecNode to Java

2020-12-01 Thread godfrey he (Jira)
godfrey he created FLINK-20437: -- Summary: Port ExecNode to Java Key: FLINK-20437 URL: https://issues.apache.org/jira/browse/FLINK-20437 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-20478) Show "Optimized Execution Plan" instead of "Physical Execution Plan" in explain result

2020-12-03 Thread godfrey he (Jira)
godfrey he created FLINK-20478: -- Summary: Show "Optimized Execution Plan" instead of "Physical Execution Plan" in explain result Key: FLINK-20478 URL: https://issues.apache.org/jira/browse/FLINK-20478 Pr

[jira] [Created] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode

2020-12-04 Thread godfrey he (Jira)
godfrey he created FLINK-20490: -- Summary: Don't share inputs between FlinkPhysicalRel and ExecNode Key: FLINK-20490 URL: https://issues.apache.org/jira/browse/FLINK-20490 Project: Flink Issue Ty

[jira] [Created] (FLINK-20509) Refactor verifyPlan method in TableTestBase

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20509: -- Summary: Refactor verifyPlan method in TableTestBase Key: FLINK-20509 URL: https://issues.apache.org/jira/browse/FLINK-20509 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20511) Deprecate the classes in scala `nodes.exec` package

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20511: -- Summary: Deprecate the classes in scala `nodes.exec` package Key: FLINK-20511 URL: https://issues.apache.org/jira/browse/FLINK-20511 Project: Flink Issue Type: S

[jira] [Created] (FLINK-20512) Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20512: -- Summary: Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode Key: FLINK-20512 URL: https://issues.apache.org/jira/browse/FLINK-20512 Project: F

[jira] [Created] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20513: -- Summary: Separate the implementation of BatchExecExchange and StreamExecExchange Key: FLINK-20513 URL: https://issues.apache.org/jira/browse/FLINK-20513 Project: Flink

[jira] [Created] (FLINK-20515) Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20515: -- Summary: Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput Key: FLINK-20515 URL: https://issues.apache.org/jira/browse/FLINK-20515 Project

[jira] [Created] (FLINK-20516) Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20516: -- Summary: Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan Key: FLINK-20516 URL: https://issues.apache.org/jira/browse/FLINK-20516 Pro

[jira] [Created] (FLINK-20608) Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20608: -- Summary: Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan Key: FLINK-20608 URL: https://issues.apache.org/jira/browse/FLINK-20608

[jira] [Created] (FLINK-20609) Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20609: -- Summary: Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan Key: FLINK-20609 URL: https://issues.apache.org/jira/browse/FLINK-20609 Proje

[jira] [Created] (FLINK-20610) Separate the implementation of BatchExecCalc and StreamExecCalc

2020-12-15 Thread godfrey he (Jira)
godfrey he created FLINK-20610: -- Summary: Separate the implementation of BatchExecCalc and StreamExecCalc Key: FLINK-20610 URL: https://issues.apache.org/jira/browse/FLINK-20610 Project: Flink

[jira] [Created] (FLINK-20620) Port StreamExecPythonCalc to java

2020-12-16 Thread godfrey he (Jira)
godfrey he created FLINK-20620: -- Summary: Port StreamExecPythonCalc to java Key: FLINK-20620 URL: https://issues.apache.org/jira/browse/FLINK-20620 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20622) Separate the implementation of StreamExecChangelogNormalize

2020-12-16 Thread godfrey he (Jira)
godfrey he created FLINK-20622: -- Summary: Separate the implementation of StreamExecChangelogNormalize Key: FLINK-20622 URL: https://issues.apache.org/jira/browse/FLINK-20622 Project: Flink Issu

[jira] [Created] (FLINK-20623) Separate the implementation of StreamExecWatermarkAssigner

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

[jira] [Created] (FLINK-20668) Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread godfrey he (Jira)
godfrey he created FLINK-20668: -- Summary: Introduce translateToExecNode method for FlinkPhysicalRel Key: FLINK-20668 URL: https://issues.apache.org/jira/browse/FLINK-20668 Project: Flink Issue T

[jira] [Created] (FLINK-20673) ExecNode#getOutputType method should return LogicalType instead of RowType

2020-12-18 Thread godfrey he (Jira)
godfrey he created FLINK-20673: -- Summary: ExecNode#getOutputType method should return LogicalType instead of RowType Key: FLINK-20673 URL: https://issues.apache.org/jira/browse/FLINK-20673 Project: Flink

[jira] [Created] (FLINK-20690) Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

2020-12-20 Thread godfrey he (Jira)
godfrey he created FLINK-20690: -- Summary: Separate the implementation of BatchExecCorrelate and StreamExecCorrelate Key: FLINK-20690 URL: https://issues.apache.org/jira/browse/FLINK-20690 Project: Flink

[jira] [Created] (FLINK-20693) Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

2020-12-20 Thread godfrey he (Jira)
godfrey he created FLINK-20693: -- Summary: Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java Key: FLINK-20693 URL: https://issues.apache.org/jira/browse/FLINK-20693 Project: Flink

[jira] [Created] (FLINK-20705) Separate the implementation of BatchExecValues and StreamExecValues

2020-12-21 Thread godfrey he (Jira)
godfrey he created FLINK-20705: -- Summary: Separate the implementation of BatchExecValues and StreamExecValues Key: FLINK-20705 URL: https://issues.apache.org/jira/browse/FLINK-20705 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

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

[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-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: https://issues.apache.org/jira/browse/FLINK-20

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

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

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

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

[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: Sub-ta

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

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

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

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

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

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

[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: https://issues.apache.org/ji

[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: Sub-t

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

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

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

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

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

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

[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-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: https://issues.apache.org/jira/browse/FLINK-

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

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

[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-21890) Rename DAGProcessor to ExecNodeGraphProcessor

2021-03-20 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: Improve

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

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

[jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg

2021-04-25 Thread godfrey he (Jira)
godfrey he created FLINK-22463: -- Summary: IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg Key: FLINK-22463 URL: https://issues.apache.org/jira/browse/F

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

2023-04-10 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 Ty

[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: Sub-ta

<    1   2   3