Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14384 changed Canary to use instance of ExtendedSink 

Signed-off-by: Elliott Clark <eclark@apache.org>
This commit is contained in:
Sanjeev Srivatsa 2015-09-08 19:35:53 -07:00 committed by Elliott Clark
parent 0f0cdc5131
commit 4418f3e025
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java
View File

@ -1104,7 +1104,7 @@ public final class Canary implements Tool {
ExecutorService executor = new ScheduledThreadPoolExecutor(numThreads);
Class<? extends Sink> 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);