From 55cd146a75d28d4605c75bdc1d17a40982e6e1dd Mon Sep 17 00:00:00 2001 From: shopee-jin <40892357+shopee-jin@users.noreply.github.com> Date: Sat, 20 Feb 2021 16:28:08 +0800 Subject: [PATCH] [nitpick] ReadExampleCallable use readConnection --- .../hadoop/hbase/client/example/MultiThreadedClientExample.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/MultiThreadedClientExample.java b/hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/MultiThreadedClientExample.java index 6e9f44b4664..19e7f9e5d65 100644 --- a/hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/MultiThreadedClientExample.java +++ b/hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/MultiThreadedClientExample.java @@ -173,7 +173,7 @@ public class MultiThreadedClientExample extends Configured implements Tool { } else if (r < .50) { f = internalPool.submit(new SingleWriteExampleCallable(writeConnection, tableName)); } else { - f = internalPool.submit(new ReadExampleCallable(writeConnection, tableName)); + f = internalPool.submit(new ReadExampleCallable(readConnection, tableName)); } futures.add(f); }