Repository: incubator-distributedlog Updated Branches: refs/heads/master 8bb9cc004 -> 0c6e79497
DL-181: avoid starting failure due to call Optional.get() on an absent value see original JIRA for the detailed error msg Author: xieliang <xieliang...@gmail.com> Reviewers: Sijie Guo <si...@apache.org> Closes #110 from xieliang/DL-181-startingProxyFailed Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/0c6e7949 Tree: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/0c6e7949 Diff: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/0c6e7949 Branch: refs/heads/master Commit: 0c6e7949718abf5c30c150ffd045a8b765373cd6 Parents: 8bb9cc0 Author: xieliang <xieliang...@gmail.com> Authored: Mon Jan 9 22:47:09 2017 -0800 Committer: Sijie Guo <si...@apache.org> Committed: Mon Jan 9 22:47:09 2017 -0800 ---------------------------------------------------------------------- .../org/apache/distributedlog/service/DistributedLogServer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/0c6e7949/distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java ---------------------------------------------------------------------- diff --git a/distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java b/distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java index 7887445..81e476b 100644 --- a/distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java +++ b/distributedlog-service/src/main/java/org/apache/distributedlog/service/DistributedLogServer.java @@ -186,8 +186,8 @@ public class DistributedLogServer { } Class loadAppraiserClass = Class.forName(loadAppraiserClassStr.or(DEFAULT_LOAD_APPRIASER)); LoadAppraiser loadAppraiser = (LoadAppraiser) ReflectionUtils.newInstance(loadAppraiserClass); - logger.info("Supplied load appraiser class is " + loadAppraiserClassStr.get() - + " Instantiated " + loadAppraiser.getClass().getCanonicalName()); + logger.info("Load appraiser class is " + loadAppraiserClassStr.or("not specified.") + " Instantiated " + + loadAppraiser.getClass().getCanonicalName()); StreamConfigProvider streamConfProvider = getStreamConfigProvider(dlConf, converter);
