This is an automated email from the ASF dual-hosted git repository. johncasey pushed a commit to branch johnjcasey-update-ps-eh-documentation in repository https://gitbox.apache.org/repos/asf/beam.git
commit 79e91f65965c14b3099c369452a788f365dec77f Author: johnjcasey <95318300+johnjca...@users.noreply.github.com> AuthorDate: Thu Sep 11 11:18:52 2025 -0400 Update PubsubIO.java documentation --- .../src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java index 8daa40514e8..d62d294ed2a 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java @@ -1559,9 +1559,8 @@ public class PubsubIO { /** * Writes any serialization failures out to the Error Handler. See {@link ErrorHandler} for - * details on how to configure an Error Handler. Error Handlers are not well supported when - * writing to topics with schemas, and it is not recommended to configure an error handler if - * the target topic has a schema. + * details on how to configure an Error Handler. Schema errors are not handled by Error + * Handlers, and will be handled using the default behavior of the runner. */ public Write<T> withErrorHandler(ErrorHandler<BadRecord, ?> badRecordErrorHandler) { return toBuilder()