GH-5723: propagate maxExecutionTime as per-request HTTP response timeout

When setMaxExecutionTime(int) is called on an HTTP-based query or
update, the value is now applied as a per-request response timeout on
the HTTP connection, enforced client-side in addition to being sent as a
server-side hint.

HttpRequest gains an optional responseTimeout field (Duration). Both
SPARQLProtocolSession and RDF4JProtocolSession (which overrides
getQueryMethod/getUpdateMethod) set this field when maxQueryTime > 0.

The Apache HC5 client applies it via
RequestConfig.copy(defaultRequestConfig).setResponseTimeout(),
preserving factory-level defaults (connectionRequest
Timeout, redirectsEnabled, cookieSpec) while overriding only the
response timeout. The default RequestConfig is passed from the factory
to the client at construction time. The JDK client applies it via
HttpRequest.Builder#timeout(), with the per-request value taking
precedence over the global socketTimeoutMs from RDF4JHttpClientConfig.

Author: aschwarte10

core/http/client-apache5/src/main/java/org/eclipse/rdf4j/http/client/apache5/ApacheHC5RDF4JHttpClient.java

@@ -47,9 +47,17 @@ public class ApacheHC5RDF4JHttpClient implements RDF4JHttpClient {
 	 */
 	private final int maxRetries408;
 
-	public ApacheHC5RDF4JHttpClient(CloseableHttpClient httpClient, int maxConnectionsPerRoute) {
+	/**
+	 * Default request config used as the base when building per-request overrides, so that factory-level settings
+	 * (connectionRequestTimeout, redirectsEnabled, cookieSpec) are preserved.
+	 */
+	private final RequestConfig defaultRequestConfig;
+
+	public ApacheHC5RDF4JHttpClient(CloseableHttpClient httpClient, int maxConnectionsPerRoute,
+			RequestConfig defaultRequestConfig) {
 		this.httpClient = httpClient;
 		this.maxRetries408 = maxConnectionsPerRoute + 1;
+		this.defaultRequestConfig = defaultRequestConfig;
 	}
 
 	@Override
@@ -103,10 +111,13 @@ private HttpUriRequestBase buildRequest(HttpRequest request) throws IOException
 			hcRequest.addHeader(header.getName(), header.getValue());
 		}
 
-		// Apply per-request response timeout if present
+		// Apply per-request response timeout if present, copying from the default config so that
+		// factory-level settings (connectionRequestTimeout, redirectsEnabled, cookieSpec) are preserved.
 		request.getResponseTimeout()
 				.ifPresent(timeout -> hcRequest
-						.setConfig(RequestConfig.custom().setResponseTimeout(Timeout.of(timeout)).build()));
+						.setConfig(RequestConfig.copy(defaultRequestConfig)
+								.setResponseTimeout(Timeout.of(timeout))
+								.build()));
 
 		// Set body. Repeatable (byte-backed) bodies use ByteArrayEntity so that Apache HC5's
 		// RedirectExec can follow redirects and the 408 retry loop can re-send the request.

core/http/client-apache5/src/main/java/org/eclipse/rdf4j/http/client/apache5/ApacheHC5RDF4JHttpClientFactory.java

@@ -136,7 +136,7 @@ public RDF4JHttpClient create(RDF4JHttpClientConfig config) {
 		}
 
 		CloseableHttpClient httpClient = buildHttpClient(builder, config);
-		return new ApacheHC5RDF4JHttpClient(httpClient, config.getMaxConnectionsPerRoute());
+		return new ApacheHC5RDF4JHttpClient(httpClient, config.getMaxConnectionsPerRoute(), requestConfig);
 	}
 
 	/**

core/http/client/src/test/java/org/eclipse/rdf4j/http/client/SPARQLProtocolSessionTest.java

@@ -327,6 +327,32 @@ public void getQueryMethod_noResponseTimeout_whenMaxQueryTimeIsZero(String facto
 		assertThat(request.getResponseTimeout()).isEmpty();
 	}
 
+	@ParameterizedTest(name = "[{0}]")
+	@MethodSource("httpClientFactories")
+	public void getUpdateMethod_setsResponseTimeout_whenMaxQueryTimeIsPositive(String factoryName) {
+		this.factoryName = factoryName;
+		sparqlSession = createProtocolSession();
+
+		HttpRequest request = sparqlSession.getUpdateMethod(
+				QueryLanguage.SPARQL, "INSERT DATA { <urn:s> <urn:p> <urn:o> }", null, null, true, 30);
+
+		assertThat(request.getResponseTimeout())
+				.isPresent()
+				.hasValue(Duration.ofSeconds(30));
+	}
+
+	@ParameterizedTest(name = "[{0}]")
+	@MethodSource("httpClientFactories")
+	public void getUpdateMethod_noResponseTimeout_whenMaxQueryTimeIsZero(String factoryName) {
+		this.factoryName = factoryName;
+		sparqlSession = createProtocolSession();
+
+		HttpRequest request = sparqlSession.getUpdateMethod(
+				QueryLanguage.SPARQL, "INSERT DATA { <urn:s> <urn:p> <urn:o> }", null, null, true, 0);
+
+		assertThat(request.getResponseTimeout()).isEmpty();
+	}
+
 	@Test
 	public void getContentTypeSerialisationTest() {
 		{