From cdc0262cc8fcbb7d32503c427268cb7f9c4b0878 Mon Sep 17 00:00:00 2001 From: Sanjeev Srivatsa Date: Tue, 8 Sep 2015 19:35:53 -0700 Subject: [PATCH] changed Canary to use instance of ExtendedSink --- hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java index 9a6c376..6b7c2b1 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java @@ -1104,7 +1104,7 @@ public final class Canary implements Tool { ExecutorService executor = new ScheduledThreadPoolExecutor(numThreads); Class sinkClass = - conf.getClass("hbase.canary.sink.class", StdOutSink.class, Sink.class); + conf.getClass("hbase.canary.sink.class", RegionServerStdOutSink.class, Sink.class); Sink sink = ReflectionUtils.newInstance(sinkClass); int exitCode = ToolRunner.run(conf, new Canary(executor, sink), args); -- 1.9.5