diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommands.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommands.java index 625dae255391..3883e0257c5c 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommands.java +++ b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommands.java @@ -149,7 +149,7 @@ public static LocalCommands open( + "' config in the properties file." ); } - File file = new File(directory, String.format("local_commands_%d_%s%s", + final File file = new File(directory, String.format("local_commands_%d_%s%s", System.currentTimeMillis(), Integer.toHexString(RANDOM.nextInt()), LOCAL_COMMANDS_FILE_SUFFIX)); return new LocalCommands(directory, ksqlEngine, LocalCommandsFile.createWriteable(file)); diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java index 307983b30aed..3dd52a17ae91 100644 --- a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java +++ b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java @@ -16,7 +16,6 @@ package io.confluent.ksql.rest.server; import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.common.annotations.VisibleForTesting; import io.confluent.ksql.util.KsqlException; import java.io.Closeable; import java.io.File;