Uploaded image for project: 'Solr'
  1. Solr
  2. SOLR-11392

StreamExpressionTest.testParallelExecutorStream fails too frequently

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • streaming expressions
    • None

    Description

      I've never been able to reproduce the failure but jenkins fails frequently with the following error:

      Stack Trace:
      org.apache.solr.client.solrj.impl.CloudSolrClient$RouteException: Error from server at http://127.0.0.1:38180/solr/workQueue_shard2_replica_n3: Expected mime type application/octet-stream but got text/html. <html>
      <head>
      <meta http-equiv="Content-Type" content="text/html;charset=ISO-8859-1"/>
      <title>Error 404 </title>
      </head>
      <body>
      <h2>HTTP ERROR: 404</h2>
      <p>Problem accessing /solr/workQueue_shard2_replica_n3/update. Reason:
      <pre>    Can not find: /solr/workQueue_shard2_replica_n3/update</pre></p>
      <hr /><a href="http://eclipse.org/jetty">Powered by Jetty:// 9.3.20.v20170531</a><hr/>
      </body>
      </html>
      

      What appears to be happening is that the test framework is having trouble setting up the collection.

      Here is the test code:

      @Test
        public void testParallelExecutorStream() throws Exception {
          CollectionAdminRequest.createCollection("workQueue", "conf", 2, 1).process(cluster.getSolrClient());
          AbstractDistribZkTestBase.waitForRecoveriesToFinish("workQueue", cluster.getSolrClient().getZkStateReader(),
              false, true, TIMEOUT);
          CollectionAdminRequest.createCollection("mainCorpus", "conf", 2, 1).process(cluster.getSolrClient());
          AbstractDistribZkTestBase.waitForRecoveriesToFinish("mainCorpus", cluster.getSolrClient().getZkStateReader(),
              false, true, TIMEOUT);
          CollectionAdminRequest.createCollection("destination", "conf", 2, 1).process(cluster.getSolrClient());
          AbstractDistribZkTestBase.waitForRecoveriesToFinish("destination", cluster.getSolrClient().getZkStateReader(),
              false, true, TIMEOUT);
      
          UpdateRequest workRequest = new UpdateRequest();
          UpdateRequest dataRequest = new UpdateRequest();
      
      
          for (int i = 0; i < 500; i++) {
            workRequest.add(id, String.valueOf(i), "expr_s", "update(destination, batchSize=50, search(mainCorpus, q=id:"+i+", rows=1, sort=\"id asc\", fl=\"id, body_t, field_i\"))");
            dataRequest.add(id, String.valueOf(i), "body_t", "hello world "+i, "field_i", Integer.toString(i));
          }
      
          workRequest.commit(cluster.getSolrClient(), "workQueue");
          dataRequest.commit(cluster.getSolrClient(), "mainCorpus");
      

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              jbernste Joel Bernstein
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated: