This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/awaitSessionCreation
in repository https://gitbox.apache.org/repos/asf/beam.git
from b3f1f2b5dc8 Fix text parsing
add 39632ef2134 Fix iceberg gcs dependency after gcsio 3.0 upgrade (#38488)
add 1d6cdc0b4b6 Isolate tests in multi_process_shared with unique temp
path. (#38498)
add 5b5cd657c98 Bump @protobufjs/utf8 from 1.1.0 to 1.1.1 in
/sdks/typescript (#38475)
add 9a1a4b170e4 [Iceberg] pin hadoop to 3.3.6 (#38500)
add 7b4ae897cc7 Set torch upper bound
add 45790bbe2a2 Merge pull request #38505 from
shunping/set-torch-upper-bound
add 84a21684146 Bump google.golang.org/grpc from 1.81.0 to 1.81.1 in /sdks
(#38506)
add 5d2ff20e856 Enable multi-release attribute for Spark job server jar
(#38449)
add 6e23bc1ef3a Fix empty stream name encountered in
StorageApiFinalizeWrtiesDoFn (#38410)
add 6ae46e3c2d4 Bump jackson_version - Fix GHSA-72hv-8253-57qq (#37969)
add 4ac7598df14 Fix Dataflow archetype missing API client dependency
(#38509)
add b2d0ef66aa9 Fix pom involving maven-archetype and opentelemetry
(#38518)
add 357fd262211 Revert #37631 and #38497 on HEAD (#38516)
add 0496ea7117b Fix typo in README website description (#38469)
add 4c4a2c11e29 Revert "Fix Dataflow archetype missing API client
dependency (#38509)" (#38519)
add 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)
add b80a97d62c3 Merge branch 'master' of https://github.com/apache/beam
into users/damccorm/awaitSessionCreation
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../IO_Iceberg_Integration_Tests_Dataflow.json | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_ULR.json | 3 +-
...t.json => beam_PostCommit_Python_Versions.json} | 2 +-
.github/trigger_files/beam_PostCommit_SQL.json | 2 +-
CHANGES.md | 5 +-
README.md | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 12 +-
.../dataflow/DataflowPipelineTranslator.java | 2 +-
.../beam/runners/dataflow/DataflowRunner.java | 59 +++++-----
.../options/DataflowStreamingPipelineOptions.java | 10 ++
.../dataflow/DataflowPipelineTranslatorTest.java | 77 +++----------
.../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 +
.../control/ProcessBundleDescriptorsTest.java | 6 +-
runners/portability/java/build.gradle | 5 -
runners/spark/job-server/spark_job_server.gradle | 4 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../src/main/resources/beam/beam-codestyle.xml | 6 +-
.../container/license_scripts/dep_urls_java.yaml | 2 +-
.../sdk/util/construction/CoderTranslation.java | 62 +----------
.../sdk/util/construction/CoderTranslator.java | 1 -
.../construction/CoderTranslatorRegistrar.java | 16 ---
.../sdk/util/construction/CoderTranslators.java | 79 -------------
.../sdk/util/construction/ModelCoderRegistrar.java | 28 +----
.../beam/sdk/util/construction/ModelCoders.java | 2 -
.../util/construction/RehydratedComponents.java | 3 +-
.../beam/sdk/util/construction/SdkComponents.java | 39 +++----
.../org/apache/beam/sdk/io/TextIOReadTest.java | 6 +-
.../util/construction/CoderTranslationTest.java | 38 +------
.../sdk/expansion/service/ExpansionService.java | 2 +-
.../extensions/avro/AvroGenericCoderRegistrar.java | 18 ---
sdks/java/extensions/sql/iceberg/build.gradle | 1 +
.../beam/fn/harness/state/StateBackedIterable.java | 22 ----
sdks/java/io/expansion-service/build.gradle | 18 ++-
.../bigquery/StorageApiWritesShardedRecords.java | 43 ++++----
sdks/java/io/iceberg/build.gradle | 9 +-
.../beam/sdk/io/iceberg/IcebergScanConfig.java | 2 +-
.../META-INF/maven/archetype-metadata.xml | 2 +-
.../resources/projects/basic/archetype.properties | 2 +-
.../resources/projects/basic/archetype.properties | 2 +-
.../runners/interactive/cache_manager.py | 22 ++--
.../python/apache_beam/transforms/external_test.py | 8 +-
.../apache_beam/utils/multi_process_shared_test.py | 37 ++++---
sdks/python/apache_beam/utils/subprocess_server.py | 11 +-
sdks/python/scripts/{run_pylint.sh => run_lint.sh} | 6 +-
sdks/python/setup.py | 3 +-
sdks/python/tox.ini | 2 +-
sdks/typescript/package-lock.json | 12 +-
54 files changed, 438 insertions(+), 535 deletions(-)
copy .github/trigger_files/{beam_PostCommit_TransformService_Direct.json =>
beam_PostCommit_Python_Versions.json} (84%)
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%)
