This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d036c23c0e5 [FLINK-27910][connector/filesystem] Register the timer to
enforce rolling policy when file sink starts from scratch.
add d0b3390ffb9 [FLINK-27185][connector] Convert connector-jdbc module to
assertj
No new revisions were added by this update.
Summary of changes:
.../flink/connector/jdbc/JdbcDataTypeTest.java | 20 +-
.../apache/flink/connector/jdbc/JdbcITCase.java | 6 +-
.../flink/connector/jdbc/JdbcInputFormatTest.java | 38 +--
.../connector/jdbc/JdbcRowOutputFormatTest.java | 95 +++---
.../connector/jdbc/catalog/MySqlCatalogITCase.java | 46 ++-
.../jdbc/catalog/PostgresCatalogITCase.java | 86 ++---
.../jdbc/catalog/PostgresCatalogTest.java | 57 ++--
.../jdbc/catalog/PostgresTablePathTest.java | 7 +-
.../catalog/factory/JdbcCatalogFactoryTest.java | 15 +-
.../converter/AbstractJdbcRowConverterTest.java | 9 +-
.../oracle/OraclePreparedStatementTest.java | 55 +--
.../dialect/oracle/OracleTableSourceITCase.java | 15 +-
.../connector/jdbc/internal/JdbcFullTest.java | 9 +-
.../jdbc/internal/JdbcTableOutputFormatTest.java | 13 +-
...ProviderDriverClassConcurrentLoadingITCase.java | 11 +-
.../SimpleJdbcConnectionProviderTest.java | 117 +++----
.../NumericBetweenParametersProviderTest.java | 8 +-
.../FieldNamedPreparedStatementImplTest.java | 55 ++-
.../jdbc/table/JdbcDynamicTableFactoryTest.java | 204 +++++------
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 15 +-
.../connector/jdbc/table/JdbcOutputFormatTest.java | 377 +++++++++++----------
.../jdbc/table/JdbcRowDataInputFormatTest.java | 40 +--
.../jdbc/table/JdbcRowDataLookupFunctionTest.java | 12 +-
.../connector/jdbc/utils/JdbcTypeUtilTest.java | 13 +-
.../jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 8 +-
.../connector/jdbc/xa/JdbcXaFacadeImplTest.java | 6 +-
.../connector/jdbc/xa/JdbcXaFacadeTestHelper.java | 6 +-
.../connector/jdbc/xa/JdbcXaSinkDerbyTest.java | 14 +-
.../flink/connector/jdbc/xa/JdbcXaSinkH2Test.java | 25 +-
.../jdbc/xa/JdbcXaSinkNoInsertionTest.java | 20 +-
.../jdbc/xa/SemanticXidGeneratorTest.java | 4 +-
.../flink/connector/jdbc/xa/XidImplTest.java | 32 +-
32 files changed, 674 insertions(+), 764 deletions(-)
