[flink] branch master updated (d938c19 -> b0a9afd)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from d938c19  [FLINK-14593][client] Port ClusterClient to asynchronous interface version
     add fe77fdc  [FLINK-14262][table] FunctionCatalog should return empty when can not get the catalog from catalog name
     add 0a5ae34  [FLINK-14262][table-planner-blink] Add getCatalogManager to FlinkContext
     add 1b4ebce  [FLINK-14262][table-planner-blink] support referencing function with fully/partially qualified names in blink
     add 8bd4b5c  [FLINK-14262][table] FunctionIdentifier shouldn't normalize function name and use un-escaped identifier as toString
     add b0a9afd  [hotfix][table] Avoid passing CatalogManager to FunctionCatalogOperatorTable

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/tests/test_aggregate.py |  3 +-
 flink-python/pyflink/table/tests/test_calc.py      | 14 +++---
 .../pyflink/table/tests/test_column_operation.py   |  8 +--
 flink-python/pyflink/table/tests/test_correlate.py |  2 +-
 flink-python/pyflink/table/tests/test_join.py      |  8 +--
 flink-python/pyflink/table/tests/test_sort.py      |  2 +-
 .../flink/table/catalog/FunctionCatalog.java       | 46 +++++++++--------
 .../apache/flink/table/catalog/FunctionLookup.java |  4 +-
 .../expressions/UnresolvedCallExpression.java      |  2 +-
 .../expressions/resolver/LookupCallResolver.java   |  4 +-
 .../flink/table/catalog/FunctionCatalogTest.java   | 26 ++++++----
 .../flink/table/expressions/CallExpression.java    |  2 +-
 .../flink/table/functions/FunctionIdentifier.java  | 58 ++++++++++++++--------
 .../catalog/FunctionCatalogOperatorTable.java      | 50 +++++++++----------
 .../table/planner/delegation/PlannerContext.java   | 24 +++++----
 .../planner/expressions/SqlAggFunctionVisitor.java |  9 +++-
 .../converter/ScalarFunctionConvertRule.java       |  5 +-
 .../functions/utils/HiveAggSqlFunction.java        |  8 +--
 .../functions/utils/HiveScalarSqlFunction.java     |  7 +--
 .../functions/utils/HiveTableSqlFunction.java      | 16 ++++--
 .../planner/plan/QueryOperationConverter.java      |  3 +-
 .../flink/table/planner/calcite/FlinkContext.scala |  7 ++-
 .../table/planner/calcite/FlinkContextImpl.scala   |  7 ++-
 .../table/planner/calcite/FlinkRelBuilder.scala    |  4 +-
 .../table/planner/delegation/PlannerBase.scala     |  3 +-
 .../planner/functions/utils/AggSqlFunction.scala   | 17 +++----
 .../functions/utils/ScalarSqlFunction.scala        | 15 +++---
 .../planner/functions/utils/TableSqlFunction.scala | 17 ++++---
 .../functions/utils/UserDefinedFunctionUtils.scala | 18 +++----
 .../BatchCommonSubGraphBasedOptimizer.scala        |  4 +-
 .../StreamCommonSubGraphBasedOptimizer.scala       |  4 +-
 .../plan/rules/logical/LogicalUnnestRule.scala     |  3 +-
 .../PushFilterIntoTableSourceScanRule.scala        |  5 +-
 .../planner/plan/utils/RexNodeExtractor.scala      | 29 +++++++----
 .../planner/plan/utils/SetOpRewriteUtil.scala      |  3 +-
 .../table/sqlexec/SqlToOperationConverterTest.java |  1 +
 .../table/planner/catalog/CatalogTableITCase.scala | 52 ++++++++++++++++++-
 .../metadata/AggCallSelectivityEstimatorTest.scala |  2 +-
 .../plan/metadata/FlinkRelMdHandlerTestBase.scala  | 17 +++++--
 .../plan/metadata/SelectivityEstimatorTest.scala   |  2 +-
 .../planner/plan/utils/PartitionPrunerTest.scala   |  8 ++-
 .../planner/plan/utils/RexNodeExtractorTest.scala  | 14 ++++--
 .../catalog/FunctionCatalogOperatorTable.java      |  3 +-
 .../table/plan/util/RexProgramExtractor.scala      |  6 +--
 .../flink/table/api/stream/sql/AggregateTest.scala |  8 +--
 45 files changed, 341 insertions(+), 209 deletions(-)