From def4739fac4b435a86c569afd4f09a2bfd613b17 Mon Sep 17 00:00:00 2001 From: Michael Stack Date: Mon, 26 Feb 2018 16:26:36 -0800 Subject: [PATCH] HBASE-20069 fix existing findbugs errors in hbase-server; ADDENDUM Address review --- .../apache/hadoop/hbase/regionserver/MemStoreFlusher.java | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java index a0e65ec616..23321e8550 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java @@ -90,17 +90,9 @@ class MemStoreFlusher implements FlushRequester { private FlushType flushType; /** - * Singleton instance of this class inserted into flush queue. + * Singleton instance inserted into flush queue used for signaling. */ - private static final WakeupFlushThread WAKEUPFLUSH_INSTANCE = new WakeupFlushThread(); - - /** - * Marker class used as a token inserted into flush queue that ensures the flusher does not sleep. - * Create a single instance only. - */ - private static final class WakeupFlushThread implements FlushQueueEntry { - private WakeupFlushThread() {} - + private static final FlushQueueEntry WAKEUPFLUSH_INSTANCE = new FlushQueueEntry() { @Override public long getDelay(TimeUnit unit) { return 0; @@ -120,7 +112,7 @@ class MemStoreFlusher implements FlushRequester { public int hashCode() { return 42; } - } + }; /** -- 2.11.0 (Apple Git-81)