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 5c5c710441c Revert "upgrade vllm for vuln" (#37856)
add 47bab7e7597 [SpannerIO] Add low-latency configuration in Spanner
Change Streams (#37718)
add 0f6c88e0d4b Pin zookeeper in expansion service (#37859)
add b9a7585d7f4 [ErrorProne] Enable StaticAssignmentInConstructor check
(#37786)
add 3b472aaa9d3 [ErrorProne] Enable UnsafeReflectiveConstructionCast check
(#37784)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 -
.../direct/BoundedReadEvaluatorFactoryTest.java | 11 +-
.../direct/UnboundedReadEvaluatorFactoryTest.java | 44 +++---
.../worker/StreamingDataflowWorkerTest.java | 7 +-
.../aggregators/metrics/sink/InMemoryMetrics.java | 26 ++--
.../aggregators/metrics/sink/InMemoryMetrics.java | 26 ++--
.../coders/SparkRunnerKryoRegistratorTest.java | 3 +-
.../avro/schemas/utils/AvroUtilsTest.java | 18 +--
sdks/java/io/expansion-service/build.gradle | 3 +
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 70 +++++++++-
.../changestreams/ChangeStreamsConstants.java | 9 ++
.../changestreams/action/ActionFactory.java | 12 +-
.../action/HeartbeatRecordAction.java | 14 +-
.../action/QueryChangeStreamAction.java | 19 ++-
.../spanner/changestreams/dofn/InitializeDoFn.java | 12 +-
.../dofn/ReadChangeStreamPartitionDoFn.java | 18 ++-
.../action/HeartbeatRecordActionTest.java | 149 ++++++++++++++++++++-
.../action/QueryChangeStreamActionTest.java | 114 +++++++++++++---
.../changestreams/dofn/InitializeDoFnTest.java | 3 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 19 ++-
.../sdk/io/hcatalog/HiveDatabaseTestHelper.java | 17 +--
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 10 +-
.../io/snowflake/test/FakeSnowflakeDatabase.java | 10 +-
23 files changed, 477 insertions(+), 139 deletions(-)
