Fix checkstyle

criteo · Nov 27, 2023 · 390485c · 390485c
1 parent 84cdc6a
commit 390485c
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/readers/hdfs/src/main/java/com/criteo/hadoop/garmadon/hdfs/writer/PartitionedWriter.java b/readers/hdfs/src/main/java/com/criteo/hadoop/garmadon/hdfs/writer/PartitionedWriter.java
@@ -44,9 +44,10 @@ public class PartitionedWriter<MESSAGE_KIND> implements Closeable {
 
     // A pool of worker dedicated to writing files to HDFS. Allows the reader to block for less time
     // the pool is static to avoid creating too many pools
-    private static final ExecutorService consumerCloserThreads = Executors.newCachedThreadPool();
+    private static final ExecutorService CONSUMER_CLOSER_THREADS = Executors.newCachedThreadPool();
+
     static {
-        Runtime.getRuntime().addShutdownHook(new Thread(consumerCloserThreads::shutdown));
+        Runtime.getRuntime().addShutdownHook(new Thread(CONSUMER_CLOSER_THREADS::shutdown));
     }
 
     private final BiFunction<Integer, LocalDateTime, ExpiringConsumer<MESSAGE_KIND>> writerBuilder;
@@ -222,7 +223,7 @@ private void possiblyCloseConsumers(Predicate<ExpiringConsumer<MESSAGE_KIND>> sh
 
                 return dailyWriters.entrySet().stream().map(e -> CompletableFuture.supplyAsync(
                         new CloseConsumerTask(shouldClose, partitionId, e.getKey(), e.getValue()),
-                        consumerCloserThreads
+                        CONSUMER_CLOSER_THREADS
                 ));
             }).collect(Collectors.toList());