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 ba49cd9 [BEAM-13402] Add another workaround for
https://github.com/googleapis/gax-java/issues/1577 and bump Pub/Sub Lite
version to pick up another similar workaround (#16190)
add 9cc8ca6 [BEAM-13171] Fix Duration ambiguity
add d842e4e Merge pull request #16194: [BEAM-13171] Fix Duration ambiguity
add f57973b [BEAM-13410][BEAM-11788] Integration test for S3Filesystem
using Localstack. This overrides the AWS service endpoint and invalidates
[BEAM-11788].
add 3b74958 Merge pull request #16168: [BEAM-13410][BEAM-11788]
Integration test for S3Filesystem using Localstack
add 4600532 [BEAM-13434] Bump up Apache log4j2 vulnerability to 2.15.0
add 9fce7f6 Merge pull request #16191: [BEAM-13434] Bump up Apache log4j2
to 2.15.0 due to the vulnerability
add a000621 add type of precompiled object
add bb38872 Merge pull request #16184 from
[BEAM-13413][Playground][Bugfix] add type of precompiled object
add 94eddab [BEAM-13424][Playground] Set float64 to the cache instead of
int Change converting to float64 instead of int
add 6a75a0d [BEAM-13424][Playground] fix tests
add 7082da2 [BEAM-13424][Playground] add a check before setting the value
to the cache for localCache
add c459eef Merge pull request #16180 from [BEAM-13424][Playground]
[Bugfix] Error during get Logs and Run output from the backend with Redis
add ee0dfa9 [BEAM-13428][Playground] Fix to get pipelineOptions for the
precompiledObjects
add b9ed02a Merge pull request #16181 from [BEAM-13428][Playground]
[Bugfix] Backend doesn't send pipeline's options from examples API
add dd0edba [BEAM-13426] clear log and output panels on example change
add 62ca2b9 Merge pull request #16182 from [BEAM-13426] [Bugfix]
[Playground] clear log and output panels on example change
add 1d55577 Merge pull request #16138 from [BEAM-13343][Playground]
Support go unit tests
add 07b956a [BEAM-12560] Dataframe idxmin and idxmax implementation
(#15827)
add f98a3b0 [BEAM-12565] Dataframe compare implementation (#16027)
add daadaa4 [BEAM-12976] Use a map to pass all pushdown requests at once.
(#16189)
No new revisions were added by this update.
Summary of changes:
build.gradle.kts | 1 +
playground/backend/configs/SDK_GO.json | 7 +-
playground/backend/containers/go/Dockerfile | 6 +-
.../backend/internal/cache/local/local_cache.go | 6 +
.../internal/code_processing/code_processing.go | 61 ++++---
.../code_processing/code_processing_test.go | 8 +-
playground/backend/internal/executors/executor.go | 5 +-
.../backend/internal/executors/executor_builder.go | 8 +
.../backend/internal/executors/executor_test.go | 9 +-
playground/backend/internal/fs_tool/fs.go | 6 +
.../backend/internal/preparators/go_preparators.go | 28 ++-
.../internal/preparators/go_preparators_test.go | 3 +-
.../internal/setup_tools/builder/setup_builder.go | 18 +-
.../setup_tools/builder/setup_builder_test.go | 11 +-
.../internal/utils/precompiled_objects_utils.go | 9 +-
.../backend/internal/utils/validators_utils.go | 2 +-
.../backend/internal/validators/go_validators.go | 31 +++-
...va_validators_test.go => go_validators_test.go} | 54 ++----
.../backend/internal/validators/java_validators.go | 4 +-
.../internal/validators/java_validators_test.go | 52 ++----
.../backend/internal/validators/validator_test.go | 46 ++---
.../pages/playground/states/playground_state.dart | 1 +
playground/infrastructure/cd_helper.py | 4 +-
playground/infrastructure/config.py | 7 +
playground/infrastructure/helper.py | 40 ++++-
playground/infrastructure/test_helper.py | 21 ++-
.../beam/sdk/schemas/ProjectionProducer.java | 10 +-
.../provider/SchemaIOTableProviderWrapper.java | 5 +-
.../provider/TestSchemaIOTableProviderWrapper.java | 12 +-
sdks/java/io/amazon-web-services/build.gradle | 3 +
.../org/apache/beam/sdk/io/aws/ITEnvironment.java | 143 ++++++++++++++++
.../apache/beam/sdk/io/aws/s3/S3FileSystemIT.java | 133 +++++++++++++++
.../org/apache/beam/sdk/io/aws2/ITEnvironment.java | 148 ++++++++++++++++
.../apache/beam/sdk/io/aws2/s3/S3FileSystemIT.java | 119 +++++++++++++
.../elasticsearch-tests-5/build.gradle | 2 +-
.../elasticsearch-tests-6/build.gradle | 2 +-
.../elasticsearch-tests-7/build.gradle | 2 +-
.../elasticsearch-tests-common/build.gradle | 2 +-
sdks/java/io/hcatalog/build.gradle | 2 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 3 +-
sdks/python/apache_beam/dataframe/frames.py | 190 +++++++++++++++++++++
sdks/python/apache_beam/dataframe/frames_test.py | 130 ++++++++++++++
.../apache_beam/dataframe/pandas_doctests_test.py | 13 +-
43 files changed, 1166 insertions(+), 201 deletions(-)
copy playground/backend/internal/validators/{java_validators_test.go =>
go_validators_test.go} (52%)
copy sdks/go/pkg/beam/core/runtime/xlangx/payload_test.go =>
playground/backend/internal/validators/validator_test.go (55%)
create mode 100644
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/ITEnvironment.java
create mode 100644
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/s3/S3FileSystemIT.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/ITEnvironment.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystemIT.java