You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/03/19 10:11:22 UTC

[flink] branch master updated (786420a -> ba5b122)

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

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


    from 786420a  [FLINK-21843][table-planner-blink] Support StreamExecGroupWindowAggregate json serialization/deserialization
     add ba5b122  [FLINK-21801][table-api] Use new schema in Table and TableResult

No new revisions were added by this update.

Summary of changes:
 .../pyflink/table/tests/test_table_completeness.py |  3 +-
 .../table/client/cli/CliChangelogResultView.java   |  4 ++-
 .../apache/flink/table/client/cli/CliClient.java   |  2 +-
 .../flink/table/client/cli/CliResultView.java      |  8 +++--
 .../flink/table/client/cli/CliTableResultView.java |  4 ++-
 .../table/client/cli/CliTableauResultView.java     |  8 ++---
 .../table/client/gateway/ResultDescriptor.java     |  8 ++---
 .../table/client/gateway/local/LocalExecutor.java  | 20 +-----------
 .../flink/table/client/cli/CliClientTest.java      | 11 ++++---
 .../flink/table/client/cli/CliResultViewTest.java  |  7 ++--
 .../table/client/cli/CliTableauResultViewTest.java | 20 ++++++------
 .../table/client/cli/utils/TestTableResult.java    | 30 ++++++++---------
 .../gateway/context/ExecutionContextTest.java      | 25 +++++++-------
 .../table/client/gateway/local/DependencyTest.java | 27 +++++++--------
 .../local/result/ChangelogCollectResultTest.java   |  5 +--
 .../result/MaterializedCollectBatchResultTest.java | 26 +++++++--------
 .../MaterializedCollectStreamResultTest.java       | 26 +++++++--------
 .../java/org/apache/flink/table/api/Table.java     | 20 ++++++++++--
 .../org/apache/flink/table/api/TableResult.java    | 20 ++++++++++--
 .../table/api/internal/TableEnvironmentImpl.java   | 28 ++++++++--------
 .../apache/flink/table/api/internal/TableImpl.java |  8 ++---
 .../flink/table/api/internal/TableResultImpl.java  | 33 ++++++++++---------
 .../flink/table/catalog/SchemaResolutionTest.java  | 32 +++++++++---------
 .../java/org/apache/flink/table/api/Schema.java    |  2 +-
 .../apache/flink/table/catalog/ResolvedSchema.java |  2 +-
 .../org/apache/flink/table/utils/PrintUtils.java   | 20 ++++++------
 .../apache/flink/table/utils/PrintUtilsTest.java   | 20 ++++++------
 .../planner/functions/BuiltInFunctionTestBase.java |  2 +-
 .../ConstructedAccessFunctionsITCase.java          | 22 ++++++-------
 .../runtime/stream/table/PrintConnectorITCase.java |  4 +--
 .../flink/table/api/TableEnvironmentITCase.scala   | 24 +++++++-------
 .../flink/table/api/TableEnvironmentTest.scala     | 38 ++++++++++++----------
 .../org/apache/flink/table/api/TableITCase.scala   | 14 ++++----
 .../table/planner/catalog/CatalogTableTest.scala   | 32 ++++++++++--------
 .../runtime/batch/table/SetOperatorsITCase.scala   |  5 +--
 .../flink/table/api/internal/TableEnvImpl.scala    | 16 +++++----
 .../flink/table/api/TableEnvironmentITCase.scala   | 27 +++++++--------
 .../org/apache/flink/table/api/TableITCase.scala   | 14 ++++----
 .../api/batch/BatchTableEnvironmentTest.scala      | 22 ++++++-------
 .../runtime/batch/sql/TableEnvironmentITCase.scala | 12 +++----
 .../table/runtime/batch/table/TableITCase.scala    | 10 +++---
 41 files changed, 339 insertions(+), 322 deletions(-)