Skip to content

Commit b392748

Browse files
author
Jonah Calvo
committed
Cleanup for linter
Signed-off-by: Jonah Calvo <caljonah@amazon.com>
1 parent d4aae9e commit b392748

3 files changed

Lines changed: 1 addition & 6 deletions

File tree

data-prepper-plugins/opensearch/src/integrationTest/java/org/opensearch/dataprepper/plugins/sink/opensearch/OpenSearchSinkIT.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,11 @@
4747
import org.opensearch.dataprepper.model.plugin.PluginConfigObservable;
4848
import org.opensearch.dataprepper.model.record.Record;
4949
import org.opensearch.dataprepper.model.sink.SinkContext;
50-
import org.opensearch.dataprepper.plugins.sink.opensearch.BulkRetryStrategy;
5150
import org.opensearch.dataprepper.plugins.sink.opensearch.configuration.OpenSearchSinkConfig;
52-
import org.opensearch.dataprepper.plugins.sink.opensearch.ConnectionConfiguration;
53-
import org.opensearch.dataprepper.plugins.sink.opensearch.DistributionVersion;
5451
import org.opensearch.dataprepper.plugins.sink.opensearch.index.AbstractIndexManager;
5552
import org.opensearch.dataprepper.plugins.sink.opensearch.index.IndexConfiguration;
5653
import org.opensearch.dataprepper.plugins.sink.opensearch.index.IndexConstants;
5754
import org.opensearch.dataprepper.plugins.sink.opensearch.index.IndexType;
58-
import org.opensearch.dataprepper.plugins.sink.opensearch.RetryConfiguration;
5955

6056
import javax.ws.rs.HttpMethod;
6157
import java.io.BufferedReader;

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/DataStreamDetector.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import org.slf4j.LoggerFactory;
1818

1919
import java.io.IOException;
20-
import java.util.concurrent.ConcurrentHashMap;
2120

2221
/**
2322
* Utility class to detect if an index name refers to a Data Stream

data-prepper-plugins/opensearch/src/test/java/org/opensearch/dataprepper/plugins/sink/opensearch/index/DataStreamIndexTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ void ensureTimestamp_setsTimestamp_whenDataStreamAndTimestampMissing() {
8080

8181
dataStreamIndex.ensureTimestamp(event, "my-data-stream");
8282

83-
verify(event).put("@timestamp", testTime);
83+
verify(event).put("@timestamp", testTime.toEpochMilli());
8484
}
8585

8686
@Test

0 commit comments

Comments
 (0)