godfrey he created FLINK-14656:
--
Summary: blink planner should convert catalog statistics to
TableStats for permanent table instead of temporary table
Key: FLINK-14656
URL: https://issues.apache.org/jira/browse/FLINK
godfrey he created FLINK-14724:
--
Summary: Join condition could be simplified in logical phase
Key: FLINK-14724
URL: https://issues.apache.org/jira/browse/FLINK-14724
Project: Flink
Issue Type: S
godfrey he created FLINK-14789:
--
Summary: extends max/min type in ColumnStats from Number to
Comparable
Key: FLINK-14789
URL: https://issues.apache.org/jira/browse/FLINK-14789
Project: Flink
Is
godfrey he created FLINK-14874:
--
Summary: add local aggregate to solve data skew for ROLLUP/CUBE
case
Key: FLINK-14874
URL: https://issues.apache.org/jira/browse/FLINK-14874
Project: Flink
Issu
godfrey he created FLINK-14899:
--
Summary: can not be translated to StreamExecDeduplicate when
PROCTIME is defined in query
Key: FLINK-14899
URL: https://issues.apache.org/jira/browse/FLINK-14899
Project:
godfrey he created FLINK-14999:
--
Summary: sub-plan reuse should consider
Key: FLINK-14999
URL: https://issues.apache.org/jira/browse/FLINK-14999
Project: Flink
Issue Type: Bug
Report
godfrey he created FLINK-15001:
--
Summary: The digest of sub-plan reuse should contain RelNode's
trait
Key: FLINK-15001
URL: https://issues.apache.org/jira/browse/FLINK-15001
Project: Flink
Issu
godfrey he created FLINK-15004:
--
Summary: Choose SortMergeJoin instead of HashJoin if the
statistics is unknown
Key: FLINK-15004
URL: https://issues.apache.org/jira/browse/FLINK-15004
Project: Flink
godfrey he created FLINK-15095:
--
Summary: bridge table schema's primary key to metadata handler in
blink planner
Key: FLINK-15095
URL: https://issues.apache.org/jira/browse/FLINK-15095
Project: Flink
godfrey he created FLINK-15123:
--
Summary: remove uniqueKeys from FlinkStatistic in blink planner
Key: FLINK-15123
URL: https://issues.apache.org/jira/browse/FLINK-15123
Project: Flink
Issue Typ
godfrey he created FLINK-12018:
--
Summary: Add support for generating optimized logical plan for
Sort and Rank
Key: FLINK-12018
URL: https://issues.apache.org/jira/browse/FLINK-12018
Project: Flink
godfrey he created FLINK-12076:
--
Summary: Add support for generating optimized logical plan for
batch simple group aggregate
Key: FLINK-12076
URL: https://issues.apache.org/jira/browse/FLINK-12076
Projec
godfrey he created FLINK-12079:
--
Summary: Add support for generating optimized logical plan for
join on batch
Key: FLINK-12079
URL: https://issues.apache.org/jira/browse/FLINK-12079
Project: Flink
godfrey he created FLINK-12098:
--
Summary: Add support for generating optimized logical plan for
simple group aggregate on batch
Key: FLINK-12098
URL: https://issues.apache.org/jira/browse/FLINK-12098
Pro
godfrey he created FLINK-12161:
--
Summary: Supports partial-final optimization for stream group
aggregate
Key: FLINK-12161
URL: https://issues.apache.org/jira/browse/FLINK-12161
Project: Flink
godfrey he created FLINK-12170:
--
Summary: Add support for generating optimized logical plan for
Over aggregate
Key: FLINK-12170
URL: https://issues.apache.org/jira/browse/FLINK-12170
Project: Flink
godfrey he created FLINK-12185:
--
Summary: Add support for generating optimized logical plan for
join on stream
Key: FLINK-12185
URL: https://issues.apache.org/jira/browse/FLINK-12185
Project: Flink
godfrey he created FLINK-12192:
--
Summary: Add support for generating optimized logical plan for
grouping sets and distinct aggregate
Key: FLINK-12192
URL: https://issues.apache.org/jira/browse/FLINK-12192
godfrey he created FLINK-12282:
--
Summary: re-estimate row count for batch global Rank operator
Key: FLINK-12282
URL: https://issues.apache.org/jira/browse/FLINK-12282
Project: Flink
Issue Type:
godfrey he created FLINK-12295:
--
Summary: use retract aggregate function instead of regular
aggregate function for retractable aggregate in code gen
Key: FLINK-12295
URL: https://issues.apache.org/jira/browse/FLINK-1
godfrey he created FLINK-12321:
--
Summary: Supports sub-plan reuse
Key: FLINK-12321
URL: https://issues.apache.org/jira/browse/FLINK-12321
Project: Flink
Issue Type: Bug
Components: Tab
godfrey he created FLINK-12345:
--
Summary: Add support for generating optimized logical plan for
stream window aggregate
Key: FLINK-12345
URL: https://issues.apache.org/jira/browse/FLINK-12345
Project: Fl
godfrey he created FLINK-12371:
--
Summary: Add support for converting (NOT) IN/ (NOT) EXISTS to
SemiJoin, and generating optimized logical plan
Key: FLINK-12371
URL: https://issues.apache.org/jira/browse/FLINK-12371
godfrey he created FLINK-12424:
--
Summary: Supports dag (multiple-sinks query) optimization
Key: FLINK-12424
URL: https://issues.apache.org/jira/browse/FLINK-12424
Project: Flink
Issue Type: New
godfrey he created FLINK-12487:
--
Summary: Introduce planner rules to rewrite expression and merge
calc
Key: FLINK-12487
URL: https://issues.apache.org/jira/browse/FLINK-12487
Project: Flink
Iss
godfrey he created FLINK-12509:
--
Summary: Introduce planner rules about non semi/anti join
Key: FLINK-12509
URL: https://issues.apache.org/jira/browse/FLINK-12509
Project: Flink
Issue Type: New
godfrey he created FLINK-12519:
--
Summary: Introduce planner rules about semi/anti join
Key: FLINK-12519
URL: https://issues.apache.org/jira/browse/FLINK-12519
Project: Flink
Issue Type: New Feat
godfrey he created FLINK-12524:
--
Summary: Introduce planner rules about rank
Key: FLINK-12524
URL: https://issues.apache.org/jira/browse/FLINK-12524
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12559:
--
Summary: Introduce metadata handlers on window aggregate
Key: FLINK-12559
URL: https://issues.apache.org/jira/browse/FLINK-12559
Project: Flink
Issue Type: New F
godfrey he created FLINK-12575:
--
Summary: Introduce planner rules to remove redundant shuffle and
collation
Key: FLINK-12575
URL: https://issues.apache.org/jira/browse/FLINK-12575
Project: Flink
godfrey he created FLINK-12600:
--
Summary: Introduce planner rules to do deterministic rewriting on
RelNode
Key: FLINK-12600
URL: https://issues.apache.org/jira/browse/FLINK-12600
Project: Flink
godfrey he created FLINK-12610:
--
Summary: Introduce planner rules about aggregate
Key: FLINK-12610
URL: https://issues.apache.org/jira/browse/FLINK-12610
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12665:
--
Summary: Introduce MiniBatchIntervalInferRule and watermark
assigner operators
Key: FLINK-12665
URL: https://issues.apache.org/jira/browse/FLINK-12665
Project: Flink
godfrey he created FLINK-12685:
--
Summary: Supports UNNEST query in blink planner
Key: FLINK-12685
URL: https://issues.apache.org/jira/browse/FLINK-12685
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-12703:
--
Summary: Introduce metadata handlers on SEMI/ATNI join and look up
join
Key: FLINK-12703
URL: https://issues.apache.org/jira/browse/FLINK-12703
Project: Flink
I
godfrey he created FLINK-12734:
--
Summary: remove getVolcanoPlanner method from FlinkOptimizeContext
and RelNodeBlock does not depend on TableEnvironment
Key: FLINK-12734
URL: https://issues.apache.org/jira/browse/FLI
godfrey he created FLINK-12795:
--
Summary: Extracted creation & configuration of FrameworkConfig &
RelBuilder to separate class in blink planner
Key: FLINK-12795
URL: https://issues.apache.org/jira/browse/FLINK-12795
godfrey he created FLINK-12815:
--
Summary: Supports CatalogManager in blink planner
Key: FLINK-12815
URL: https://issues.apache.org/jira/browse/FLINK-12815
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-12856:
--
Summary: Introduce planner rule to push projection into
ProjectableTableSource
Key: FLINK-12856
URL: https://issues.apache.org/jira/browse/FLINK-12856
Project: Flink
godfrey he created FLINK-12857:
--
Summary: move FilterableTableSource into flink-table-common
Key: FLINK-12857
URL: https://issues.apache.org/jira/browse/FLINK-12857
Project: Flink
Issue Type: Im
godfrey he created FLINK-12878:
--
Summary: Add travis profile for
flink-table-planner-blink/flink-table-runtime-blink
Key: FLINK-12878
URL: https://issues.apache.org/jira/browse/FLINK-12878
Project: Flink
godfrey he created FLINK-12888:
--
Summary: Introduce planner rule to push filter into TableSource
Key: FLINK-12888
URL: https://issues.apache.org/jira/browse/FLINK-12888
Project: Flink
Issue Type
godfrey he created FLINK-12937:
--
Summary: Introduce join reorder planner rules in blink planner
Key: FLINK-12937
URL: https://issues.apache.org/jira/browse/FLINK-12937
Project: Flink
Issue Type:
godfrey he created FLINK-12969:
--
Summary: Remove dependencies on RelNode from TableImpl in blink
planner
Key: FLINK-12969
URL: https://issues.apache.org/jira/browse/FLINK-12969
Project: Flink
I
godfrey he created FLINK-13030:
--
Summary: add more test case for blink planner
Key: FLINK-13030
URL: https://issues.apache.org/jira/browse/FLINK-13030
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-13076:
--
Summary: Bump Calcite dependency to 1.20.0 in blink planner
Key: FLINK-13076
URL: https://issues.apache.org/jira/browse/FLINK-13076
Project: Flink
Issue Type: Im
godfrey he created FLINK-13081:
--
Summary: Supports explain and execute DAG plan
Key: FLINK-13081
URL: https://issues.apache.org/jira/browse/FLINK-13081
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-13088:
--
Summary: Supports execute DAG plan
Key: FLINK-13088
URL: https://issues.apache.org/jira/browse/FLINK-13088
Project: Flink
Issue Type: New Feature
Compo
godfrey he created FLINK-13114:
--
Summary: adapt blink planner to new unified TableEnvironment
Key: FLINK-13114
URL: https://issues.apache.org/jira/browse/FLINK-13114
Project: Flink
Issue Type: N
godfrey he created FLINK-13115:
--
Summary: Introduce planner rule to support partition pruning for
PartitionableTableSource
Key: FLINK-13115
URL: https://issues.apache.org/jira/browse/FLINK-13115
Project:
godfrey he created FLINK-13116:
--
Summary: supports catalog statistic in blink planner
Key: FLINK-13116
URL: https://issues.apache.org/jira/browse/FLINK-13116
Project: Flink
Issue Type: New Feat
godfrey he created FLINK-13168:
--
Summary: clarify isBatch/isStreaming/isBounded flag in flink
planner and blink planner
Key: FLINK-13168
URL: https://issues.apache.org/jira/browse/FLINK-13168
Project: Fl
godfrey he created FLINK-13185:
--
Summary: Bump Calcite dependency to 1.20.0 in sql parser & flink
planner
Key: FLINK-13185
URL: https://issues.apache.org/jira/browse/FLINK-13185
Project: Flink
godfrey he created FLINK-13263:
--
Summary: supports explain DAG plan in flink-python
Key: FLINK-13263
URL: https://issues.apache.org/jira/browse/FLINK-13263
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-13268:
--
Summary: revert SqlSplittableAggFunction to make two planners
available in one jar
Key: FLINK-13268
URL: https://issues.apache.org/jira/browse/FLINK-13268
Project: Flink
godfrey he created FLINK-13269:
--
Summary: copy RelDecorrelator from blink planner to flink planner
to fix CALCITE-3169 & CALCITE-3170
Key: FLINK-13269
URL: https://issues.apache.org/jira/browse/FLINK-13269
godfrey he created FLINK-13347:
--
Summary: should handle new JoinRelType(SEMI/ANTI) in switch case
Key: FLINK-13347
URL: https://issues.apache.org/jira/browse/FLINK-13347
Project: Flink
Issue Typ
godfrey he created FLINK-13403:
--
Summary: Correct package name after relocation
Key: FLINK-13403
URL: https://issues.apache.org/jira/browse/FLINK-13403
Project: Flink
Issue Type: Bug
C
godfrey he created FLINK-13404:
--
Summary: Port csv factories & validator from flink-table-planner
to flink-csv
Key: FLINK-13404
URL: https://issues.apache.org/jira/browse/FLINK-13404
Project: Flink
godfrey he created FLINK-13502:
--
Summary: CatalogTableStatisticsConverter should be in
planner.utils package
Key: FLINK-13502
URL: https://issues.apache.org/jira/browse/FLINK-13502
Project: Flink
godfrey he created FLINK-13545:
--
Summary: JoinToMultiJoinRule should not match SEMI/ANTI LogicalJoin
Key: FLINK-13545
URL: https://issues.apache.org/jira/browse/FLINK-13545
Project: Flink
Issue
godfrey he created FLINK-13562:
--
Summary: throws exception when FlinkRelMdColumnInterval meets two
stage stream group aggregate
Key: FLINK-13562
URL: https://issues.apache.org/jira/browse/FLINK-13562
Pro
godfrey he created FLINK-13563:
--
Summary: TumblingGroupWindow should implement toString method
Key: FLINK-13563
URL: https://issues.apache.org/jira/browse/FLINK-13563
Project: Flink
Issue Type:
godfrey he created FLINK-13564:
--
Summary: blink planner should also throw exception if constant
with YEAR TO MONTH resolution was used for group windows
Key: FLINK-13564
URL: https://issues.apache.org/jira/browse/FL
godfrey he created FLINK-13611:
--
Summary: Introduce analyze statistic utility to generate table &
column statistics
Key: FLINK-13611
URL: https://issues.apache.org/jira/browse/FLINK-13611
Project: Flink
godfrey he created FLINK-13708:
--
Summary: transformations should be cleared because a table
environment could execute multiple job
Key: FLINK-13708
URL: https://issues.apache.org/jira/browse/FLINK-13708
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
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
Pr
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-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-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-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 Fea
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-27983:
--
Summary: Introduce SupportsStatisticsReport interface
Key: FLINK-27983
URL: https://issues.apache.org/jira/browse/FLINK-27983
Project: Flink
Issue Type: Sub-task
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-27985:
--
Summary: Introduce FlinkRecomputeStatisticsProgram to compute
statistics after filter push and partition pruning
Key: FLINK-27985
URL: https://issues.apache.org/jira/browse/FLINK-2798
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
Is
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 Typ
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-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-27990:
--
Summary: Parquet format supports reporting statistics
Key: FLINK-27990
URL: https://issues.apache.org/jira/browse/FLINK-27990
Project: Flink
Issue Type: Sub-task
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-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-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 Featur
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: Sub-ta
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-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-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: Sub-t
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 Fea
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: S
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: Sub-t
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-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-28711:
--
Summary: Hive connector implements SupportsDynamicFiltering
interface
Key: FLINK-28711
URL: https://issues.apache.org/jira/browse/FLINK-28711
Project: Flink
Iss
godfrey he created FLINK-28726:
--
Summary: CompileException: BoundedOverAggregateHelper must
implement method AggsHandeFunction.setWindowSize(int)
Key: FLINK-28726
URL: https://issues.apache.org/jira/browse/FLINK-2872
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: Flink
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
Issu
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: Flink
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: Sub
1 - 100 of 280 matches
Mail list logo