[beam] branch master updated: Use default context output rather than outputWithTimestamp for ElasticsearchIO

[ec...@apache.org]

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

echauchot 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 49d376c  Use default context output rather than outputWithTimestamp for ElasticsearchIO
     new 786d9b9  Merge pull request #16744 from egalpin/elasticsearch-default-output
49d376c is described below

commit 49d376c2c581e1cb2d244247f06eaf260ad77d26
Author: egalpin <eg...@users.noreply.github.com>
AuthorDate: Fri Feb 4 15:57:52 2022 -0500

    Use default context output rather than outputWithTimestamp for ElasticsearchIO
---
 .../java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
index 273443a..dc29ac6 100644
--- a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
+++ b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java
@@ -2359,9 +2359,10 @@ public class ElasticsearchIO {
 
         @Override
         public void output(
-            TupleTag<Document> tag, Document document, Instant timestamp, BoundedWindow ignored) {
-          // Note: window is intentionally unused, but required as a param to fit the interface
-          context.outputWithTimestamp(tag, document, timestamp);
+            TupleTag<Document> tag, Document document, Instant ignored1, BoundedWindow ignored2) {
+          // Note: window and timestamp are intentionally unused, but required as params to fit the
+          // interface
+          context.output(tag, document);
         }
       }