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/09/10 03:20:48 UTC
[beam] tag nightly-master updated (e76b4db -> 297171b)
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 e76b4db (commit)
to 297171b (commit)
from e76b4db Merge pull request #15480: [BEAM-12356] Make sure DatasetService is always closed
add 1d70ad7 [BEAM-11981] Java Bigtable - Implement IO Request Count metrics (#15342)
add 7f36b9b [BEAM-12834] Improve Go SDK cross-language documentation and API. (#15452)
add 7acadb6 [BEAM-10708] Support streaming cache in beam_sql magic
add a871a49 Merge pull request #15446 from KevinGG/ib-ts-coder
add f5da9ff [BEAM-12769] Fix typo in test class name, CLass -> Class
add 390b482 [BEAM-12769] Fix typo in test class name, CLass -> Class
add dcdc355 [BEAM-5172] Temporary ignore testSplit and testSizes tests waiting for a fix because they are flaky.
add 4bc8708 Merge pull request #15477 from echauchot/BEAM-5172-ignore-es-flaky-tests
add 9d3ae05 [BEAM-12740] Remove matching to filter files when renaming gcs files in the same bucket
add f8ba28a Merge pull request #15353: [BEAM-12740] Remove matching to filter files when renaming gcs files in the same bucket
add 7e82513 [BEAM-3304] Helper functions for triggers (#15430)
add ee1e95b Added GroupBy row in Aggregation table.
add b58f6c8 Merge pull request #15463 from [BEAM-12846] Added GroupBy row in Aggregation table.
add 20a4cc0 Fix broken 'differences from pandas' link
add f7da22b Merge pull request #15451 from Fix broken 'differences from pandas' link
add 2379b73 Clarify additional_bq_parameters argument
add 37cd8f8 Merge pull request #15412 from Ruwann/docs-additional-bq-parameters
add dc29e88 Bump a throttling counter on BigQueryRead retries due to RESOURCE_EXHAUSTED
add 549d138 Merge pull request #15445 from Bump throttling counter on BigQueryRead retries due to RESOURCE_EXHAU…
add 297171b [BEAM-5097] Increment counter for "small words" in go SDK example (#15399)
No new revisions were added by this update.
Summary of changes:
model/pipeline/src/main/proto/metrics.proto | 3 +
.../core/metrics/GcpResourceIdentifiers.java | 10 ++
.../core/metrics/MonitoringInfoConstants.java | 7 ++
.../dataflow/worker/BatchModeExecutionContext.java | 9 ++
sdks/go/examples/cookbook/combine/combine.go | 8 +-
sdks/go/examples/wordcount/wordcount.go | 24 +++--
sdks/go/examples/xlang/transforms.go | 15 ++-
sdks/go/pkg/beam/core/graph/window/trigger.go | 58 +++++++++++
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 9 +-
sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 3 +-
sdks/go/pkg/beam/windowing.go | 15 +++
sdks/go/pkg/beam/xlang.go | 109 ++++++++++++++++++---
sdks/go/test/integration/primitives/windowinto.go | 45 ++++++---
.../test/integration/primitives/windowinto_test.go | 7 ++
.../java/org/apache/beam/sdk/io/FileSystems.java | 64 ++++++++----
.../org/apache/beam/sdk/io/fs/MatchResult.java | 1 +
.../org/apache/beam/sdk/io/FileSystemsTest.java | 88 ++++++++++++++++-
...a => JavaClassLookupTransformProviderTest.java} | 38 +++----
.../src/test/resources/test_allowlist.yaml | 26 ++---
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 25 ++++-
.../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 56 +++++++++--
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 +
sdks/java/io/google-cloud-platform/build.gradle | 1 +
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 37 ++++++-
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 65 +++++++++++-
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 67 +++++++++++++
.../io/gcp/bigtable/BigtableServiceImplTest.java | 44 ++++++++-
sdks/python/apache_beam/io/gcp/bigquery.py | 10 +-
.../runners/interactive/cache_manager.py | 2 -
.../runners/interactive/caching/streaming_cache.py | 2 -
.../runners/interactive/sql/beam_sql_magics.py | 6 +-
.../en/documentation/dsls/dataframes/overview.md | 2 +-
.../en/documentation/transforms/python/overview.md | 1 +
35 files changed, 732 insertions(+), 134 deletions(-)
rename sdks/java/expansion-service/src/test/java/org/apache/beam/sdk/expansion/service/{JavaCLassLookupTransformProviderTest.java => JavaClassLookupTransformProviderTest.java} (97%)