This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch tvalentyn-gha
in repository https://gitbox.apache.org/repos/asf/beam.git
discard b3bf42b65e6 trigger
discard 00ad85d284d Attmpt to update pyarrow and add compat test suite
definitions.
discard 1ba37cd6d69 Define Python 3.12 test environments in tox.
add 5a42d54bfd1 Catch org.elasticsearch.client.ResponseException and
return document with withHasError(true)
add 29b47e69716 Remove status
add 84b1d92a73e Fix Style
add ff858b8b966 doc -> doc.withHasError(true)
add 3cbf7de5796 Add tests
add 1647872e054 Fix styles via spotlessApply
add 41772b015c2 rename INJECT_SOME_INVALID_DOCS and insert numDoc
add 00c59b251ec Catch with java.io.IOExecption
add 591d2c75679 explicit import
add 0f6a79cd2eb Removed unused import
add a7380297011 java util explicit import
add 035c88da6cf spotlessapply
add c6eabd19faf Fix max batch size
add 77da5add258 Rename message from
org.elasticsearch.client.ResponseException to java.io.IOException
add 1ee2f0ec5e6 Add test to verify response items message
add e010a3ecc66 spotlessapply
add 5ee569f930b fix comment
add ed84ba0e0dc Fix naming
add 1a399b96977 Verify the whole error message string
add e97064aa14c Remove mapToInputDoc
add 946f4959b7b retry 500-range http except 501
add 68790eb242f Add elasticResponseExceptionMessage predicate
add 3d897b27635 Merge pull request #31151 from andyzhangdialpad/master
add 6de9a60dc9e Skip tests using TFT in Beam ML unit test suite on Python
3.11+ (#31288)
add 041a8dd1173 Touch Samza ValidatesRunner trigger files
add f58a9d6680e Reapply "Add Redistribute translation to Samza runner"
add 2196758c20b Merge pull request #31270: Reapply "Add Redistribute
translation to Samza runner"
add a01bcfd53a8 Increase pyarrow upper bound. Add compat tests, and remove
some of the compat suites for pyarrow to reduce test suite runtime.
add db6a0ec8340 Define Python 3.12 test environments in tox.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b3bf42b65e6)
\
N -- N -- N refs/heads/tvalentyn-gha (db6a0ec8340)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Java_PVR_Samza.json | 3 +-
...beam_PostCommit_Java_ValidatesRunner_Samza.json | 3 +-
.../beam_PostCommit_Python_Dependency.json | 0
.../translation/RedistributeByKeyTranslator.java | 64 ++++++++++++++++++++++
.../samza/translation/ReshuffleTranslator.java | 14 ++++-
.../samza/translation/SamzaPipelineTranslator.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 6 ++
.../elasticsearch/ElasticsearchIOTestCommon.java | 52 ++++++++++++++++++
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 26 ++++++++-
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 54 ++++++++++++++----
.../ml/transforms/embeddings/huggingface_test.py | 2 +
sdks/python/setup.py | 20 ++-----
sdks/python/test-suites/tox/py38/build.gradle | 39 ++++++-------
sdks/python/tox.ini | 45 +++++----------
14 files changed, 247 insertions(+), 82 deletions(-)
delete mode 100644 .github/trigger_files/beam_PostCommit_Python_Dependency.json
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/RedistributeByKeyTranslator.java
