Repository: bookkeeper Updated Branches: refs/heads/master 5de01f700 -> 130ebfa8f
BOOKKEEPER-805: NullPointException in bookie server when using twitter-ostrich-provider (Youngjoon Kim via sijie) Project: http://git-wip-us.apache.org/repos/asf/bookkeeper/repo Commit: http://git-wip-us.apache.org/repos/asf/bookkeeper/commit/130ebfa8 Tree: http://git-wip-us.apache.org/repos/asf/bookkeeper/tree/130ebfa8 Diff: http://git-wip-us.apache.org/repos/asf/bookkeeper/diff/130ebfa8 Branch: refs/heads/master Commit: 130ebfa8f3763c1b98b29124a2bb648b2a810281 Parents: 5de01f7 Author: Sijie Guo <[email protected]> Authored: Fri Dec 5 21:54:19 2014 -0800 Committer: Sijie Guo <[email protected]> Committed: Fri Dec 5 21:54:19 2014 -0800 ---------------------------------------------------------------------- .../bookkeeper/stats/twitter/ostrich/OstrichProvider.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/130ebfa8/bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java ---------------------------------------------------------------------- diff --git a/bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java b/bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java index a56bf2f..f0cba13 100644 --- a/bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java +++ b/bookkeeper-stats-providers/twitter-ostrich-provider/src/main/java/org/apache/bookkeeper/stats/twitter/ostrich/OstrichProvider.java @@ -18,6 +18,7 @@ package org.apache.bookkeeper.stats.twitter.ostrich; import com.twitter.ostrich.admin.CustomHttpHandler; import com.twitter.ostrich.admin.RuntimeEnvironment; +import com.twitter.ostrich.admin.StatsFactory; import com.twitter.util.Duration; import org.apache.bookkeeper.stats.StatsLogger; import org.apache.bookkeeper.stats.StatsProvider; @@ -28,6 +29,7 @@ import scala.collection.immutable.List; import scala.collection.immutable.List$; import scala.collection.immutable.Map; import scala.collection.immutable.Map$; +import scala.util.matching.Regex; import java.util.concurrent.TimeUnit; @@ -55,13 +57,10 @@ public class OstrichProvider implements StatsProvider { public void start(Configuration conf) { if (conf.getBoolean(STATS_EXPORT, false)) { statsExporter = new com.twitter.ostrich.admin.AdminServiceFactory( - conf.getInt(STATS_HTTP_PORT, 9002), 20, null, Some.apply(""), null, + conf.getInt(STATS_HTTP_PORT, 9002), 20, List$.MODULE$.<StatsFactory>empty(), Some.apply(""), List$.MODULE$.<Regex>empty(), OstrichProvider.<String, CustomHttpHandler>emptyMap(), list(Duration.apply(1, TimeUnit.MINUTES)) ).apply(RuntimeEnvironment.apply(this, new String[0])); } - if (null != statsExporter) { - statsExporter.start(); - } } @Override
