From 50d8e749b9478c4fbd04f99824217e05874e94f0 Mon Sep 17 00:00:00 2001 From: Roman Fursov Date: Tue, 13 Dec 2022 11:37:20 +0100 Subject: [PATCH] Rename DEFAULT_ROLLOVER_TIME_MILLISECONDS to DEFAULT_ROLLOVER_CHECK_INTERVAL_DURATION (#7) A leftover from #4 --- .../bigquery/dwhassessment/hooks/logger/EventLogger.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java b/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java index 7da514e..20b151a 100644 --- a/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java +++ b/src/java/com/google/cloud/bigquery/dwhassessment/hooks/logger/EventLogger.java @@ -39,7 +39,7 @@ public class EventLogger { private static final int MAX_RETRIES = 2; private static final Duration SHUTDOWN_WAIT_TIME = Duration.ofSeconds(5); private static final int QUERY_EVENTS_QUEUE_DEFAULT_SIZE = 64; - private static final Duration DEFAULT_ROLLOVER_TIME_MILLISECONDS = Duration.ofSeconds(600); + private static final Duration DEFAULT_ROLLOVER_CHECK_INTERVAL_DURATION = Duration.ofMinutes(10); private final DatePartitionedRecordsWriterFactory logger; private final EventRecordConstructor eventRecordConstructor; @@ -97,7 +97,7 @@ protected EventLogger(HiveConf conf, Clock clock) { long rolloverIntervalMilliseconds = conf.getTimeDuration( HIVE_QUERY_EVENTS_ROLLOVER_CHECK_INTERVAL.getConfName(), - DEFAULT_ROLLOVER_TIME_MILLISECONDS.toMillis(), + DEFAULT_ROLLOVER_CHECK_INTERVAL_DURATION.toMillis(), TimeUnit.MILLISECONDS); logWriter.scheduleWithFixedDelay(