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 90f1675 [BEAM-10345] Add an import guard to support recent
google-cloud-spanner versions. (#16434)
add 3bbe6ff Fixed empty labels treated as wildcard when matching cache
files (#16440)
add 5c564d1 [BEAM-13570] Remove erroneous compileClasspath dependency.
(#16438)
add 17485ee [BEAM-13015] Plumb through process wide and bundle cache
through the FnApiStateAccessor. (#16423)
add 638687f [BEAM-13015] Cache the state backed iterable used for large
GBK results. (#16409)
add 50ef9e4 [BEAM-13604] NPE while getting null from BigDecimal column
add 19d60ea Merge pull request #16442: [BEAM-13604] NPE while getting
null from BigDecimal column
add ae5ea31 Fix formatting/alignment (#16443)
add b94d6b3 Merge pull request #16183 from [BEAM-13427] [Playground]
show logs for precompiled objects
add 52efbe4 [BEAM-10277] re-write encoding position tests to declare
schema protos explicitly (#16267)
add 3c67192 Update local_env_tests.yml (#16444)
add 3c53a78 [BEAM-13574] Filesystem abstraction Rename support (#16428)
add a1a530e [BEAM-13597] Setup Go in github actions (#16446)
add f656713 [BEAM-13091] Generate missing staged names from hash for
Dataflow runner
add a43eb11 add test
add cb652eb Merge pull request #15765 from ihji/BEAM-13091
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_tests.yml | 9 +
.github/workflows/local_env_tests.yml | 3 +-
.github/workflows/python_tests.yml | 9 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
.../modules/editor/parsers/run_options_parser.dart | 24 +-
.../lib/modules/examples/models/example_model.dart | 6 +
.../example_client/example_client.dart | 2 +
.../example_client/grpc_example_client.dart | 26 +-
.../examples/repositories/example_repository.dart | 7 +
.../pages/playground/states/examples_state.dart | 24 +-
.../pages/playground/states/playground_state.dart | 3 +-
.../editor/parsers/run_options_parser_test.dart | 4 +
.../beam/runners/dataflow/DataflowRunner.java | 67 ++--
.../beam/runners/dataflow/DataflowRunnerTest.java | 46 +++
.../fnexecution/control/RemoteExecutionTest.java | 180 ++++++++--
runners/spark/spark_runner.gradle | 4 +-
sdks/go/pkg/beam/io/filesystem/filesystem.go | 31 +-
.../filesystem/filesystem_test.go} | 26 +-
sdks/go/pkg/beam/io/filesystem/gcs/gcs.go | 36 ++
.../{util/gcsx => io/filesystem/gcs}/gcs_test.go | 31 +-
sdks/go/pkg/beam/io/filesystem/local/local.go | 16 +
sdks/go/pkg/beam/io/filesystem/local/local_test.go | 179 +++++++++
sdks/go/pkg/beam/io/filesystem/memfs/memory.go | 70 +++-
.../go/pkg/beam/io/filesystem/memfs/memory_test.go | 125 ++++++-
sdks/go/pkg/beam/io/filesystem/util.go | 67 ++++
sdks/go/pkg/beam/io/filesystem/util_test.go | 399 +++++++++++++++++++++
sdks/go/pkg/beam/runners/flag.go | 1 +
.../java/org/apache/beam/fn/harness/Caches.java | 20 +-
.../fn/harness/control/ProcessBundleHandler.java | 39 +-
.../fn/harness/state/CachingBeamFnStateClient.java | 177 ---------
.../beam/fn/harness/state/FnApiStateAccessor.java | 64 +++-
.../beam/fn/harness/state/MultimapUserState.java | 2 +-
.../beam/fn/harness/state/StateBackedIterable.java | 42 +--
.../org/apache/beam/fn/harness/CachesTest.java | 1 +
.../state/CachingBeamFnStateClientTest.java | 347 ------------------
.../fn/harness/state/StateBackedIterableTest.java | 51 ++-
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 4 +-
sdks/python/apache_beam/coders/row_coder_test.py | 121 ++++---
.../runners/interactive/cache_manager.py | 4 +-
.../runners/interactive/cache_manager_test.py | 12 +
.../runners/interactive/caching/streaming_cache.py | 6 +-
.../interactive/caching/streaming_cache_test.py | 3 +
.../runners/interactive/interactive_runner.py | 2 +-
.../runners/interactive/pipeline_fragment_test.py | 13 +-
44 files changed, 1506 insertions(+), 805 deletions(-)
copy sdks/go/pkg/beam/{core/runtime/coderx/string_test.go =>
io/filesystem/filesystem_test.go} (66%)
copy sdks/go/pkg/beam/{util/gcsx => io/filesystem/gcs}/gcs_test.go (64%)
create mode 100644 sdks/go/pkg/beam/io/filesystem/local/local_test.go
create mode 100644 sdks/go/pkg/beam/io/filesystem/util_test.go
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClient.java
delete mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClientTest.java
