From 9a09667a7606f5a89b925f17737743bdaa3b7e83 Mon Sep 17 00:00:00 2001
From: Shunping Huang <shunping@google.com>
Date: Thu, 25 Jun 2026 15:26:29 -0400
Subject: [PATCH] Fix typo

---
 .../beam/runners/direct/ExecutorServiceParallelExecutor.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
index 37cff06a267f..603832843bb6 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
@@ -355,10 +355,10 @@ private void shutdownIfNecessary(State newState) {
             new IllegalStateException(
                 "Error"
                     + (errors.size() == 1 ? "" : "s")
-                    + " occurred during pipeline execution:\\n"
+                    + " occurred during executor shutdown:\n"
                     + errors.stream()
                         .map(e -> e.getMessage() == null ? e.getClass().getName() : e.getMessage())
-                        .collect(Collectors.joining("\\n- ", "- ", "")));
+                        .collect(Collectors.joining("\n- ", "- ", "")));
         visibleUpdates.failed(exception);
       }
     } finally {