You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/08/05 03:43:00 UTC

[beam] tag nightly-master updated (92ea5f5 -> 39cf3fc)

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%)