SNOW-1805174 Format.sh

snowflakedb · Nov 20, 2024 · 7ca6cfc · 7ca6cfc
1 parent 309fa4d
commit 7ca6cfc
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 19 deletions.
diff --git a/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java b/src/main/java/com/snowflake/kafka/connector/SnowflakeSinkConnectorConfig.java
@@ -261,10 +261,10 @@ public static void setDefaultValues(Map<String, String> config) {
           "");
 
       setFieldToDefaultValues(
-              config,
-              SNOWPIPE_STREAMING_MAX_CLIENT_LAG,
-              SNOWPIPE_STREAMING_MAX_CLIENT_LAG_SECONDS_DEFAULT,
-              "seconds");
+          config,
+          SNOWPIPE_STREAMING_MAX_CLIENT_LAG,
+          SNOWPIPE_STREAMING_MAX_CLIENT_LAG_SECONDS_DEFAULT,
+          "seconds");
     }
   }
 

diff --git a/src/test/java/com/snowflake/kafka/connector/ConnectorConfigValidatorTest.java b/src/test/java/com/snowflake/kafka/connector/ConnectorConfigValidatorTest.java
@@ -490,9 +490,9 @@ public void testErrorLog_DisallowedValues() {
   @Test
   public void testStreamingEmptyFlushTime() {
     Map<String, String> config =
-            SnowflakeSinkConnectorConfigBuilder.streamingConfig()
-                    .withSingleBufferEnabled(false)
-                    .build();
+        SnowflakeSinkConnectorConfigBuilder.streamingConfig()
+            .withSingleBufferEnabled(false)
+            .build();
     config.remove(SnowflakeSinkConnectorConfig.BUFFER_FLUSH_TIME_SEC);
     assertThatThrownBy(() -> connectorConfigValidator.validateConfig(config))
         .isInstanceOf(SnowflakeKafkaConnectorException.class)
@@ -502,9 +502,9 @@ public void testStreamingEmptyFlushTime() {
   @Test
   public void testStreamingFlushTimeSmall() {
     Map<String, String> config =
-            SnowflakeSinkConnectorConfigBuilder.streamingConfig()
-                    .withSingleBufferEnabled(false)
-                    .build();
+        SnowflakeSinkConnectorConfigBuilder.streamingConfig()
+            .withSingleBufferEnabled(false)
+            .build();
     config.put(
         SnowflakeSinkConnectorConfig.BUFFER_FLUSH_TIME_SEC,
         (StreamingUtils.STREAMING_BUFFER_FLUSH_TIME_MINIMUM_SEC - 1) + "");
@@ -516,9 +516,9 @@ public void testStreamingFlushTimeSmall() {
   @Test
   public void testStreamingFlushTimeNotNumber() {
     Map<String, String> config =
-            SnowflakeSinkConnectorConfigBuilder.streamingConfig()
-                    .withSingleBufferEnabled(false)
-                    .build();
+        SnowflakeSinkConnectorConfigBuilder.streamingConfig()
+            .withSingleBufferEnabled(false)
+            .build();
     config.put(SnowflakeSinkConnectorConfig.BUFFER_FLUSH_TIME_SEC, "fdas");
     assertThatThrownBy(() -> connectorConfigValidator.validateConfig(config))
         .isInstanceOf(SnowflakeKafkaConnectorException.class)
@@ -552,9 +552,9 @@ public void testStreamingEmptyBufferCount() {
   @Test
   public void testStreamingBufferCountNegative() {
     Map<String, String> config =
-            SnowflakeSinkConnectorConfigBuilder.streamingConfig()
-                    .withSingleBufferEnabled(false)
-                    .build();
+        SnowflakeSinkConnectorConfigBuilder.streamingConfig()
+            .withSingleBufferEnabled(false)
+            .build();
     config.put(BUFFER_COUNT_RECORDS, "-1");
     assertThatThrownBy(() -> connectorConfigValidator.validateConfig(config))
         .isInstanceOf(SnowflakeKafkaConnectorException.class)
@@ -564,9 +564,9 @@ public void testStreamingBufferCountNegative() {
   @Test
   public void testStreamingBufferCountValue() {
     Map<String, String> config =
-            SnowflakeSinkConnectorConfigBuilder.streamingConfig()
-                    .withSingleBufferEnabled(false)
-                    .build();
+        SnowflakeSinkConnectorConfigBuilder.streamingConfig()
+            .withSingleBufferEnabled(false)
+            .build();
     config.put(BUFFER_COUNT_RECORDS, "adssadsa");
     assertThatThrownBy(() -> connectorConfigValidator.validateConfig(config))
         .isInstanceOf(SnowflakeKafkaConnectorException.class)