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
godfrey he created FLINK-29981:
--
Summary: Improve WatermarkAssignerChangelogNormalizeTransposeRule
Key: FLINK-29981
URL: https://issues.apache.org/jira/browse/FLINK-29981
Project: Flink
Issue Ty
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
godfrey he created FLINK-20858:
--
Summary: Port StreamExecPythonGroupWindowAggregate and
BatchExecPythonGroupWindowAggregate to Java
Key: FLINK-20858
URL: https://issues.apache.org/jira/browse/FLINK-20858
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
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
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
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
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
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
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:
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
godfrey he created FLINK-20966:
--
Summary: Rename StreamExecIntermediateTableScan to
StreamPhysicalIntermediateTableScan
Key: FLINK-20966
URL: https://issues.apache.org/jira/browse/FLINK-20966
Project: Fl
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
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
godfrey he created FLINK-21791:
--
Summary: Support StreamExecLocalGroupAggregate and
StreamExecGlobalGroupAggregate json serialization/deserialization
Key: FLINK-21791
URL: https://issues.apache.org/jira/browse/FLINK-
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
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
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
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
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
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
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
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
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
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
201 - 280 of 280 matches
Mail list logo