From dbfe1b82c83294daa33ed643658a363f60a79fc5 Mon Sep 17 00:00:00 2001 From: ismail simsek <6005685+ismailsimsek@users.noreply.github.com> Date: Mon, 22 Aug 2022 11:20:20 +0200 Subject: [PATCH] Use restrictToAnnotatedClass=true for quarkus tests (#104) * Use restrictToAnnotatedClass=true for quarkus tests --- .../server/iceberg/IcebergChangeConsumerMangodbTest.java | 4 ++-- .../server/iceberg/IcebergChangeConsumerMysqlTest.java | 4 ++-- .../debezium/server/iceberg/IcebergChangeConsumerTest.java | 4 ++-- .../IcebergChangeConsumerUpsertDeleteDeletesTest.java | 4 ++-- .../server/iceberg/IcebergChangeConsumerUpsertTest.java | 4 ++-- .../server/iceberg/IcebergEventsChangeConsumerTest.java | 4 ++-- .../server/iceberg/batchsizewait/MaxBatchSizeWaitTest.java | 5 +++++ .../iceberg/tableoperator/IcebergTableOperatorTest.java | 2 +- 8 files changed, 18 insertions(+), 13 deletions(-) diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java index d6bdfe33..feb51fdc 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java @@ -28,8 +28,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourceMangoDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourceMangoDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerMangodbTestProfile.class) public class IcebergChangeConsumerMangodbTest extends BaseSparkTest { diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java index aac775ae..d6733f8e 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java @@ -28,8 +28,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourceMysqlDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourceMysqlDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerMysqlTestProfile.class) public class IcebergChangeConsumerMysqlTest extends BaseSparkTest { diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java index cbbf3f16..f1a88042 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java @@ -36,8 +36,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourcePostgresqlDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourcePostgresqlDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerTestProfile.class) public class IcebergChangeConsumerTest extends BaseSparkTest { diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java index d09ae1d7..b69ed085 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java @@ -28,8 +28,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourcePostgresqlDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourcePostgresqlDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerUpsertTestDeleteDeletesProfile.class) public class IcebergChangeConsumerUpsertDeleteDeletesTest extends BaseSparkTest { diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java index ea9bb25c..8fc176fb 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java @@ -28,8 +28,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourcePostgresqlDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourcePostgresqlDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergChangeConsumerUpsertTestProfile.class) public class IcebergChangeConsumerUpsertTest extends BaseSparkTest { diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java index 78215c2a..52b1e413 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java @@ -30,8 +30,8 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) -@QuarkusTestResource(SourcePostgresqlDB.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = SourcePostgresqlDB.class, restrictToAnnotatedClass = true) @TestProfile(IcebergEventsChangeConsumerTestProfile.class) public class IcebergEventsChangeConsumerTest extends BaseSparkTest { @ConfigProperty(name = "debezium.sink.type") diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWaitTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWaitTest.java index f973984f..6ccc3a64 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWaitTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWaitTest.java @@ -9,6 +9,9 @@ package io.debezium.server.iceberg.batchsizewait; import io.debezium.server.iceberg.testresources.BaseSparkTest; +import io.debezium.server.iceberg.testresources.S3Minio; +import io.debezium.server.iceberg.testresources.SourcePostgresqlDB; +import io.quarkus.test.common.QuarkusTestResource; import io.quarkus.test.junit.QuarkusTest; import io.quarkus.test.junit.TestProfile; @@ -23,6 +26,8 @@ @QuarkusTest @TestProfile(MaxBatchSizeWaitTestProfile.class) +@QuarkusTestResource(value = SourcePostgresqlDB.class, restrictToAnnotatedClass = true) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) class MaxBatchSizeWaitTest extends BaseSparkTest { @Inject MaxBatchSizeWait waitBatchSize; diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java index 9250e91a..8e7fe929 100644 --- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java +++ b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java @@ -37,7 +37,7 @@ * @author Ismail Simsek */ @QuarkusTest -@QuarkusTestResource(S3Minio.class) +@QuarkusTestResource(value = S3Minio.class, restrictToAnnotatedClass = true) class IcebergTableOperatorTest extends BaseSparkTest { static String testTable = "inventory.test_table_operator";