This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from ee32c23 (commit)
to c499c49 (commit)
from ee32c23 [BEAM-11934] Remove Dataflow override of streaming WriteFiles
with runner determined sharding (#15178)
add 5ff77d7 [BEAM-12474] Write PubsubIO parsing errors to dead-letter
topic
add d99ebb6 Merge pull request #15037: [BEAM-12474] Write PubsubIO
parsing errors to dead-letter topic
add c367dab [BEAM-4152] Disable window tests on Dataflow (#15188)
add fd2dac0 [BEAM-12548] Implement EqualsFloat test helper (#15175)
add a2bb1e1 Fix formatting using go fmt (#15189)
add 47f8d0d [BEAM-4152] Add merging strategy for sessions to
WindowingStrategy proto (#15190)
add 8790481 [BEAM-12613] Enable Python build tests for Samza (#15169)
add aac6cbc Fix spelling.
add c499c49 Fix spelling.
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 6 +-
.test-infra/jenkins/README.md | 3 +-
...PostCommit_Python_ValidatesRunner_Samza.groovy} | 10 +-
CHANGES.md | 1 +
README.md | 2 +-
.../samza/metrics/SamzaMetricsContainer.java | 2 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 8 +-
sdks/go/pkg/beam/core/runtime/xlangx/payload.go | 2 +-
sdks/go/pkg/beam/testing/passert/equals.go | 1 -
sdks/go/pkg/beam/testing/passert/equals_test.go | 2 +-
sdks/go/pkg/beam/testing/passert/floats.go | 91 ++++++++++-
sdks/go/pkg/beam/testing/passert/floats_test.go | 97 +++++++++++
sdks/go/pkg/beam/transforms/stats/stats.shims.go | 151 +++++++++--------
sdks/go/test/integration/integration.go | 6 +-
.../apache/beam/sdk/transforms/WithFailures.java | 19 +++
.../apache/beam/sdk/values/EncodableThrowable.java | 69 ++++++++
.../beam/sdk/transforms/WithFailuresTest.java | 31 ++++
.../beam/sdk/values/EncodableThrowableTest.java | 57 +++++++
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 119 +++++++++++++-
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 179 +++++++++++++++------
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 51 ++++++
.../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 44 +++++
.../{spark_runner_test.py => samza_runner_test.py} | 122 ++++++++------
sdks/python/test-suites/gradle.properties | 5 +-
sdks/python/test-suites/portable/build.gradle | 6 +
sdks/python/test-suites/portable/common.gradle | 25 +++
sdks/python/tox.ini | 5 +
.../en/documentation/patterns/side-inputs.md | 2 +-
28 files changed, 913 insertions(+), 203 deletions(-)
copy .test-infra/jenkins/{job_PostCommit_Python_ValidatesRunner_Spark.groovy
=> job_PostCommit_Python_ValidatesRunner_Samza.groovy} (85%)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/values/EncodableThrowable.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/values/EncodableThrowableTest.java
copy sdks/python/apache_beam/runners/portability/{spark_runner_test.py =>
samza_runner_test.py} (61%)
