From 5c7fa12ab31d840955454c76d72b799486036313 Mon Sep 17 00:00:00 2001 From: Apekshit Sharma Date: Thu, 1 Sep 2016 17:23:54 -0700 Subject: [PATCH] HBASE-16101 addendum. Fixes runtime ClassCastException of Future in ProcedureWALPerformanceEvaluation. Change-Id: Ibe4f3a001b4f50e8598e367cc8648aeae129eee8 --- .../hbase/procedure2/store/wal/ProcedureWALPerformanceEvaluation.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPerformanceEvaluation.java b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPerformanceEvaluation.java index 210ac43..6f1332c 100644 --- a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPerformanceEvaluation.java +++ b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPerformanceEvaluation.java @@ -145,7 +145,7 @@ public class ProcedureWALPerformanceEvaluation extends AbstractHBaseTool { try { setupProcedureStore(); ExecutorService executor = Executors.newFixedThreadPool(numThreads); - Future[] futures = (Future[]) new Object[numThreads]; + Future[] futures = new Future[numThreads]; // Start worker threads. long start = System.currentTimeMillis(); for (int i = 0; i < numThreads; i++) { @@ -153,7 +153,7 @@ public class ProcedureWALPerformanceEvaluation extends AbstractHBaseTool { } boolean failure = false; try { - for (Future future : futures) { + for (Future future : futures) { long timeout = start + WORKER_THREADS_TIMEOUT_SEC * 1000 - System.currentTimeMillis(); failure |= (future.get(timeout, TimeUnit.MILLISECONDS).equals(EXIT_FAILURE)); } -- 2.3.2 (Apple Git-55)