You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2016/02/07 22:22:55 UTC
hbase git commit: HBASE-15217 Canary -regionserver fails with cast
exception (Ted Yu)
Repository: hbase
Updated Branches:
refs/heads/0.98 b3fe25566 -> 2c126026c
HBASE-15217 Canary -regionserver fails with cast exception (Ted Yu)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2c126026
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2c126026
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2c126026
Branch: refs/heads/0.98
Commit: 2c126026cb7c735ad300e1363486791a330af18b
Parents: b3fe255
Author: Andrew Purtell <ap...@apache.org>
Authored: Sun Feb 7 12:27:24 2016 -0800
Committer: Andrew Purtell <ap...@apache.org>
Committed: Sun Feb 7 12:27:24 2016 -0800
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/tool/Canary.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/2c126026/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/Canary.java
----------------------------------------------------------------------
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<? 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);