Skip to content

Commit

Permalink
Removed Explore References
Browse files Browse the repository at this point in the history
  • Loading branch information
@dj-smart
dj-smart committed Jan 5, 2023
1 parent 23daccb commit 4e3a727
Show file tree
Hide file tree
Showing 9 changed files with 8 additions and 22 deletions.
4 changes: 0 additions & 4 deletions kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/AbstractKafkaBatchSourceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand All @@ -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;

Expand Down
4 changes: 0 additions & 4 deletions kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaSinkAndAlertsPublisherTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand All @@ -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;
Expand Down
3 changes: 1 addition & 2 deletions ...ns-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceBegginingOffsetTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down
3 changes: 1 addition & 2 deletions ...plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceLastOffsetTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down
3 changes: 1 addition & 2 deletions ...ins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceSpecificOffsetTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down
3 changes: 1 addition & 2 deletions ...-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreFailureTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down
3 changes: 1 addition & 2 deletions ...client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreRecoveryTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down
4 changes: 2 additions & 2 deletions ...plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceStateStoreTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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 =
Expand Down
3 changes: 1 addition & 2 deletions kafka-plugins-client/src/test/java/io/cdap/plugin/kafka/KafkaStreamingSourceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down

0 comments on commit 4e3a727

Please sign in to comment.