Skip to content

Commit b642c5c

Browse files
authored
Fix typo (#39123)
1 parent 0c51b0d commit b642c5c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -355,10 +355,10 @@ private void shutdownIfNecessary(State newState) {
355355
new IllegalStateException(
356356
"Error"
357357
+ (errors.size() == 1 ? "" : "s")
358-
+ " occurred during pipeline execution:\\n"
358+
+ " occurred during executor shutdown:\n"
359359
+ errors.stream()
360360
.map(e -> e.getMessage() == null ? e.getClass().getName() : e.getMessage())
361-
.collect(Collectors.joining("\\n- ", "- ", "")));
361+
.collect(Collectors.joining("\n- ", "- ", "")));
362362
visibleUpdates.failed(exception);
363363
}
364364
} finally {

0 commit comments

Comments
 (0)