[ https://issues.apache.org/jira/browse/SOLR-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629150#comment-17629150 ]
Joel Bernstein commented on SOLR-16510: --------------------------------------- I think I see the issue. I'll put up a PR for it. > StreamDecoratorTest.testParallelTerminatingDaemonUpdateStream > ConcurrentModificationException > --------------------------------------------------------------------------------------------- > > Key: SOLR-16510 > URL: https://issues.apache.org/jira/browse/SOLR-16510 > Project: Solr > Issue Type: Bug > Security Level: Public(Default Security Level. Issues are Public) > Components: streaming expressions > Reporter: Kevin Risden > Assignee: Joel Bernstein > Priority: Major > > https://lists.apache.org/list?bui...@solr.apache.org:lte=1y:java.util.ConcurrentModificationException > {code:java} > org.apache.solr.client.solrj.io.stream.StreamDecoratorTest > > testParallelTerminatingDaemonUpdateStream FAILED > java.io.IOException: Query to '/stream?action=list&indent=off' failed due > to: (500) > {"error":{"msg":"java.util.ConcurrentModificationException","trace":"java.io.IOException: > java.util.ConcurrentModificationException\n\tat > org.apache.solr.client.solrj.io.stream.TupleStream.lambda$writeMap$0(TupleStream.java:110)\n\tat > > org.apache.solr.common.util.JsonTextWriter.writeIterator(JsonTextWriter.java:149)\n\tat > > org.apache.solr.common.util.TextWriter.writeIterator(TextWriter.java:256)\n\tat > org.apache.solr.common.util.TextWriter.writeVal(TextWriter.java:85)\n\tat > org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:212)\n\tat > org.apache.solr.common.util.TextWriter.writeVal(TextWriter.java:47)\n\tat > org.apache.solr.common.util.JsonTextWriter$2.put(JsonTextWriter.java:186)\n\tat > > org.apache.solr.client.solrj.io.stream.TupleStream.writeMap(TupleStream.java:79)\n\tat > > org.apache.solr.common.util.JsonTextWriter.writeMap(JsonTextWriter.java:173)\n\tat > org.apache.solr.common.util.TextWriter.writeMap(TextWriter.java:247)\n\tat > org.apache.solr.common.util.TextWriter.writeVal(TextWriter.java:87)\n\tat > org.apache.solr.response.TextResponseWriter.writeVal(TextResponseWriter.java:212)\n\tat > org.apache.solr.common.util.TextWriter.writeVal(TextWriter.java:47)\n\tat > org.apache.solr.common.util.JsonTextWriter.writeNamedListAsMapWithDups(JsonTextWriter.java:403)\n\tat > > org.apache.solr.common.util.JsonTextWriter.writeNamedList(JsonTextWriter.java:311)\n\tat > org.apache.solr.response.JSONWriter.writeResponse(JSONWriter.java:77)\n\tat > org.apache.solr.response.JSONResponseWriter.write(JSONResponseWriter.java:63)\n\tat > > org.apache.solr.response.QueryResponseWriterUtil.writeQueryResponse(QueryResponseWriterUtil.java:71)\n\tat > > org.apache.solr.servlet.HttpSolrCall.writeResponse(HttpSolrCall.java:974)\n\tat > org.apache.solr.servlet.HttpSolrCall.call(HttpSolrCall.java:579)\n\tat > org.apache.solr.servlet.SolrDispatchFilter.dispatch(SolrDispatchFilter.java:251)\n\tat > > org.apache.solr.servlet.SolrDispatchFilter.lambda$doFilter$0(SolrDispatchFilter.java:219)\n\tat > > org.apache.solr.servlet.ServletUtils.traceHttpRequestExecution2(ServletUtils.java:257)\n\tat > > org.apache.solr.servlet.ServletUtils.rateLimitRequest(ServletUtils.java:227)\n\tat > > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:214)\n\tat > > org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:196)\n\tat > org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)\n\tat > org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)\n\tat > > org.apache.solr.client.solrj.embedded.JettySolrRunner$DebugFilter.doFilter(JettySolrRunner.java:186)\n\tat > org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)\n\tat > org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)\n\tat > > org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:552)\n\tat > > org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)\n\tat > > org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)\n\tat > > org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)\n\tat > > org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440)\n\tat > > org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)\n\tat > > org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505)\n\tat > > org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)\n\tat > > org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)\n\tat > > org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355)\n\tat > > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)\n\tat > > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\n\tat > > org.eclipse.jetty.rewrite.handler.RewriteHandler.handle(RewriteHandler.java:322)\n\tat > > org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:722)\n\tat > > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\n\tat > org.eclipse.jetty.server.Server.handle(Server.java:516)\n\tat > org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487)\n\tat > org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732)\n\tat > org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479)\n\tat > org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)\n\tat > > org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)\n\tat > org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)\n\tat > org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)\n\tat > org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)\n\tat > > org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)\n\tat > java.base/java.lang.Thread.run(Thread.java:829)\nCaused by: > java.util.ConcurrentModificationException\n\tat > java.base/java.util.HashMap$HashIterator.nextNode(HashMap.java:1511)\n\tat > java.base/java.util.HashMap$ValueIterator.next(HashMap.java:1539)\n\tat > org.apache.solr.handler.StreamHandler$DaemonCollectionStream.read(StreamHandler.java:432)\n\tat > > org.apache.solr.client.solrj.io.stream.TupleStream.lambda$writeMap$0(TupleStream.java:85)\n\t... > 56 more\n","code":500}} > at > __randomizedtesting.SeedInfo.seed([D5AB152AF549890:FC3E693AFB3E578E]:0) > at > org.apache.solr.client.solrj.io.stream.SolrStream.constructParser(SolrStream.java:319) > at > org.apache.solr.client.solrj.io.stream.SolrStream.open(SolrStream.java:131) > at > org.apache.solr.client.solrj.io.stream.StreamDecoratorTest.testParallelTerminatingDaemonUpdateStream(StreamDecoratorTest.java:3620) > at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.base/java.lang.reflect.Method.invoke(Method.java:566) > at > com.carrotsearch.randomizedtesting.RandomizedRunner.invoke(RandomizedRunner.java:1758) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$8.evaluate(RandomizedRunner.java:946) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$9.evaluate(RandomizedRunner.java:982) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$10.evaluate(RandomizedRunner.java:996) > at > com.carrotsearch.randomizedtesting.rules.SystemPropertiesRestoreRule$1.evaluate(SystemPropertiesRestoreRule.java:80) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) > at > org.apache.lucene.tests.util.TestRuleSetupTeardownChained$1.evaluate(TestRuleSetupTeardownChained.java:44) > at > org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43) > at > org.apache.lucene.tests.util.TestRuleThreadAndTestName$1.evaluate(TestRuleThreadAndTestName.java:45) > at > org.apache.lucene.tests.util.TestRuleIgnoreAfterMaxFailures$1.evaluate(TestRuleIgnoreAfterMaxFailures.java:60) > at > org.apache.lucene.tests.util.TestRuleMarkFailure$1.evaluate(TestRuleMarkFailure.java:44) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > com.carrotsearch.randomizedtesting.ThreadLeakControl$StatementRunner.run(ThreadLeakControl.java:390) > at > com.carrotsearch.randomizedtesting.ThreadLeakControl.forkTimeoutingTask(ThreadLeakControl.java:843) > at > com.carrotsearch.randomizedtesting.ThreadLeakControl$3.evaluate(ThreadLeakControl.java:490) > at > com.carrotsearch.randomizedtesting.RandomizedRunner.runSingleTest(RandomizedRunner.java:955) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$5.evaluate(RandomizedRunner.java:840) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$6.evaluate(RandomizedRunner.java:891) > at > com.carrotsearch.randomizedtesting.RandomizedRunner$7.evaluate(RandomizedRunner.java:902) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43) > at > org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43) > at > com.carrotsearch.randomizedtesting.rules.SystemPropertiesRestoreRule$1.evaluate(SystemPropertiesRestoreRule.java:80) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) > at > org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > org.apache.lucene.tests.util.TestRuleStoreClassName$1.evaluate(TestRuleStoreClassName.java:38) > at > com.carrotsearch.randomizedtesting.rules.NoShadowingOrOverridesOnMethodsRule$1.evaluate(NoShadowingOrOverridesOnMethodsRule.java:40) > at > com.carrotsearch.randomizedtesting.rules.NoShadowingOrOverridesOnMethodsRule$1.evaluate(NoShadowingOrOverridesOnMethodsRule.java:40) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > org.apache.lucene.tests.util.TestRuleAssertionsRequired$1.evaluate(TestRuleAssertionsRequired.java:53) > at > org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43) > at > org.apache.lucene.tests.util.TestRuleMarkFailure$1.evaluate(TestRuleMarkFailure.java:44) > at > org.apache.lucene.tests.util.TestRuleIgnoreAfterMaxFailures$1.evaluate(TestRuleIgnoreAfterMaxFailures.java:60) > at > org.apache.lucene.tests.util.TestRuleIgnoreTestSuites$1.evaluate(TestRuleIgnoreTestSuites.java:47) > at org.junit.rules.RunRules.evaluate(RunRules.java:20) > at > com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36) > at > com.carrotsearch.randomizedtesting.ThreadLeakControl$StatementRunner.run(ThreadLeakControl.java:390) > at > com.carrotsearch.randomizedtesting.ThreadLeakControl.lambda$forkTimeoutingTask$0(ThreadLeakControl.java:850) > at java.base/java.lang.Thread.run(Thread.java:829) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@solr.apache.org For additional commands, e-mail: issues-h...@solr.apache.org