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%)