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 c2ef7a2..e0c2e5b 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 @@ -1148,7 +1148,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);