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 92ea5f5 (commit)
to 39cf3fc (commit)
from 92ea5f5 [BEAM-11088] Add TestStream package to Go SDK testing
capabilities (#15253)
add 8b6f675 Merge pull request #15272:[BEAM-12712] Exclude runners that
can't handle looping timers
add 3a84a78 [BEAM-12703] Fix universal metrics. (#15260)
add ec62170 [BEAM-12702] Pull step unique names from pipeline for
metrics. (#15261)
add e11fbba fix GroupIntoBatches
add 03a1cca Merge pull request #15273: [BEAM-12720] fix GroupIntoBatches
incorrectly clearing variables after outputting them
add 74963dc [BEAM-12715] Use shard number specified by user in
SnowflakeIO batch writeFiles
add 3898642 Merge pull request #15255: [BEAM-12715] Snowflake IO use
getShards in batch write mode
add dbb44bf [BEAM-12678] Add dependency of java jars when running go VR
on portable runners (#15276)
add 64188aa [BEAM-12671] Mark known composite transforms native (#15236)
add 2c7911b [BEAM-12670] Relocate bq client exception imports to try
block and conditionally turn off tests if imports fail
add 39cf3fc Merge pull request #15264 from [BEAM-12670] Relocate bq
client exception imports to try block and conditionally turn off tests if
imports fail
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
runners/direct-java/build.gradle | 2 +
runners/flink/flink_runner.gradle | 1 +
.../runners/dataflow/GroupIntoBatchesOverride.java | 4 +-
runners/samza/build.gradle | 1 +
runners/samza/job-server/build.gradle | 5 +-
.../beam/runners/samza/SamzaPipelineRunner.java | 17 ++-
.../SamzaPortablePipelineTranslator.java | 27 +++-
....java => SamzaPortableTranslatorRegistrar.java} | 4 +-
sdks/go/pkg/beam/core/metrics/metrics.go | 54 ++++++--
sdks/go/pkg/beam/core/metrics/metrics_test.go | 144 +++++++++++++++++++++
.../beam/runners/dataflow/dataflowlib/execute.go | 7 +-
.../beam/runners/dataflow/dataflowlib/metrics.go | 22 ++--
.../runners/dataflow/dataflowlib/metrics_test.go | 34 ++---
sdks/go/test/build.gradle | 7 +
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 3 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 3 +-
.../apache_beam/io/gcp/bigquery_tools_test.py | 11 +-
.../runners/portability/samza_runner_test.py | 6 +
19 files changed, 293 insertions(+), 60 deletions(-)
copy
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/{SamzaTranslatorRegistrar.java
=> SamzaPortableTranslatorRegistrar.java} (89%)
