You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ho...@apache.org on 2023/08/22 21:31:12 UTC
[solr] branch branch_9x updated: SOLR-16265: Fix NPE for req in Http2SolrClient (#1860)
This is an automated email from the ASF dual-hosted git repository.
houston pushed a commit to branch branch_9x
in repository https://gitbox.apache.org/repos/asf/solr.git
The following commit(s) were added to refs/heads/branch_9x by this push:
new 5eb27048136 SOLR-16265: Fix NPE for req in Http2SolrClient (#1860)
5eb27048136 is described below
commit 5eb27048136bd8dd5ae3e063014dea74ea3f6bb7
Author: Houston Putman <ho...@apache.org>
AuthorDate: Tue Aug 22 17:28:44 2023 -0400
SOLR-16265: Fix NPE for req in Http2SolrClient (#1860)
(cherry picked from commit c79c8994b5e29f69bcb5db12fcd42d332e3bba37)
---
.../org/apache/solr/client/solrj/impl/Http2SolrClient.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
index a4160df36b5..68d319e079f 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
@@ -528,34 +528,35 @@ public class Http2SolrClient extends SolrClient {
InputStreamResponseListener listener = new InputStreamResponseListener();
req = makeRequestAndSend(solrRequest, url, listener, false);
Response response = listener.get(idleTimeoutMillis, TimeUnit.MILLISECONDS);
+ url = req.getURI().toString();
InputStream is = listener.getInputStream();
assert ObjectReleaseTracker.track(is);
- return processErrorsAndResponse(solrRequest, response, is, req.getURI().toString());
+ return processErrorsAndResponse(solrRequest, response, is, url);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
abortCause = e;
throw new RuntimeException(e);
} catch (TimeoutException e) {
throw new SolrServerException(
- "Timeout occurred while waiting response from server at: " + req.getURI(), e);
+ "Timeout occurred while waiting response from server at: " + url, e);
} catch (ExecutionException e) {
Throwable cause = e.getCause();
abortCause = cause;
if (cause instanceof ConnectException) {
- throw new SolrServerException("Server refused connection at: " + req.getURI(), cause);
+ throw new SolrServerException("Server refused connection at: " + url, cause);
}
if (cause instanceof SolrServerException) {
throw (SolrServerException) cause;
} else if (cause instanceof IOException) {
throw new SolrServerException(
- "IOException occurred when talking to server at: " + req.getURI(), cause);
+ "IOException occurred when talking to server at: " + url, cause);
}
throw new SolrServerException(cause.getMessage(), cause);
} catch (SolrServerException | RuntimeException sse) {
abortCause = sse;
throw sse;
} finally {
- if (abortCause != null) {
+ if (abortCause != null && req != null) {
req.abort(abortCause);
}
}