You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2026/04/16 05:01:27 UTC

(beam) branch nightly-refs/heads/master updated (98f5b339bab -> ae536b6f0f8)

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 98f5b339bab Add mutable change stream in IntegrateionTestEnv.java for postgresql (#38057)
     add 5655186de73 Retry transient NOT_FOUND on Storage API default stream
     add a056c5b4991 Merge pull request #38132 from aIbrahiim/fix-gcp-io-default-stream
     add 0471bb5e935 Change TriggerState finished bitset coder to a SentinelBitSetCoder (#38139)
     add 48a6ceb7a57 [Dataflow Streaming] Fix spammy log during GrpcGetDataStream physical stream half-closing (#38158)
     add 77ff67063f5 Install openssh-client
     add 0bdc149b9b9 Merge pull request #38195 from apache/fix-flink-container
     add e6c0796d2c2 Fix Lint PreCommit
     add 56c8de59b13 skip spanner assignment too
     add 09bc761f57b remove unused ignore
     add 2e1edb08232 Merge pull request #38191 from jrmccluskey/assignmentSkip
     add 4ee32cddb4c [Java Harness] Reapply optimization to use Caches.weigh on objects within cached blocks (#37964)
     add a60a71e238a [Iceberg AddFiles] Attach name-mapping to table (#38189)
     add 9a9d241b341 [ErrorProne] Enable BigDecimalEquals check and fix violations (#38193)
     add c7e54f81e57 ErrorProne - enable NarrowCalculation check
     add b2e97dee8c2 Merge pull request #38192 from stankiewicz/errorprone_NarrowCalculation
     add d6fd0698769 [Iceberg] Support nested column paths in keep/drop configuration (#37516)
     add ae536b6f0f8 fixed PythonDocker rerun matrix gating and gh setup (#38199)

No new revisions were added by this update.

Summary of changes:
 .github/actions/rerun-job-action/action.yml        |   6 +-
 .../arc/images/Dockerfile                          |   2 +-
 .github/workflows/README.md                        |   4 +-
 .github/workflows/beam_PreCommit_PythonDocker.yml  |   5 +-
 CHANGES.md                                         |   4 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 -
 .../core/serialization/SentinelBitSetCoder.java    |  27 ++-
 .../core/triggers/TriggerStateMachineRunner.java   |   4 +-
 .../serialization/SentinelBitSetCoderTest.java     |  75 ++++++--
 .../windmill/client/grpc/GrpcGetDataStream.java    |   5 +-
 .../org/apache/beam/sdk/fn/data/WeightedList.java  |  11 +-
 .../beam/sdk/util/RowJsonValueExtractors.java      |   5 +-
 .../sql/impl/transform/agg/CovarianceFn.java       |   2 +-
 .../sql/impl/transform/agg/VarianceFn.java         |   2 +-
 .../fn/harness/jmh/ProcessBundleBenchmark.java     |   6 +-
 .../java/org/apache/beam/fn/harness/Caches.java    |  57 +++---
 .../fn/harness/state/StateFetchingIterators.java   | 195 ++++++++++++++-------
 .../harness/state/StateFetchingIteratorsTest.java  |  39 +++++
 .../bigquery/StorageApiWriteUnshardedRecords.java  |   2 +-
 .../org/apache/beam/sdk/io/iceberg/AddFiles.java   |  31 +++-
 .../beam/sdk/io/iceberg/IcebergScanConfig.java     |  20 ++-
 .../apache/beam/sdk/io/iceberg/AddFilesTest.java   |  13 ++
 .../beam/sdk/io/iceberg/IcebergIOReadTest.java     |  30 ++++
 .../nexmark/sources/generator/GeneratorConfig.java |   2 +-
 .../ml/rag/ingestion/spanner_it_test.py            |   2 +-
 25 files changed, 396 insertions(+), 155 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BitSetCoder.java => runners/core-java/src/main/java/org/apache/beam/runners/core/serialization/SentinelBitSetCoder.java (66%)
 copy sdks/java/core/src/test/java/org/apache/beam/sdk/coders/BitSetCoderTest.java => runners/core-java/src/test/java/org/apache/beam/runners/core/serialization/SentinelBitSetCoderTest.java (52%)