Remove request_id and no star imports

snowflakedb · Jun 12, 2024 · ce91a9a · ce91a9a
1 parent ba47eb2
commit ce91a9a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 14 deletions.
diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/ChannelsStatusRequest.java b/src/main/java/net/snowflake/ingest/streaming/internal/ChannelsStatusRequest.java
@@ -61,20 +61,12 @@ Long getClientSequencer() {
     }
   }
 
-  // Optional Request ID. Used for diagnostic purposes.
-  private String requestId;
-
   // Channels in request
   private List<ChannelStatusRequestDTO> channels;
 
   // Snowflake role used by client
   private String role;
 
-  @JsonProperty("request_id")
-  String getRequestId() {
-    return requestId;
-  }
-
   @JsonProperty("role")
   public String getRole() {
     return role;
@@ -85,11 +77,6 @@ public void setRole(String role) {
     this.role = role;
   }
 
-  @JsonProperty("request_id")
-  void setRequestId(String requestId) {
-    this.requestId = requestId;
-  }
-
   @JsonProperty("channels")
   void setChannels(List<ChannelStatusRequestDTO> channels) {
     this.channels = channels;

diff --git a/...est/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java b/...est/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelTest.java
@@ -1,7 +1,12 @@
 package net.snowflake.ingest.streaming.internal;
 
 import static java.time.ZoneOffset.UTC;
-import static net.snowflake.ingest.utils.Constants.*;
+import static net.snowflake.ingest.utils.Constants.ACCOUNT_URL;
+import static net.snowflake.ingest.utils.Constants.OPEN_CHANNEL_ENDPOINT;
+import static net.snowflake.ingest.utils.Constants.PRIVATE_KEY;
+import static net.snowflake.ingest.utils.Constants.RESPONSE_SUCCESS;
+import static net.snowflake.ingest.utils.Constants.ROLE;
+import static net.snowflake.ingest.utils.Constants.USER;
 import static org.mockito.ArgumentMatchers.argThat;
 
 import java.security.KeyPair;