diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/DropChannelResponse.java b/src/main/java/net/snowflake/ingest/streaming/internal/DropChannelResponse.java index de65e8835..e36692915 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/DropChannelResponse.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/DropChannelResponse.java @@ -2,9 +2,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; -/** - * Response for a {@link net.snowflake.ingest.streaming.DropChannelRequest}. - */ +/** Response for a {@link net.snowflake.ingest.streaming.DropChannelRequest}. */ class DropChannelResponse extends StreamingIngestResponse { private Long statusCode; private String message; diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java index 467d7fc59..058668651 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestClientInternal.java @@ -5,6 +5,7 @@ package net.snowflake.ingest.streaming.internal; import static net.snowflake.ingest.connection.ServiceResponseHandler.ApiName.STREAMING_CHANNEL_STATUS; +import static net.snowflake.ingest.connection.ServiceResponseHandler.ApiName.STREAMING_DROP_CHANNEL; import static net.snowflake.ingest.connection.ServiceResponseHandler.ApiName.STREAMING_OPEN_CHANNEL; import static net.snowflake.ingest.connection.ServiceResponseHandler.ApiName.STREAMING_REGISTER_BLOB; import static net.snowflake.ingest.streaming.internal.StreamingIngestUtils.executeWithRetries;