[flink] branch master updated (f38cb48 -> 91d2b62)

[tw...@apache.org]

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 f38cb48  [FLINK-19043][docs-zh] Translate the 'Logging' page of 'Debugging & Monitoring' into Chinese
     add 6f2a041  [FLINK-18337][table] Introduce TableResult#await method to block until data is ready or job finished
     add 91d2b62  [hotfix][table][connector] Use CollectionUtil#iteratorToList instead of Guava Lists

No new revisions were added by this update.

Summary of changes:
 .../cassandra/CassandraConnectorITCase.java        |   4 +-
 .../table/Elasticsearch6DynamicSinkITCase.java     |  18 +---
 .../table/Elasticsearch7DynamicSinkITCase.java     |  18 +---
 .../connector/hbase/HBaseConnectorITCase.java      |  76 +++------------
 .../flink/connectors/hive/HiveDialectITCase.java   |  50 +++++-----
 .../connectors/hive/HiveLookupJoinITCase.java      |  11 +--
 .../flink/connectors/hive/HiveTableSinkITCase.java |  34 +++----
 .../connectors/hive/HiveTableSourceITCase.java     |  49 +++++-----
 .../hive/TableEnvHiveConnectorITCase.java          | 105 ++++++++++-----------
 .../table/catalog/hive/HiveCatalogITCase.java      |  35 ++++---
 .../catalog/hive/HiveCatalogUseBlinkITCase.java    |  15 ++-
 .../flink/table/catalog/hive/HiveTestUtils.java    |   5 -
 .../flink/table/module/hive/HiveModuleTest.java    |  29 +++---
 .../connector/jdbc/JdbcLookupFunctionTest.java     |   4 +-
 .../jdbc/catalog/PostgresCatalogITCase.java        |  36 ++++---
 .../jdbc/table/JdbcDynamicTableSinkITCase.java     |  25 ++---
 .../jdbc/table/JdbcDynamicTableSourceITCase.java   |   7 +-
 .../jdbc/table/JdbcLookupTableITCase.java          |   9 +-
 .../jdbc/table/JdbcRowDataLookupFunctionTest.java  |   4 +-
 .../jdbc/table/JdbcUpsertTableSinkITCase.java      |  22 ++---
 .../jdbc/table/UnsignedTypeConversionITCase.java   |  10 +-
 .../connectors/kafka/table/KafkaTableTestBase.java |  14 ++-
 .../kinesis/FlinkKinesisConsumerTest.java          |   5 +-
 .../dataset/tests/test_execution_environment.py    |   2 +-
 .../tests/test_stream_execution_environment.py     |   2 +-
 .../pyflink/ml/tests/test_pipeline_it_case.py      |  12 +--
 flink-python/pyflink/table/table_result.py         |  19 ++++
 flink-python/pyflink/table/tests/test_calc.py      |   6 +-
 .../pyflink/table/tests/test_dependency.py         |  16 ++--
 .../pyflink/table/tests/test_descriptor.py         |   4 +-
 .../pyflink/table/tests/test_pandas_conversion.py  |   4 +-
 .../pyflink/table/tests/test_pandas_udf.py         |  58 ++++++------
 .../pyflink/table/tests/test_shell_example.py      |   6 +-
 flink-python/pyflink/table/tests/test_sql.py       |   4 +-
 .../table/tests/test_table_environment_api.py      |  14 +--
 flink-python/pyflink/table/tests/test_udf.py       |  86 ++++++++---------
 flink-python/pyflink/table/tests/test_udtf.py      |   5 +-
 .../table/client/cli/utils/TestTableResult.java    |  13 +++
 .../org/apache/flink/table/api/TableResult.java    |  36 ++++++-
 .../table/api/internal/InsertResultIterator.java   |  75 +++++++++++++++
 .../table/api/internal/TableEnvironmentImpl.java   |   2 +-
 .../flink/table/api/internal/TableResultImpl.java  |  93 +++++++++++++++++-
 .../planner/runtime/stream/sql/FunctionITCase.java |  73 +++++++-------
 .../stream/table/BlackHoleConnectorITCase.java     |   6 +-
 .../runtime/stream/table/FunctionITCase.java       |  15 ++-
 .../runtime/stream/table/PrintConnectorITCase.java |   8 +-
 .../planner/runtime/stream/table/ValuesITCase.java |  16 +---
 .../flink/table/planner/utils/XmlOutput.java       |   8 +-
 .../flink/table/api/TableEnvironmentITCase.scala   |  61 ++----------
 .../org/apache/flink/table/api/TableITCase.scala   |  11 ++-
 .../table/planner/catalog/CatalogTableITCase.scala |  30 +++---
 .../table/planner/catalog/CatalogViewITCase.scala  |  21 ++---
 .../planner/plan/common/TableFactoryTest.scala     |   1 -
 .../validation/LegacyTableSinkValidationTest.scala |   4 +-
 .../planner/runtime/FileSystemITCaseBase.scala     |  34 +++----
 .../batch/sql/PartitionableSinkITCase.scala        |  20 ++--
 .../batch/table/LegacyTableSinkITCase.scala        |  12 +--
 .../runtime/batch/table/TableSinkITCase.scala      |  12 +--
 .../runtime/stream/FsStreamingSinkITCaseBase.scala |  10 +-
 .../runtime/stream/sql/AggregateITCase.scala       |   4 +-
 .../planner/runtime/stream/sql/CalcITCase.scala    |   2 +-
 .../runtime/stream/sql/ChangelogSourceITCase.scala |   4 +-
 .../runtime/stream/sql/CorrelateITCase.scala       |  14 +--
 .../runtime/stream/sql/Limit0RemoveITCase.scala    |  16 ++--
 .../planner/runtime/stream/sql/RankITCase.scala    |  38 ++++----
 .../planner/runtime/stream/sql/UnnestITCase.scala  |   2 +-
 .../runtime/stream/sql/WindowAggregateITCase.scala |   2 +-
 .../runtime/stream/table/AggregateITCase.scala     |   2 +-
 .../planner/runtime/stream/table/JoinITCase.scala  |  12 +--
 .../stream/table/LegacyTableSinkITCase.scala       |  29 +++---
 .../runtime/stream/table/TableSinkITCase.scala     |  36 +++----
 .../planner/runtime/utils/BatchTableEnvUtil.scala  |  30 +-----
 .../planner/runtime/utils/BatchTestBase.scala      |  16 +---
 .../planner/runtime/utils/StreamingTestBase.scala  |  11 +--
 .../table/planner/runtime/utils/TableEnvUtil.scala |  41 --------
 .../table/api/internal/BatchTableEnvImpl.scala     |   2 +-
 .../flink/table/api/internal/TableEnvImpl.scala    |   7 +-
 .../flink/table/api/TableEnvironmentITCase.scala   |  53 +----------
 .../org/apache/flink/table/api/TableITCase.scala   |   7 +-
 .../runtime/batch/sql/TableEnvironmentITCase.scala |  48 +---------
 .../table/runtime/batch/table/TableITCase.scala    |   5 +-
 81 files changed, 813 insertions(+), 952 deletions(-)
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/InsertResultIterator.java
 delete mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/utils/TableEnvUtil.scala