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/12/16 03:50:42 UTC
[beam] branch nightly-refs/heads/master updated (f9b0d6d -> 112b3cd)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f9b0d6d [BEAM-13434] Bump log4j to 2.16.0. (#16237)
add 62c34bd [BEAM-13209] Fix DynamoDBIO.write to properly handle partial success with unprocessed items remaining.
add fbe386e Merge pull request #15964: [BEAM-13209] Fix DynamoDBIO.write to properly handle partial success (SDK v2)
add 9b212bc [BEAM-13209] Fix DynamoDBIO.write to properly handle partial success (SDK v1)
add 665a542 Merge pull request #16239: [BEAM-13209] Fix DynamoDBIO.write to properly handle partial success (SDK v1)
add bc82f6f [BEAM-13341] Serialize reflection parameter in AvroCoder cloud object (#16080)
add c6b43e0 Update grafana from 8.1.6 to 8.1.8
add d609b65 Merge pull request #16247 from apache/aaltay-patch-1
add 7e27e0f [BEAM-13015] Update FakeBeamFnStateClient to generate elements that stop at the next block boundary instead of continuing into additional blocks. (#16230)
add d185303 [BEAM-13218] Sickbay PubSubIntegrationTest.test_streaming_with_attributes (#16251)
add 112b3cd [BEAM-13399] Add infrastructure to start JARs from Go functions (#16214)
No new revisions were added by this update.
Summary of changes:
.test-infra/metrics/grafana/Dockerfile | 2 +-
.../util/AvroCoderCloudObjectTranslator.java | 5 +-
.../runners/dataflow/util/CloudObjectsTest.java | 13 +-
.../beam/core/runtime/xlangx/expansionx/process.go | 71 +++++++++++
.../core/runtime/xlangx/expansionx/process_test.go | 85 +++++++++++++
.../java/org/apache/beam/sdk/coders/AvroCoder.java | 15 ++-
.../org/apache/beam/sdk/coders/AvroCoderTest.java | 16 ++-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 141 +++++++++++++--------
.../beam/fn/harness/state/BagUserStateTest.java | 23 ++--
.../state/CachingBeamFnStateClientTest.java | 34 +++--
.../fn/harness/state/FakeBeamFnStateClient.java | 95 +++++++++++---
.../fn/harness/state/MultimapSideInputTest.java | 50 +++++---
.../fn/harness/state/MultimapUserStateTest.java | 85 +++++++------
.../fn/harness/state/StateBackedIterableTest.java | 16 ++-
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 128 +++++++++++--------
.../beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java | 16 ++-
.../sdk/io/aws/dynamodb/DynamoDBIOWriteTest.java | 98 +++++++++++---
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 124 +++++++++++-------
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 13 +-
.../sdk/io/aws2/dynamodb/DynamoDBIOWriteTest.java | 101 ++++++++++++---
.../apache_beam/io/gcp/pubsub_integration_test.py | 2 +
21 files changed, 826 insertions(+), 307 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
create mode 100644 sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process_test.go