This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
commit 9d535c6fefdb652faaa8a4265c46683cbcbca7b0 Author: Joao Boto <[email protected]> AuthorDate: Fri Jul 12 22:22:20 2024 +0200 [FLINK-35363] Fix deprecated documentation --- .../jdbc/internal/options/InternalJdbcConnectionOptions.java | 2 +- .../src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java | 6 +++++- .../apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java | 2 +- .../java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java | 2 +- .../flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java | 3 ++- .../flink/connector/jdbc/converter/AbstractJdbcRowConverter.java | 2 +- .../org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java | 2 +- .../org/apache/flink/connector/jdbc/dialect/AbstractDialect.java | 2 +- .../java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java | 2 +- .../org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java | 2 +- .../apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java | 2 +- .../main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java | 2 +- .../java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java | 3 +-- .../java/org/apache/flink/connector/jdbc/source/JdbcSource.java | 2 +- .../org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java | 3 +-- .../connector/jdbc/source/reader/extractor/ResultExtractor.java | 2 +- .../org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java | 2 +- .../flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java | 1 + .../apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java | 1 + .../org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java | 1 + .../org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java | 1 + .../org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java | 1 + .../java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java | 1 + .../apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java | 1 + .../java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java | 1 + .../org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java | 1 + .../apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java | 1 + 27 files changed, 32 insertions(+), 19 deletions(-) diff --git a/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java b/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java index de9e67b7..6c79ce15 100644 --- a/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java +++ b/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java @@ -179,7 +179,7 @@ public class InternalJdbcConnectionOptions extends JdbcConnectionOptions { /** * optional, Handle the SQL dialect of jdbc driver. If not set, it will be infer by {@link - * JdbcFactoryLoader#load} from DB url. + * JdbcFactoryLoader#loadDialect} from DB url. */ public Builder setDialect(JdbcDialect dialect) { this.dialect = dialect; diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java index a46601f6..81bbc83d 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java @@ -30,7 +30,11 @@ import org.apache.flink.util.function.SerializableSupplier; import javax.sql.XADataSource; -/** Facade to create JDBC {@link SinkFunction sinks}. */ +/** + * Facade to create JDBC {@link SinkFunction sinks}. + * + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.datastream.Jdbc} + */ @PublicEvolving @Deprecated public class JdbcSink { diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java index 4af50e7a..c5658367 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java @@ -21,7 +21,7 @@ package org.apache.flink.connector.jdbc.catalog; /** * Abstract catalog for any JDBC catalogs. * - * @deprecated use org.apache.flink.connector.jdbc.core.table.catalog.AbstractJdbcCatalog + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog} */ @Deprecated public abstract class AbstractJdbcCatalog diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java index b392788e..08db15da 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java @@ -37,7 +37,7 @@ import static org.apache.flink.connector.jdbc.JdbcConnectionOptions.getBriefAuth /** * Catalogs for relational databases via JDBC. * - * @deprecated user org.apache.flink.connector.jdbc.core.table.catalog.JdbcCatalog + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalog} */ @Deprecated @PublicEvolving diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java index 9aad0c7a..223b91c1 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java @@ -42,7 +42,8 @@ import static org.apache.flink.table.factories.FactoryUtil.PROPERTY_VERSION; /** * Factory for {@link JdbcCatalog}. * - * @deprecated use org.apache.flink.connector.jdbc.core.table.catalog.factory.JdbcCatalogFactory + * @deprecated Use {@link + * org.apache.flink.connector.jdbc.core.database.catalog.factory.JdbcCatalogFactory}. */ @Deprecated public class JdbcCatalogFactory implements CatalogFactory { diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java index 433b40c4..3f016201 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/AbstractJdbcRowConverter.java @@ -24,7 +24,7 @@ import org.apache.flink.table.types.logical.RowType; /** * Base class for all converters that convert between JDBC object and Flink internal object. * - * @deprecated use AbstractDialectConverter + * @deprecated Use {@link AbstractDialectConverter} */ @Deprecated public abstract class AbstractJdbcRowConverter extends AbstractDialectConverter { diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java index 0effab66..bd0bc6c9 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/converter/JdbcRowConverter.java @@ -26,7 +26,7 @@ import org.apache.flink.table.data.RowData; * Converter that is responsible to convert between JDBC object and Flink SQL internal data * structure {@link RowData}. * - * @deprecated use JdbcDialectConverter + * @deprecated Use {@link JdbcDialectConverter} */ @Deprecated @PublicEvolving diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java index 73db56e8..3a5af411 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java @@ -29,7 +29,7 @@ import org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect; * <p>Implementors should be careful to check the default SQL statements are performant for their * specific dialect and override them if necessary. * - * @deprecated use org.apache.flink.connector.jdbc.core.table.dialect.AbstractDialect + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.database.dialect.AbstractDialect} */ @Deprecated @PublicEvolving diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java index 400593d0..b8d2a63f 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java @@ -26,7 +26,7 @@ import org.apache.flink.connector.jdbc.core.database.JdbcFactory; * and stateless. * * @see JdbcFactory - * @deprecated use org.apache.flink.connector.jdbc.core.table.dialect.JdbcDialect + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.database.dialect.JdbcDialect} */ @Deprecated @PublicEvolving diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java index 4a6128f4..de674cda 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java @@ -30,7 +30,7 @@ import org.apache.flink.util.StringUtils; * current classpath to be found. * * @see org.apache.flink.connector.jdbc.dialect.JdbcDialect - * @deprecated use JdbcFactory + * @deprecated Use {@link JdbcFactory} */ @Deprecated public interface JdbcDialectFactory extends JdbcFactory { diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java index 73beac35..b1711478 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectTypeMapper.java @@ -23,7 +23,7 @@ import org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapp /** * Separate the jdbc meta-information type to flink table type into the interface. * - * @deprecated use JdbcCatalogTypeMapper + * @deprecated Use {@link JdbcCatalogTypeMapper} */ @Deprecated public interface JdbcDialectTypeMapper extends JdbcCatalogTypeMapper {} diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java index a1f8a4b4..2b1ba89a 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSink.java @@ -44,7 +44,7 @@ import java.util.Collections; * Flink Sink to produce data into a jdbc database. * * @see JdbcSinkBuilder on how to construct a JdbcSink - * @deprecated please use {@link org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSink} + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSink} */ @PublicEvolving @Deprecated diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java index 3b073568..da08b999 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/JdbcSinkBuilder.java @@ -39,8 +39,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull; /** * Builder to construct {@link JdbcSink}. * - * @deprecated please use {@link - * org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder} + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.datastream.sink.JdbcSinkBuilder} */ @PublicEvolving @Deprecated diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java index 19405624..cee58e75 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java @@ -53,7 +53,7 @@ import java.util.Objects; /** * JDBC source. * - * @deprecated please use {@link org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource} + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.datastream.source.JdbcSource} */ @PublicEvolving @Deprecated diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java index 7e940e92..a1931584 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java @@ -89,8 +89,7 @@ import java.util.Objects; * @see PreparedStatement * @see DriverManager * @see JdbcSource - * @deprecated please use {@link - * org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder} + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.datastream.source.JdbcSourceBuilder} */ @PublicEvolving @Deprecated diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java index 79935080..0a3e0ce9 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/extractor/ResultExtractor.java @@ -26,7 +26,7 @@ import java.sql.ResultSet; * The Extractor to extract the data from {@link ResultSet}. * * @param <T> The target data type. - * @deprecated please use {@link + * @deprecated Use {@link * org.apache.flink.connector.jdbc.core.datastream.source.reader.extractor.ResultExtractor} */ @PublicEvolving diff --git a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java index 8612e926..bee0d54a 100644 --- a/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java +++ b/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcConnectorOptions.java @@ -23,7 +23,7 @@ import org.apache.flink.annotation.PublicEvolving; /** * Options for the JDBC connector. * - * @deprecated please use {@link org.apache.flink.connector.jdbc.core.table.JdbcConnectorOptions} + * @deprecated Use {@link org.apache.flink.connector.jdbc.core.table.JdbcConnectorOptions} */ @PublicEvolving @Deprecated diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java index b736dddb..ef020ea3 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/CheckpointAndXidSerializersTest.java @@ -22,6 +22,7 @@ import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.connector.jdbc.datasource.transactions.xa.xid.XaXidTest; /** XaSerializersTest. */ +@Deprecated class CheckpointAndXidSerializersTest extends SerializerTestBase<CheckpointAndXid> { private static final CheckpointAndXid CHECKPOINT_AND_XID = CheckpointAndXid.createRestored(1L, 1, XaXidTest.XID); diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java index eb8569db..f27cba56 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcExactlyOnceSinkE2eTest.java @@ -72,6 +72,7 @@ import static org.apache.flink.util.Preconditions.checkState; import static org.assertj.core.api.Assertions.assertThat; /** A simple end-to-end test for {@link JdbcXaSinkFunction}. */ +@Deprecated public abstract class JdbcExactlyOnceSinkE2eTest implements DatabaseTest { private static final Logger LOG = LoggerFactory.getLogger(JdbcExactlyOnceSinkE2eTest.class); diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java index 12d3762d..313c0d5d 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeImplTest.java @@ -36,6 +36,7 @@ import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; /** {@link XaFacadeImpl} tests. */ +@Deprecated class JdbcXaFacadeImplTest extends JdbcTestBase { private static final Xid XID = diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java index b167d62a..7eb232c8 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaFacadeTestHelper.java @@ -33,6 +33,7 @@ import java.util.stream.IntStream; import static org.apache.flink.connector.jdbc.JdbcTestFixture.TEST_DATA; import static org.assertj.core.api.Assertions.assertThat; +@Deprecated class JdbcXaFacadeTestHelper implements AutoCloseable { private final String table; private final DatabaseMetadata metadata; diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java index 1f899af7..1a75a5a3 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkDerbyTest.java @@ -29,6 +29,7 @@ import static org.assertj.core.api.Assertions.assertThatThrownBy; * {@link JdbcXaSinkFunction} tests using Derby DB. Derby supports XA but doesn't use MVCC, so we * can't check anything before all transactions are completed. */ +@Deprecated class JdbcXaSinkDerbyTest extends JdbcXaSinkTestBase { /** diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java index d080bbcf..6574242b 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkH2Test.java @@ -33,6 +33,7 @@ import static org.assertj.core.api.Assertions.assertThat; * transaction is not yet committed). But XA support isn't full, so for some scenarios {@link * H2XaDsWrapper wrapper} is used, and for some - Derby. */ +@Deprecated class JdbcXaSinkH2Test extends JdbcXaSinkTestBase implements H2XaTestBase { @Override diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java index 48972a97..b8e477bc 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkNoInsertionTest.java @@ -28,6 +28,7 @@ import static org.apache.flink.connector.jdbc.JdbcTestFixture.TEST_DATA; import static org.assertj.core.api.Assertions.assertThat; /** Tests that data is not inserted ahead of time. */ +@Deprecated class JdbcXaSinkNoInsertionTest extends JdbcXaSinkTestBase implements H2XaTestBase { @Override diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java index 8441318f..c7407b0b 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestBase.java @@ -53,6 +53,7 @@ import static org.apache.flink.connector.jdbc.JdbcTestFixture.INSERT_TEMPLATE; * // todo: javadoc case Base class for {@link JdbcXaSinkFunction} tests. In addition to {@link * JdbcTestBase} init it initializes/closes helpers. */ +@Deprecated abstract class JdbcXaSinkTestBase extends JdbcTestBase { JdbcXaFacadeTestHelper xaHelper; diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java index 76050fe0..81bee7d2 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkTestHelper.java @@ -25,6 +25,7 @@ import org.apache.flink.util.Preconditions; import static org.apache.flink.connector.jdbc.JdbcTestFixture.TEST_DATA; import static org.apache.flink.connector.jdbc.xa.JdbcXaSinkTestBase.TEST_SINK_CONTEXT; +@Deprecated class JdbcXaSinkTestHelper implements AutoCloseable { private final JdbcXaSinkFunction<TestEntry> sink; diff --git a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java index 03b9f8dd..70c26314 100644 --- a/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java +++ b/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java @@ -33,6 +33,7 @@ import static org.apache.flink.connector.jdbc.xa.JdbcXaSinkTestBase.TEST_RUNTIME import static org.assertj.core.api.Assertions.assertThat; /** Simple uniqueness tests for the {@link SemanticXidGenerator}. */ +@Deprecated class SemanticXidGeneratorTest { private static final int COUNT = 100_000;
