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(-)