From f73a3a6fb7c10abb4d512637911c7f9ad1c8d2d5 Mon Sep 17 00:00:00 2001
From: Ramkrishna <ramkrishna.s.vasudevan@intel.com>
Date: Thu, 28 Sep 2017 10:37:23 +0530
Subject: [PATCH] HBASE-18888 StealJobQueue should call super() to init the
 PriorityBlockingQueue (Ram)

---
 .../apache/hadoop/hbase/util/StealJobQueue.java  | 16 +---------------
 1 file changed, 1 insertion(+), 15 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java
index 9a5d5959b75..efd3da3a88d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java
@@ -50,21 +50,7 @@ public class StealJobQueue<T> extends PriorityBlockingQueue<T> {
   private final transient Condition notEmpty = lock.newCondition();
 
   public StealJobQueue(Comparator<? super T> comparator) {
-    this.stealFromQueue = new PriorityBlockingQueue<T>(11, comparator) {
-
-      private static final long serialVersionUID = -7070010365201826904L;
-
-      @Override
-      public boolean offer(T t) {
-        lock.lock();
-        try {
-          notEmpty.signal();
-          return super.offer(t);
-        } finally {
-          lock.unlock();
-        }
-      }
-    };
+    this(11, 11, comparator);
   }
 
   public StealJobQueue(int initCapacity, int stealFromQueueInitCapacity,