From 4e3a7272b88a5cce0b620ecf85c657be5ef95ef2 Mon Sep 17 00:00:00 2001 From: dj-smart Date: Thu, 5 Jan 2023 17:03:16 +0000 Subject: [PATCH] Removed Explore References --- .../io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java | 4 ---- .../io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java | 4 ---- .../plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java | 3 +-- .../cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java | 3 +-- .../plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java | 3 +-- .../kafka/KafkaStreamingSourceStateStoreFailureTest.java | 3 +-- .../kafka/KafkaStreamingSourceStateStoreRecoveryTest.java | 3 +-- .../cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java | 4 ++-- .../java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java | 3 +-- 9 files changed, 8 insertions(+), 22 deletions(-) diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java index 3936b7e..2c34c63 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java @@ -38,7 +38,6 @@ import io.cdap.cdap.proto.id.NamespaceId; import io.cdap.cdap.test.ApplicationManager; import io.cdap.cdap.test.DataSetManager; -import io.cdap.cdap.test.TestConfiguration; import io.cdap.cdap.test.WorkflowManager; import io.cdap.plugin.kafka.batch.source.KafkaBatchConfig; import io.cdap.plugin.kafka.batch.source.KafkaPartitionOffsets; @@ -51,7 +50,6 @@ import org.junit.After; import org.junit.Assert; import org.junit.Before; -import org.junit.ClassRule; import org.junit.Test; import java.io.File; @@ -71,8 +69,6 @@ public abstract class AbstractKafkaBatchSourceTest extends HydratorTestBase { private static final ArtifactSummary APP_ARTIFACT = new ArtifactSummary("data-pipeline", "1.0.0"); - @ClassRule - public static final TestConfiguration CONFIG = new TestConfiguration("explore.enabled", false); private static final int ZOOKEEPER_TICK_TIME = 1000; private static final int ZOOKEEPER_MAX_CONNECTIONS = 100; diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java index 34db77c..52f7753 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java @@ -41,7 +41,6 @@ import io.cdap.cdap.proto.id.NamespaceId; import io.cdap.cdap.test.ApplicationManager; import io.cdap.cdap.test.DataSetManager; -import io.cdap.cdap.test.TestConfiguration; import io.cdap.cdap.test.WorkflowManager; import io.cdap.plugin.kafka.alertpublisher.KafkaAlertPublisher; import io.cdap.plugin.kafka.sink.KafkaBatchSink; @@ -55,7 +54,6 @@ import org.junit.After; import org.junit.Assert; import org.junit.Before; -import org.junit.ClassRule; import org.junit.Test; import java.io.File; @@ -75,8 +73,6 @@ */ public class KafkaSinkAndAlertsPublisherTest extends HydratorTestBase { private static final ArtifactSummary APP_ARTIFACT = new ArtifactSummary("data-pipeline", "1.0.0"); - @ClassRule - public static final TestConfiguration CONFIG = new TestConfiguration("explore.enabled", false); private static final Gson GSON = new Gson(); private static final int ZOOKEEPER_TICK_TIME = 1000; diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java index 7729249..680ad57 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java @@ -75,8 +75,7 @@ public class KafkaStreamingSourceBegginingOffsetTest extends HydratorTestBase { // This test needs a fix to work with checkpointing disabled. See PLUGIN-1414 @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "false"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "false"); private static final ArtifactId DATAPIPELINE_ARTIFACT_ID = NamespaceId.DEFAULT.artifact("data-pipeline", "4.3.2"); diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java index 2d6ee12..67b67a8 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java @@ -75,8 +75,7 @@ public class KafkaStreamingSourceLastOffsetTest extends HydratorTestBase { // This test needs a fix to work with checkpointing disabled. See PLUGIN-1414 @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "false"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "false"); private static final ArtifactId DATAPIPELINE_ARTIFACT_ID = NamespaceId.DEFAULT.artifact("data-pipeline", "4.3.2"); diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java index f0b56c8..ca6b2ad 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java @@ -75,8 +75,7 @@ public class KafkaStreamingSourceSpecificOffsetTest extends HydratorTestBase { // This test needs a fix to work with checkpointing disabled. See PLUGIN-1414 @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "false"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "false"); private static final ArtifactId DATAPIPELINE_ARTIFACT_ID = NamespaceId.DEFAULT.artifact("data-pipeline", "4.3.2"); diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreFailureTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreFailureTest.java index 3e007c2..3b9fb09 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreFailureTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreFailureTest.java @@ -76,8 +76,7 @@ public class KafkaStreamingSourceStateStoreFailureTest extends HydratorTestBase // Turn on state tracking. @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "true"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "true"); private static final Gson GSON = new Gson(); private static final ArtifactId DATASTREAMS_ARTIFACT_ID = diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreRecoveryTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreRecoveryTest.java index 8e11a61..f4aaaeb 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreRecoveryTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreRecoveryTest.java @@ -85,8 +85,7 @@ public class KafkaStreamingSourceStateStoreRecoveryTest extends HydratorTestBase // Turn on state tracking. @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "true"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "true"); private static final Gson GSON = new Gson(); private static final ArtifactId DATASTREAMS_ARTIFACT_ID = diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java index d55782a..74d8e59 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java @@ -61,6 +61,7 @@ import org.junit.ClassRule; import org.junit.Test; import org.junit.rules.TemporaryFolder; + import java.io.ByteArrayInputStream; import java.io.File; import java.io.InputStreamReader; @@ -81,8 +82,7 @@ public class KafkaStreamingSourceStateStoreTest extends HydratorTestBase { // Turn on state tracking. @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "true"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "true"); private static final Gson GSON = new Gson(); private static final ArtifactId DATASTREAMS_ARTIFACT_ID = diff --git a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java index 5c7d787..dc3aeeb 100644 --- a/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java +++ b/kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java @@ -73,8 +73,7 @@ public class KafkaStreamingSourceTest extends HydratorTestBase { // This test needs a fix to work with checkpointing disabled. See PLUGIN-1414 @ClassRule public static final TestConfiguration CONFIG = - new TestConfiguration("explore.enabled", false, - "feature.streaming.pipeline.native.state.tracking.enabled", "false"); + new TestConfiguration("feature.streaming.pipeline.native.state.tracking.enabled", "false"); private static final ArtifactId DATAPIPELINE_ARTIFACT_ID = NamespaceId.DEFAULT.artifact("data-pipeline", "4.3.2");