beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (0424485 -> 302de87)
Date Sat, 12 Dec 2020 02:52:43 GMT
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


Mime
View raw message