You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Robert Joseph Evans (JIRA)" <ji...@apache.org> on 2018/10/04 19:16:00 UTC
[jira] [Created] (STORM-3245) Log viewer cleanup failes if multiple
empty worker-artifact dirs
Robert Joseph Evans created STORM-3245:
------------------------------------------
Summary: Log viewer cleanup failes if multiple empty worker-artifact dirs
Key: STORM-3245
URL: https://issues.apache.org/jira/browse/STORM-3245
Project: Apache Storm
Issue Type: Bug
Components: storm-server
Affects Versions: 2.0.0
Reporter: Robert Joseph Evans
Assignee: Robert Joseph Evans
If a drive fills up for various reasons it is possible that we can create the directory for a worker in worker-artifacts, but not able to create the worker.yaml. If we get more than one of these on a node we get an exception like.
{code:java}
o.a.s.d.l.u.LogCleaner logviewer-cleanup [ERROR] Exception while cleaning up old log.
java.lang.IllegalStateException: Duplicate key ...
at java.util.stream.Collectors.lambda$throwingMerger$0(Collectors.java:133) ~[?:1.8.0_102]
at java.util.HashMap.merge(HashMap.java:1253) ~[?:1.8.0_102]
at java.util.stream.Collectors.lambda$toMap$58(Collectors.java:1320) ~[?:1.8.0_102]
at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:1.8.0_102]
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_102]
at java.util.TreeMap$KeySpliterator.forEachRemaining(TreeMap.java:2746) ~[?:1.8.0_102]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[?:1.8.0_102]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[?:1.8.0_102]
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_102]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_102]
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[?:1.8.0_102]
at org.apache.storm.daemon.logviewer.utils.WorkerLogs.identifyWorkerLogDirs(WorkerLogs.java:214) ~[storm-webapp-...{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)