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 1ca1fafcd62 Fix SubprocessServer cache thread-safety and test
isolation (#38501)
add 233ebd8e2bc [Dataflow Streaming] Add a job setting to limit value size
in windmill state cache (#38458)
add 2ea46979154 Fix non-unique job names in TextIOReadTest (#38242)
add 2c4d2c6de4d Rename run_pylint.sh (#38307)
add 26c6ec7cb74 add todo (#38517)
add 55eb624e5cd Fix interactive environment clean up failure at atexit.
(#38526)
No new revisions were added by this update.
Summary of changes:
.../options/DataflowStreamingPipelineOptions.java | 10 ++
.../dataflow/worker/StreamingDataflowWorker.java | 17 ++-
...lsoByWindowFn.java => SimpleByteHistogram.java} | 29 ++++-
.../worker/windmill/state/WindmillStateCache.java | 122 +++++++++++++++++----
.../worker/util/SimpleByteHistogramTest.java | 38 ++++---
.../windmill/state/WindmillStateCacheTest.java | 62 +++++++++++
.../worker/windmill/src/main/proto/windmill.proto | 2 +
.../org/apache/beam/sdk/io/TextIOReadTest.java | 6 +-
sdks/java/io/expansion-service/build.gradle | 6 +-
sdks/java/io/iceberg/build.gradle | 6 +-
.../runners/interactive/cache_manager.py | 22 ++--
sdks/python/scripts/{run_pylint.sh => run_lint.sh} | 6 +-
sdks/python/tox.ini | 2 +-
13 files changed, 262 insertions(+), 66 deletions(-)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/{BatchGroupAlsoByWindowFn.java
=> SimpleByteHistogram.java} (55%)
copy
sdks/java/core/src/test/java/org/apache/beam/sdk/coders/VoidCoderTest.java =>
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/util/SimpleByteHistogramTest.java
(53%)
rename sdks/python/scripts/{run_pylint.sh => run_lint.sh} (96%)
