This is an automated email from the ASF dual-hosted git repository.
xqhu 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 f96128a33bd Update PubsubIO.java documentation (#36120)
f96128a33bd is described below
commit f96128a33bd17feec3d7f62dec261d1088c291dc
Author: johnjcasey <[email protected]>
AuthorDate: Thu Sep 11 15:04:22 2025 -0400
Update PubsubIO.java documentation (#36120)
---
.../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()
