[beam] branch master updated (b0225ca084c -> 673a4cc7930)

[eg...@apache.org]

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

egalpin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from b0225ca084c Merge pull request #17111: [BEAM-14101] [CdapIO] Add ReceiverBuilder for SparkReceiverIO
     new 2cb2ee2ba3b Moves timestamp skew override to correct place
     new 0140c9c0020 Adds TestStream to verify window preservation of ElasticsearchIO#write
     new 60e9573ef6f Removes unnecessary line
     new 30d25de001e Adds validation that ES#Write outputs are in expected windows
     new 132d634ce14 Updates window verification test to assert the exact docs in the window
     new b9dabebc112 Uses guava Iterables over shaded avro version
     new 673a4cc7930 Merge pull request #22183 from egalpin/egalpin/timestamp-skew-es

The 36548 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |  6 ++
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |  6 ++
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |  6 ++
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |  6 ++
 .../elasticsearch/ElasticsearchIOTestCommon.java   | 86 ++++++++++++++++++++++
 .../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 14 ++--
 6 files changed, 117 insertions(+), 7 deletions(-)