Fix spotless issues

ozone-his · Jun 26, 2024 · 8d40808 · 8d40808
1 parent 592ba3b
commit 8d40808
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/ozonehis/data/pipelines/utils/Environment.java b/src/main/java/com/ozonehis/data/pipelines/utils/Environment.java
@@ -79,7 +79,8 @@ public static MiniCluster initMiniClusterWithEnv(Boolean isStreaming) throws Exc
         flinkConfig.setString("execution.checkpointing.unaligned.enabled", "true");
         flinkConfig.setString("execution.checkpointing.tolerable-failed-checkpoints", "50");
         flinkConfig.setString("table.dynamic-table-options.enabled", "true");
-        flinkConfig.setString("table.exec.resource.default-parallelism", System.getenv().getOrDefault("TASK_PARALLELISM", "1"));
+        flinkConfig.setString(
+                "table.exec.resource.default-parallelism", System.getenv().getOrDefault("TASK_PARALLELISM", "1"));
         flinkConfig.setString("state.backend.type", "rocksdb");
         flinkConfig.setString("state.backend.incremental", "true");
         flinkConfig.setString("state.checkpoints.dir", "file:///tmp/flink/checkpoints/");