diff --git a/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java b/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java index b1bad046e..3054d9564 100644 --- a/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java +++ b/src/main/java/net/snowflake/ingest/streaming/SnowflakeStreamingIngestClient.java @@ -6,7 +6,6 @@ import java.util.List; import java.util.Map; -import net.snowflake.ingest.streaming.internal.DropChannelResponse; /** * A class that is the starting point for using the Streaming Ingest client APIs, a single client diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java b/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java index 0406eec1c..0a0a2124b 100644 --- a/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java +++ b/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java @@ -854,7 +854,10 @@ public void testDropOnClose() throws Exception { Assert.assertTrue(channel.isClosed()); Mockito.verify(client, Mockito.times(1)) .dropChannel( - argThat((DropChannelRequest req) -> req.getChannelName().equals(channel.getName()) && req.getClientSequencer().equals(channel.getChannelSequencer()))); + argThat( + (DropChannelRequest req) -> + req.getChannelName().equals(channel.getName()) + && req.getClientSequencer().equals(channel.getChannelSequencer()))); } @Test diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java b/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java index 68e481f70..c956529e6 100644 --- a/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java +++ b/src/test/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientTest.java @@ -407,10 +407,10 @@ public void testDropChannel() throws Exception { .build(); client.dropChannel(request); Mockito.verify(requestBuilder) - .generateStreamingIngestPostRequest( - ArgumentMatchers.contains("channel"), - ArgumentMatchers.refEq(DROP_CHANNEL_ENDPOINT), - ArgumentMatchers.refEq("drop channel")); + .generateStreamingIngestPostRequest( + ArgumentMatchers.contains("channel"), + ArgumentMatchers.refEq(DROP_CHANNEL_ENDPOINT), + ArgumentMatchers.refEq("drop channel")); } @Test