format and improve comment

snowflakedb · Nov 12, 2024 · 27e973f · 27e973f
1 parent 2a7dd77
commit 27e973f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...n/java/com/snowflake/kafka/connector/internal/streaming/DirectStreamingClientHandler.java b/...n/java/com/snowflake/kafka/connector/internal/streaming/DirectStreamingClientHandler.java
@@ -46,8 +46,7 @@ public SnowflakeStreamingIngestClient createClient(
           SnowflakeStreamingIngestClientFactory.builder(
                   streamingClientProperties.clientName + "_" + createdClientId.getAndIncrement())
               .setProperties(streamingClientProperties.clientProperties)
-              .setParameterOverrides(streamingClientProperties.parameterOverrides)
-              ;
+              .setParameterOverrides(streamingClientProperties.parameterOverrides);
 
       SnowflakeStreamingIngestClient createdClient = builder.build();
 

diff --git a/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java b/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java
@@ -91,7 +91,8 @@ public StreamingClientProperties(Map<String, String> connectorConfig) {
     // Override only if the streaming client properties are explicitly set in config
     this.parameterOverrides = new HashMap<>();
     if (isIcebergEnabled) {
-      // todo extract to field
+      // TODO should be replaced by SnowflakeStreamingIngestClientFactory.builder.setIceberg(true)
+      // call in SNOW-1728002
       this.parameterOverrides.put("enable_iceberg_streaming", "true");
     }
     Optional<String> snowpipeStreamingMaxClientLag =