This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from eb29f866586 Update BEAM_DEV_SDK_CONTAINER_TAG to new version (#38699)
add d553b78ce2f [Dataflow Streaming] Add Operation::finishKey() and move
processTimers into it (#38430)
add 9583fe94755 [Cloud Spanner Change Streams] Fix inverted evaluation of
cancelQueryOnHeartbeat (#38695)
add b91538b4acc Bump cloud.google.com/go/bigtable from 1.47.0 to 1.48.0 in
/sdks (#38703)
add a7d2708d0f5 Bump google.golang.org/api from 0.280.0 to 0.281.0 in
/sdks (#38704)
add 45b79d23f9a Remove redundant HTTP->HTTPS redirect in .htaccess (#38522)
add 852d0720ac0 Refactor _SharedCache to handle context vs non-context
ownership (#38620)
add d2a3cee22e3 Enforce binary-only constraints during early requirements
cache attempts (#38688)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
.../beam/runners/dataflow/worker/PubsubReader.java | 14 +-
.../worker/StreamingModeExecutionContext.java | 22 ++-
.../dataflow/worker/UngroupedWindmillReader.java | 14 +-
.../worker/WindmillReaderIteratorBase.java | 11 +-
.../dataflow/worker/WindowingWindmillReader.java | 2 +
.../WorkerCustomSourceOperationExecutor.java | 3 +
.../dataflow/worker/WorkerCustomSources.java | 9 +-
.../worker/streaming/ComputationWorkExecutor.java | 2 +-
.../util/common/worker/FlattenOperation.java | 3 +
.../worker/util/common/worker/MapTaskExecutor.java | 7 +
.../worker/util/common/worker/Operation.java | 3 +
.../worker/util/common/worker/ParDoOperation.java | 7 +-
.../worker/util/common/worker/ReadOperation.java | 3 +
.../worker/util/common/worker/WorkExecutor.java | 3 +
.../worker/util/common/worker/WriteOperation.java | 3 +
.../worker/IntrinsicMapTaskExecutorTest.java | 12 ++
.../worker/StreamingDataflowWorkerTest.java | 4 +-
.../worker/StreamingModeExecutionContextTest.java | 18 ++-
.../worker/WindmillReaderIteratorBaseTest.java | 60 +++++++-
.../dataflow/worker/WorkerCustomSourcesTest.java | 26 ++--
.../util/common/worker/ExecutorTestUtils.java | 3 +
.../util/common/worker/MapTaskExecutorTest.java | 12 ++
.../util/common/worker/ParDoOperationTest.java | 2 +
sdks/go.mod | 4 +-
sdks/go.sum | 8 +-
.../action/HeartbeatRecordAction.java | 2 +-
.../action/HeartbeatRecordActionTest.java | 4 +-
.../apache_beam/runners/portability/stager.py | 151 +++++++++++++--------
sdks/python/apache_beam/utils/subprocess_server.py | 40 ++++--
.../apache_beam/utils/subprocess_server_test.py | 57 +++++++-
website/www/site/static/.htaccess | 14 --
32 files changed, 377 insertions(+), 148 deletions(-)
