Repository: incubator-distributedlog Updated Branches: refs/heads/release-0.4.0-incubating 2f467e4c2 -> 3c979e672
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 (cherry picked from commit 0c6e7949718abf5c30c150ffd045a8b765373cd6) Signed-off-by: Sijie Guo <si...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/3c979e67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/3c979e67 Diff: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/3c979e67 Branch: refs/heads/release-0.4.0-incubating Commit: 3c979e6724d9a5139f7d28db611aa7efa464bb32 Parents: 2f467e4 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:48:49 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/3c979e67/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 d37612a..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 " + loadAppraiserClass - + " Instantiated " + loadAppraiser.getClass().getCanonicalName()); + logger.info("Load appraiser class is " + loadAppraiserClassStr.or("not specified.") + " Instantiated " + + loadAppraiser.getClass().getCanonicalName()); StreamConfigProvider streamConfProvider = getStreamConfigProvider(dlConf, converter);
