fix checkstyle

confluentinc · Jul 6, 2020 · 8d03103 · 8d03103
1 parent 8b8a2f9
commit 8d03103
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 29 deletions.
diff --git a/ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java b/ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java
@@ -68,7 +68,7 @@ public class KsqlConfig extends AbstractConfig {
 
   public static final String METRIC_REPORTER_CLASSES_DOC =
       CommonClientConfigs.METRIC_REPORTER_CLASSES_DOC;
-  
+
   private static final String TELEMETRY_PREFIX = "confluent.telemetry";
   private static final Set<String> REPORTER_CONFIGS_PREFIXES =
       ImmutableSet.of(
@@ -78,7 +78,7 @@ public class KsqlConfig extends AbstractConfig {
 
   public static final String KSQL_INTERNAL_TOPIC_REPLICAS_PROPERTY = "ksql.internal.topic.replicas";
 
-  public static final String KSQL_INTERNAL_TOPIC_MIN_INSYNC_REPLICAS_PROPERTY = 
+  public static final String KSQL_INTERNAL_TOPIC_MIN_INSYNC_REPLICAS_PROPERTY =
       "ksql.internal.topic.min.insync.replicas";
 
   public static final String KSQL_SCHEMA_REGISTRY_PREFIX = "ksql.schema.registry.";
@@ -951,7 +951,7 @@ private static Set<String> sslConfigNames() {
   }
 
   public String getServiceId() {
-      return ReservedInternalTopics.KSQL_INTERNAL_TOPIC_PREFIX
-              + this.getString(KsqlConfig.KSQL_SERVICE_ID_CONFIG);
+    return ReservedInternalTopics.KSQL_INTERNAL_TOPIC_PREFIX
+        + this.getString(KsqlConfig.KSQL_SERVICE_ID_CONFIG);
   }
 }
diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryExecutor.java b/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryExecutor.java
@@ -52,7 +52,6 @@
 import io.confluent.ksql.util.KsqlException;
 import io.confluent.ksql.util.PersistentQueryMetadata;
 import io.confluent.ksql.util.QueryMetadata;
-import io.confluent.ksql.util.ReservedInternalTopics;
 import io.confluent.ksql.util.TransientQueryMetadata;
 import java.util.Arrays;
 import java.util.HashMap;

diff --git a/...db-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/ListSourceExecutor.java b/...db-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/ListSourceExecutor.java
@@ -48,7 +48,6 @@
 import io.confluent.ksql.util.KsqlConstants;
 import io.confluent.ksql.util.KsqlStatementException;
 import io.confluent.ksql.util.PersistentQueryMetadata;
-import io.confluent.ksql.util.ReservedInternalTopics;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.LinkedList;

diff --git a/ksqldb-rest-model/src/main/java/io/confluent/ksql/rest/entity/SourceDescription.java b/ksqldb-rest-model/src/main/java/io/confluent/ksql/rest/entity/SourceDescription.java
@@ -214,27 +214,4 @@ public int hashCode() {
         consumerGroupsOffsets
     );
   }
-
-  @Override
-  public String toString() {
-    return "SourceDescription{" +
-            "name='" + name + '\'' +
-            ", windowType=" + windowType +
-            ", readQueries=" + readQueries +
-            ", writeQueries=" + writeQueries +
-            ", fields=" + fields +
-            ", type='" + type + '\'' +
-            ", timestamp='" + timestamp + '\'' +
-            ", statistics='" + statistics + '\'' +
-            ", errorStats='" + errorStats + '\'' +
-            ", extended=" + extended +
-            ", keyFormat='" + keyFormat + '\'' +
-            ", valueFormat='" + valueFormat + '\'' +
-            ", topic='" + topic + '\'' +
-            ", partitions=" + partitions +
-            ", replication=" + replication +
-            ", statement='" + statement + '\'' +
-            ", consumerGroupsOffsets=" + consumerGroupsOffsets +
-            '}';
-  }
 }