[flink] branch master updated (a9f72f9 -> ccb29e9)

[dw...@apache.org]

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

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


    from a9f72f9  [FLINK-16871][runtime] Make more build time information available at runtime
     add ccb29e9  [FLINK-16804] Deprecate all Table methods that accept expressions as a String

No new revisions were added by this update.

Summary of changes:
 .../flink/table/examples/java/WordCountSQL.java    |   4 +-
 .../flink/table/examples/java/WordCountTable.java  |   8 +-
 .../flink/table/examples/scala/WordCountSQL.scala  |   2 +-
 .../flink/table/runtime/batch/AvroTypesITCase.java |  12 +-
 .../ml/pipeline/UserDefinedPipelineStages.java     |   6 +-
 flink-python/dev/dev-requirements.txt              |   0
 flink-python/pyflink/table/table.py                |  12 +-
 .../client/python/PythonFunctionFactoryTest.java   |  18 +-
 .../PythonScalarFunctionOperatorTestBase.java      |   3 +-
 .../client/gateway/local/ExecutionContext.java     |  10 +-
 .../apache/flink/table/api/AggregatedTable.java    |  24 +-
 .../apache/flink/table/api/FlatAggregateTable.java |  24 +-
 .../apache/flink/table/api/GroupWindowedTable.java |  14 +-
 .../org/apache/flink/table/api/GroupedTable.java   |  54 ++-
 .../main/java/org/apache/flink/table/api/Over.java |   2 +
 .../flink/table/api/OverWindowPartitioned.java     |   2 +
 .../table/api/OverWindowPartitionedOrdered.java    |   2 +
 .../api/OverWindowPartitionedOrderedPreceding.java |   2 +
 .../apache/flink/table/api/OverWindowedTable.java  |  14 +
 .../java/org/apache/flink/table/api/Session.java   |   2 +
 .../org/apache/flink/table/api/SessionWithGap.java |   2 +
 .../java/org/apache/flink/table/api/Slide.java     |   2 +
 .../org/apache/flink/table/api/SlideWithSize.java  |   2 +
 .../flink/table/api/SlideWithSizeAndSlide.java     |   2 +
 .../java/org/apache/flink/table/api/Table.java     | 389 ++++++++++++++++++---
 .../java/org/apache/flink/table/api/Tumble.java    |   2 +
 .../org/apache/flink/table/api/TumbleWithSize.java |   2 +
 .../apache/flink/table/api/WindowGroupedTable.java |  34 ++
 .../apache/flink/table/api/internal/TableImpl.java |  16 +-
 .../planner/runtime/stream/table/ValuesITCase.java |   5 +-
 .../plan/batch/sql/join/TemporalJoinTest.scala     |   4 +-
 .../table/planner/plan/batch/table/CalcTest.scala  |   2 +-
 .../plan/batch/table/SetOperatorsTest.scala        |   2 +-
 .../plan/batch/table/TemporalTableJoinTest.scala   |   8 +-
 .../stringexpr/CalcStringExpressionTest.scala      |   2 +-
 .../batch/table/stringexpr/SetOperatorsTest.scala  |   6 +-
 .../table/validation/AggregateValidationTest.scala |  28 +-
 .../table/validation/CalcValidationTest.scala      |   8 +-
 .../table/validation/JoinValidationTest.scala      |   2 +-
 .../stream/sql/MiniBatchIntervalInferTest.scala    |   2 +-
 .../plan/stream/sql/join/TemporalJoinTest.scala    |   6 +-
 .../table/planner/plan/stream/table/CalcTest.scala |   4 +-
 .../plan/stream/table/ColumnFunctionsTest.scala    |   2 +-
 .../plan/stream/table/TableAggregateTest.scala     |   6 +-
 .../plan/stream/table/TableSourceTest.scala        |   8 +-
 .../plan/stream/table/TemporalTableJoinTest.scala  |  22 +-
 .../stringexpr/CorrelateStringExpressionTest.scala |  51 +--
 .../TableAggregateStringExpressionTest.scala       |   4 +-
 .../table/validation/AggregateValidationTest.scala |   2 +-
 .../table/validation/CalcValidationTest.scala      |   4 +-
 .../table/validation/CorrelateValidationTest.scala |   6 +-
 .../TemporalTableJoinValidationTest.scala          |   8 +-
 .../runtime/batch/table/CorrelateITCase.scala      |  32 +-
 .../runtime/batch/table/DecimalITCase.scala        |  14 +-
 .../planner/runtime/batch/table/JoinITCase.scala   |   4 +-
 .../runtime/stream/sql/AggregateITCase.scala       |   4 +-
 .../runtime/stream/sql/TemporalJoinITCase.scala    |   8 +-
 .../planner/runtime/stream/table/CalcITCase.scala  |  28 +-
 .../runtime/stream/table/CorrelateITCase.scala     |  20 +-
 .../runtime/stream/table/OverWindowITCase.scala    |  13 +-
 .../stream/table/TableAggregateITCase.scala        |   8 +-
 .../flink/table/catalog/ViewExpansionTest.java     |   9 +-
 .../table/runtime/batch/JavaTableSourceITCase.java |   4 +-
 .../batch/table/JavaTableEnvironmentITCase.java    |   2 +-
 .../apache/flink/table/api/TableSourceTest.scala   |  18 +-
 .../apache/flink/table/api/batch/ExplainTest.scala |   8 +-
 .../flink/table/api/batch/table/CalcTest.scala     |   2 +-
 .../table/api/batch/table/SetOperatorsTest.scala   |   2 +-
 .../api/batch/table/TemporalTableJoinTest.scala    |   4 +-
 .../stringexpr/CorrelateStringExpressionTest.scala |  14 +-
 .../batch/table/stringexpr/SetOperatorsTest.scala  |   2 +-
 .../table/validation/AggregateValidationTest.scala |  28 +-
 .../table/validation/CalcValidationTest.scala      |   8 +-
 .../table/validation/JoinValidationTest.scala      |   2 +-
 .../flink/table/api/stream/ExplainTest.scala       |   2 +-
 .../sql/validation/InsertIntoValidationTest.scala  |   6 +-
 .../stream/sql/validation/JoinValidationTest.scala |   2 +-
 .../flink/table/api/stream/table/CalcTest.scala    |   4 +-
 .../api/stream/table/TableAggregateTest.scala      |   6 +-
 .../table/api/stream/table/TableSourceTest.scala   |   8 +-
 .../api/stream/table/TemporalTableJoinTest.scala   |  20 +-
 .../stringexpr/CorrelateStringExpressionTest.scala |  41 ++-
 .../TableAggregateStringExpressionTest.scala       |   4 +-
 .../table/validation/AggregateValidationTest.scala |   4 +-
 .../table/validation/CalcValidationTest.scala      |   4 +-
 .../table/validation/CorrelateValidationTest.scala |   6 +-
 .../validation/InsertIntoValidationTest.scala      |   4 +-
 .../table/validation/JoinValidationTest.scala      |   2 +-
 .../validation/TableSourceValidationTest.scala     |   2 +-
 .../TemporalTableJoinValidationTest.scala          |   8 +-
 .../table/plan/ExpressionReductionRulesTest.scala  |   4 +-
 .../flink/table/plan/PythonCalcSplitRuleTest.scala |  96 +++--
 .../table/plan/PythonCorrelateSplitRuleTest.scala  |   4 +-
 .../SplitPythonConditionFromJoinRuleTest.scala     |  12 +-
 .../table/plan/TimeIndicatorConversionTest.scala   |   7 +-
 .../table/runtime/batch/sql/AggregateITCase.scala  |   2 +-
 .../flink/table/runtime/batch/sql/CalcITCase.scala |  16 +-
 .../flink/table/runtime/batch/sql/JoinITCase.scala |  52 +--
 .../runtime/batch/sql/SetOperatorsITCase.scala     |   8 +-
 .../runtime/batch/sql/TableEnvironmentITCase.scala |   8 +-
 .../table/runtime/batch/table/CalcITCase.scala     |   2 +-
 .../runtime/batch/table/CorrelateITCase.scala      |  28 +-
 .../table/runtime/batch/table/JoinITCase.scala     |   4 +-
 .../batch/table/TableEnvironmentITCase.scala       |   2 +-
 .../runtime/batch/table/TableSourceITCase.scala    |   4 +-
 .../runtime/stream/sql/SetOperatorsITCase.scala    |  14 +-
 .../flink/table/runtime/stream/sql/SqlITCase.scala |  40 +--
 .../runtime/stream/sql/TemporalJoinITCase.scala    |   4 +-
 .../table/runtime/stream/table/CalcITCase.scala    |  26 +-
 .../runtime/stream/table/CorrelateITCase.scala     |  18 +-
 .../stream/table/TableAggregateITCase.scala        |   6 +-
 .../runtime/stream/table/TableSourceITCase.scala   |   4 +-
 112 files changed, 1066 insertions(+), 510 deletions(-)
 mode change 100644 => 100755 flink-python/dev/dev-requirements.txt