(beam) branch master updated: cancel user code with interruption after timeout (#39018)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

damondouglas pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 466989d50a4 cancel user code with interruption after timeout (#39018)
466989d50a4 is described below

commit 466989d50a45656dc3f170c556da473761746442
Author: Sam Whittle <sc...@users.noreply.github.com>
AuthorDate: Thu Jun 18 16:22:44 2026 +0200

    cancel user code with interruption after timeout (#39018)
---
 .../io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java
index b318cac1737..616a178d1c3 100644
--- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java
+++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java
@@ -535,6 +535,7 @@ class Call<RequestT, ResponseT> extends PTransform<PCollection<RequestT>, Result
       try {
         return future.get(timeout.getMillis(), TimeUnit.MILLISECONDS);
       } catch (TimeoutException | InterruptedException e) {
+        future.cancel(true);
         throw new UserCodeTimeoutException(e);
       } catch (ExecutionException e) {
         parseAndThrow(future, e);