Addressed review comments

Signed-off-by: Kondaka <[email protected]>
kkondaka · Nov 29, 2023 · d1b513e · d1b513e
1 parent b1d6108
commit d1b513e
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/...repper-plugins/common/src/main/java/org/opensearch/dataprepper/plugins/sink/FileSink.java b/...repper-plugins/common/src/main/java/org/opensearch/dataprepper/plugins/sink/FileSink.java
@@ -120,14 +120,11 @@ public void shutdown() {
 
     @Override
     public void initialize() {
+        final StandardOpenOption[] openOptions = appendMode ?
+                new StandardOpenOption[] {StandardOpenOption.APPEND, StandardOpenOption.CREATE, StandardOpenOption.WRITE} :
+                new StandardOpenOption[] {};
         try {
-            if (appendMode) {
-
-
-                writer = Files.newBufferedWriter(Paths.get(outputFilePath), StandardCharsets.UTF_8, StandardOpenOption.APPEND, StandardOpenOption.CREATE, StandardOpenOption.WRITE);
-            } else {
-                writer = Files.newBufferedWriter(Paths.get(outputFilePath), StandardCharsets.UTF_8);
-            }
+            writer = Files.newBufferedWriter(Paths.get(outputFilePath), StandardCharsets.UTF_8, openOptions);
         } catch (final IOException ex) {
             throw new RuntimeException(format("Encountered exception opening/creating file %s", outputFilePath), ex);
         }