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 2020/12/12 02:52:43 UTC
[beam] tag nightly-master updated (0424485 -> 302de87)
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 0424485 (commit)
to 302de87 (commit)
from 0424485 Merge pull request #13525: [BEAM-10402] Supress nullness and keyfor DoFnOperatorTest warnings.
add 0353554 [BEAM-11337] Make the ThriftCoder class visible from outside its package
add 9317a6b Merge pull request #13415: [BEAM-11337] Make the ThriftCoder class visible from outside its package
add fd56cf1 [BEAM-7794] Enable DynamoDBIO tests (Use localstack version 0.11.4)
add b850e76 Merge pull request #13510: [BEAM-7794] Enable DynamoDBIO tests (Use localstack version 0.11.4)
add bf3c7eb Serialize AwsCredentialsProvider for AWS SDK v2 IO connectors
add 32598ff Merge pull request #13233: [BEAM-11016] Serialize AwsCredentialsProvider for AWS SDK v2 IO connectors
add 77683be [BEAM-11439] Fix Snowflake streaming docs (#13528)
add a679bab [BEAM-9602] Add timer family support for python SDK
add 8cf88c3 Merge pull request #13421 from [BEAM-9602] Add timer family support for python SDK
add 566ee5e [BEAM-10706] Fix duplicate key error in DynamoDBIO.Write
add a1676e9 Merge pull request #12583: [BEAM-10706] Fix duplicate key error in DynamoDBIO.Write
add 20bab56 Add myself (lostluck) to the authors.yml list (#13531)
add 1c453dc [BEAM-11208] Fix for QUOTA_EXCEEDED failures in BQ Storage streams sp… (#13378)
add 2733e95 [BEAM-11434]Expose batch/admin clients in Spanner Accessor
add 70ac878 Merge pull request #13519: [BEAM-11434]Expose batch/admin clients in Spanner Accessor
add f36cd5b Update Beam website to release 2.26.0. (#13481)
add fdbf47d Add a blogpost for ApacheBeam 2.26.0. (#13482)
add dc8d82e Fix typo in publish_docker_images.sh (#13532)
add b9cc076 [BEAM-11338] Beam schema for thrift data (#13428)
add ee911d2 Fix missing braket in the 2.25 signature. (#13534)
add 302de87 Workaround for incremental in read_json. (#13489)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 19 +-
release/src/main/scripts/publish_docker_images.sh | 2 +-
.../src/main/resources/beam/suppressions.xml | 2 +
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 40 +-
.../beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java | 68 +-
.../sdk/io/aws/dynamodb/DynamoDBIOTestHelper.java | 2 +-
.../aws2/dynamodb/BasicDynamoDbClientProvider.java | 32 +-
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 40 +-
.../sdk/io/aws2/options/AwsSerializableUtils.java | 50 ++
.../io/aws2/sns/BasicSnsAsyncClientProvider.java | 32 +-
.../sdk/io/aws2/sns/BasicSnsClientProvider.java | 34 +-
.../sdk/io/aws2/sqs/BasicSqsClientProvider.java | 34 +-
.../dynamodb/BasicDynamoDbClientProviderTest.java | 51 ++
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 85 ++-
.../io/aws2/options/AwsSerializableUtilsTest.java | 70 ++
.../aws2/sns/BasicSnsAsyncClientProviderTest.java | 51 ++
.../io/aws2/sns/BasicSnsClientProviderTest.java | 51 ++
.../io/aws2/sqs/BasicSqsClientProviderTest.java | 51 ++
.../gcp/bigquery/BigQueryStorageStreamSource.java | 6 +
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 6 +-
.../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 13 +-
.../apache/beam/sdk/io/kinesis/KinesisIOIT.java | 2 +-
sdks/java/io/thrift/build.gradle | 10 +-
.../org/apache/beam/sdk/io/thrift/ThriftCoder.java | 4 +-
.../apache/beam/sdk/io/thrift/ThriftSchema.java | 374 +++++++++++
.../apache/beam/sdk/io/thrift/TestThriftEnum.java} | 50 +-
.../beam/sdk/io/thrift/TestThriftInnerStruct.java | 530 +++++++++++++++
.../beam/sdk/io/thrift/TestThriftStruct.java | 723 ++++++++++++++++++++-
.../apache/beam/sdk/io/thrift/TestThriftUnion.java | 401 ++++++++++++
.../beam/sdk/io/thrift/ThriftSchemaTest.java | 251 +++++++
.../src/test/resources/thrift/thrift_test.thrift | 24 +-
sdks/python/apache_beam/dataframe/io.py | 5 +
sdks/python/apache_beam/runners/common.pxd | 1 +
sdks/python/apache_beam/runners/common.py | 28 +-
.../apache_beam/runners/direct/direct_userstate.py | 35 +-
.../runners/direct/transform_evaluator.py | 8 +-
sdks/python/apache_beam/runners/direct/util.py | 18 +-
.../runners/direct/watermark_manager.py | 10 +-
.../runners/portability/flink_runner_test.py | 3 +
.../portability/fn_api_runner/fn_runner_test.py | 24 +
.../apache_beam/runners/worker/bundle_processor.py | 41 +-
.../apache_beam/runners/worker/operations.py | 6 +-
sdks/python/apache_beam/transforms/core.py | 3 +-
sdks/python/apache_beam/transforms/trigger.py | 39 +-
sdks/python/apache_beam/transforms/trigger_test.py | 10 +-
sdks/python/apache_beam/transforms/userstate.py | 55 +-
.../apache_beam/transforms/userstate_test.py | 216 +++++-
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.26.0.md | 64 ++
.../en/documentation/io/built-in/snowflake.md | 6 +-
.../www/site/content/en/get-started/downloads.md | 20 +-
website/www/site/data/authors.yml | 6 +-
website/www/site/static/.htaccess | 2 +-
53 files changed, 3482 insertions(+), 228 deletions(-)
create mode 100644 sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsSerializableUtils.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProviderTest.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/options/AwsSerializableUtilsTest.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProviderTest.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProviderTest.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProviderTest.java
create mode 100644 sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftSchema.java
copy sdks/java/{core/src/main/java/org/apache/beam/sdk/util/WeightedValue.java => io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/TestThriftEnum.java} (52%)
create mode 100644 sdks/java/io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/TestThriftInnerStruct.java
create mode 100644 sdks/java/io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/TestThriftUnion.java
create mode 100644 sdks/java/io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/ThriftSchemaTest.java
create mode 100644 website/www/site/content/en/blog/beam-2.26.0.md