Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-10623: Fix pre-commit

This commit is contained in:
Joel Bernstein 2017-05-18 12:50:42 -04:00
parent f326cfb175
commit c373b71b25
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SqlStream.java
View File

@ -24,6 +24,7 @@ import java.util.List;
import java.util.Locale; import java.util.Locale;
import java.util.Map; import java.util.Map;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.Random;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import org.apache.solr.client.solrj.impl.CloudSolrClient; import org.apache.solr.client.solrj.impl.CloudSolrClient;
@ -252,7 +253,7 @@ public class SqlStream extends TupleStream implements Expressible {
try { try {
List<String> shardUrls = getShards(this.zkHost, this.collection, this.streamContext); List<String> shardUrls = getShards(this.zkHost, this.collection, this.streamContext);
Collections.shuffle(shardUrls); Collections.shuffle(shardUrls, new Random());
String url = shardUrls.get(0); String url = shardUrls.get(0);
ModifiableSolrParams mParams = new ModifiableSolrParams(params); ModifiableSolrParams mParams = new ModifiableSolrParams(params);
mParams.add(CommonParams.QT, "/sql"); mParams.add(CommonParams.QT, "/sql");