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 9720e56 [FLINK-20781] Avoid NPE after SourceOperator is closed.
add 9903ea9 [FLINK-18090][core][table] Update Row#toString and provide
legacy util
add 73cdd3d [FLINK-18090] Update tests for new Row.toString
No new revisions were added by this update.
Summary of changes:
.../connector/hbase1/HBaseConnectorITCase.java | 120 ++++++++++-----------
.../connector/hbase2/HBaseConnectorITCase.java | 120 ++++++++++-----------
.../flink/connectors/hive/HiveDialectITCase.java | 20 ++--
.../connectors/hive/HiveLookupJoinITCase.java | 14 ++-
.../flink/connectors/hive/HiveRunnerITCase.java | 13 +--
.../flink/connectors/hive/HiveTableSinkITCase.java | 62 +++++------
.../connectors/hive/HiveTableSourceITCase.java | 33 +++---
.../hive/TableEnvHiveConnectorITCase.java | 30 +++---
.../table/catalog/hive/HiveCatalogITCase.java | 2 +-
.../catalog/hive/HiveCatalogUseBlinkITCase.java | 4 +-
.../flink/table/module/hive/HiveModuleTest.java | 5 +
.../connector/jdbc/JdbcLookupFunctionTest.java | 6 +-
.../jdbc/catalog/PostgresCatalogITCase.java | 64 +++++------
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 12 +--
.../jdbc/table/JdbcLookupTableITCase.java | 14 +--
.../jdbc/table/JdbcTableSourceITCase.java | 10 +-
.../jdbc/table/UnsignedTypeConversionITCase.java | 2 +-
.../kafka/table/KafkaChangelogTableITCase.java | 24 ++---
.../connectors/kafka/table/KafkaTableITCase.java | 40 +++----
.../kafka/table/UpsertKafkaTableITCase.java | 4 +
.../main/java/org/apache/flink/types/RowUtils.java | 18 +++-
.../test/java/org/apache/flink/types/RowTest.java | 16 +--
.../test-scripts/test_streaming_sql.sh | 8 +-
.../java/basics/UpdatingTopCityExampleITCase.java | 12 +--
.../formats/csv/CsvFilesystemBatchITCase.java | 4 +-
.../formats/json/JsonBatchFileSystemITCase.java | 4 +
.../debezium/DebeziumJsonFileSystemITCase.java | 44 ++++----
.../org/apache/flink/orc/OrcTableSourceITCase.java | 6 +-
.../pyflink/datastream/tests/test_data_stream.py | 24 ++---
.../tests/test_stream_execution_environment.py | 39 +++----
.../pyflink/ml/tests/test_pipeline_it_case.py | 20 ++--
flink-python/pyflink/table/tests/test_calc.py | 23 ++--
.../pyflink/table/tests/test_dependency.py | 12 +--
.../pyflink/table/tests/test_pandas_conversion.py | 8 +-
.../pyflink/table/tests/test_pandas_udaf.py | 93 +++++++++-------
.../pyflink/table/tests/test_pandas_udf.py | 21 ++--
.../table/tests/test_row_based_operation.py | 21 ++--
flink-python/pyflink/table/tests/test_sql.py | 4 +-
.../table/tests/test_table_environment_api.py | 65 +++++------
flink-python/pyflink/table/tests/test_udf.py | 44 ++++----
flink-python/pyflink/table/tests/test_udtf.py | 8 +-
.../apache/flink/api/scala/ScalaShellITCase.scala | 10 +-
.../client/gateway/local/LocalExecutorITCase.java | 74 ++++++-------
.../table/factories/PrintTableSinkFactory.java | 6 +-
.../table/expressions/ObjectToExpressionTest.java | 6 +-
.../flink/table/utils/LegacyRowResource.java} | 30 +++---
flink-table/flink-table-planner-blink/pom.xml | 8 ++
.../factories/TestValuesRuntimeFunctions.java | 12 ++-
.../runtime/stream/table/PrintConnectorITCase.java | 32 +++---
.../table/planner/catalog/CatalogTableITCase.scala | 6 +-
.../planner/runtime/batch/sql/CalcITCase.scala | 6 +-
.../batch/sql/PartitionableSinkITCase.scala | 4 +
.../batch/sql/agg/AggregateITCaseBase.scala | 6 +-
.../runtime/batch/table/AggregationITCase.scala | 4 +
.../planner/runtime/batch/table/CalcITCase.scala | 6 +-
.../runtime/batch/table/CorrelateITCase.scala | 6 +-
.../runtime/batch/table/GroupWindowITCase.scala | 4 +
.../planner/runtime/batch/table/JoinITCase.scala | 4 +
.../batch/table/LegacyTableSinkITCase.scala | 4 +
.../runtime/batch/table/SetOperatorsITCase.scala | 4 +
.../planner/runtime/batch/table/SortITCase.scala | 4 +
.../runtime/batch/table/TableSinkITCase.scala | 7 +-
.../runtime/stream/sql/AggregateRemoveITCase.scala | 6 +-
.../planner/runtime/stream/sql/CalcITCase.scala | 4 +
.../runtime/stream/sql/ChangelogSourceITCase.scala | 7 +-
.../runtime/stream/sql/DeduplicateITCase.scala | 6 +-
.../stream/sql/PruneAggregateCallITCase.scala | 6 +-
.../runtime/stream/sql/SourceWatermarkITCase.scala | 9 +-
.../runtime/stream/sql/TableSourceITCase.scala | 6 +-
.../runtime/stream/sql/TemporalJoinITCase.scala | 5 +
.../planner/runtime/stream/sql/UnnestITCase.scala | 6 +-
.../planner/runtime/stream/table/CalcITCase.scala | 4 +
.../runtime/stream/table/CorrelateITCase.scala | 6 +-
.../stream/table/LegacyTableSinkITCase.scala | 6 +-
.../runtime/stream/table/SetOperatorsITCase.scala | 6 +-
.../runtime/stream/table/TableSinkITCase.scala | 15 +--
.../table/runtime/stream/sql/JavaSqlITCase.java | 4 +
.../table/runtime/stream/table/ValuesITCase.java | 5 +
.../flink/table/api/TableEnvironmentITCase.scala | 5 +-
.../flink/table/catalog/CatalogTableITCase.scala | 4 +
.../expressions/utils/ExpressionTestBase.scala | 6 +-
.../batch/sql/PartitionableSinkITCase.scala | 6 +-
.../runtime/stream/TimeAttributesITCase.scala | 7 +-
.../runtime/stream/sql/TableSourceITCase.scala | 6 +-
.../table/runtime/stream/table/CalcITCase.scala | 6 +-
.../runtime/stream/table/CorrelateITCase.scala | 5 +-
.../runtime/stream/table/GroupWindowITCase.scala | 7 +-
.../table/GroupWindowTableAggregateITCase.scala | 7 +-
.../runtime/stream/table/SetOperatorsITCase.scala | 6 +-
.../runtime/stream/table/TableSinkITCase.scala | 9 +-
.../runtime/stream/table/TableSourceITCase.scala | 6 +-
.../runtime/utils/StreamingWithStateTestBase.scala | 5 +
.../runtime/utils/TableProgramsTestBase.scala | 6 ++
.../apache/flink/table/utils/TableTestBase.scala | 3 +
.../filesystem/FileSystemOutputFormatTest.java | 4 +
.../table/filesystem/PartitionWriterTest.java | 4 +
96 files changed, 890 insertions(+), 649 deletions(-)
copy
flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/utils/FormatDescriptorMock.java
=>
flink-table-common/src/test/java/org/apache/flink/table/utils/LegacyRowResource.java}
(58%)
