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:
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
godfrey he created FLINK-29981:
--
Summary: Improve WatermarkAssignerChangelogNormalizeTransposeRule
Key: FLINK-29981
URL: https://issues.apache.org/jira/browse/FLINK-29981
Project: Flink
Issue
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:
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
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:
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:
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:
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:
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
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:
godfrey he created FLINK-28726:
--
Summary: CompileException: BoundedOverAggregateHelper must
implement method AggsHandeFunction.setWindowSize(int)
Key: FLINK-28726
URL:
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
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
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
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:
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:
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
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:
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
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
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:
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
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
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
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:
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
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
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
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
godfrey he created FLINK-27985:
--
Summary: Introduce FlinkRecomputeStatisticsProgram to compute
statistics after filter push and partition pruning
Key: FLINK-27985
URL:
godfrey he created FLINK-27984:
--
Summary: Introduce FileBasedStatisticsReportableDecodingFormat
interface
Key: FLINK-27984
URL: https://issues.apache.org/jira/browse/FLINK-27984
Project: Flink
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:
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
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
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:
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
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
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
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
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
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:
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
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
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
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:
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
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
godfrey he created FLINK-23094:
--
Summary: encounter thread-safe problem when using
StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads
environment
Key: FLINK-23094
URL:
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
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
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
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-21890:
--
Summary: Rename DAGProcessor to ExecNodeGraphProcessor
Key: FLINK-21890
URL: https://issues.apache.org/jira/browse/FLINK-21890
Project: Flink
Issue Type:
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-21861:
--
Summary: Support StreamExecIncrementalGroupAggregate json
serialization/deserialization
Key: FLINK-21861
URL: https://issues.apache.org/jira/browse/FLINK-21861
Project:
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
godfrey he created FLINK-21791:
--
Summary: Support StreamExecLocalGroupAggregate and
StreamExecGlobalGroupAggregate json serialization/deserialization
Key: FLINK-21791
URL:
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-21730:
--
Summary: Introduce ExecNodeTranslator
Key: FLINK-21730
URL: https://issues.apache.org/jira/browse/FLINK-21730
Project: Flink
Issue Type: Sub-task
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:
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-21646:
--
Summary: Support json serialization/deserialization for the states
in StreamExecGroupAggregate
Key: FLINK-21646
URL: https://issues.apache.org/jira/browse/FLINK-21646
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
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-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-21245:
--
Summary: Support StreamExecCalc json serialization/deserialization
Key: FLINK-21245
URL: https://issues.apache.org/jira/browse/FLINK-21245
Project: Flink
Issue
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-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-21105:
--
Summary: Rename ExecEdge to InputProperty
Key: FLINK-21105
URL: https://issues.apache.org/jira/browse/FLINK-21105
Project: Flink
Issue Type: Sub-task
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:
godfrey he created FLINK-21096:
--
Summary: Introduce ExecNodeGraphJsonPlanGenerator to serialize
ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph
Key: FLINK-21096
URL:
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
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-21092:
--
Summary: Introduce getJsonPlan, explainJsonPlan and
executeJsonPlan in TableEnvironmentInternal
Key: FLINK-21092
URL: https://issues.apache.org/jira/browse/FLINK-21092
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:
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
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-20968:
--
Summary: Remove legacy exec nodes
Key: FLINK-20968
URL: https://issues.apache.org/jira/browse/FLINK-20968
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:
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-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-20941:
--
Summary: Separate the implementation of StreamExecMatch
Key: FLINK-20941
URL: https://issues.apache.org/jira/browse/FLINK-20941
Project: Flink
Issue Type:
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:
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-20883:
--
Summary: Separate the implementation of BatchExecOverAggregate and
StreamExecOverAggregate
Key: FLINK-20883
URL: https://issues.apache.org/jira/browse/FLINK-20883
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-20857:
--
Summary: Separate the implementation of batch window aggregate
nodes
Key: FLINK-20857
URL: https://issues.apache.org/jira/browse/FLINK-20857
Project: Flink
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-20856:
--
Summary: Separate the implementation of stream window aggregate
nodes
Key: FLINK-20856
URL: https://issues.apache.org/jira/browse/FLINK-20856
Project: Flink
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-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-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-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-20737:
--
Summary: Separate the implementation of stream aggregate nodes
Key: FLINK-20737
URL: https://issues.apache.org/jira/browse/FLINK-20737
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:
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-20708:
--
Summary: Separate the implementation of StreamExecDropUpdateBefore
Key: FLINK-20708
URL: https://issues.apache.org/jira/browse/FLINK-20708
Project: Flink
Issue
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-20706:
--
Summary: Separate the implementation of BatchExecUnion and
StreamExecUnion
Key: FLINK-20706
URL: https://issues.apache.org/jira/browse/FLINK-20706
Project: Flink
1 - 100 of 276 matches
Mail list logo