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 c2c9275c680 [Python] Added the validate support for
ReadAllFromBigQuery (#34910)
add e7cdee37bb3 [Dataflow Streaming] Remove unused quota throttling
metrics from windmill streams (#34891)
add 63242c9413a [Java SDK] Added cache for AvroCoder
DatumReader/DatumWriter to reduce memory footprint (#34873)
add 23dc4470592 [Dataflow] Fix flaky BoundedQueueExecutor test (#34878)
add 28df7cb27f6 [AnomalyDetection] Support unkeyed input for the
transform. (#34897)
add 0c92ee9343d Adding release-2.65.0-postrelease to protected branches in
.asf.yaml
add 0ddfb14c9f1 Update Beam website to release 2.65.0 (#34821)
add 92050fb6048 Prevent ValueError when passing resource_hints in
StandardOptions (#34886)
add c68bab4c5a4 Specify pip version for ML and Transformers tests (#34917)
add 61ad7e10ca3 Fix minor issues in various PTransformRunner classes
add e27c927c009 Merge pull request #34881: Fix minor issues in various
PTransformRunner classes
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
CHANGES.md | 2 +-
.../core/metrics/SimpleMonitoringInfoBuilder.java | 6 +
.../dataflow/worker/DataflowSystemMetrics.java | 1 -
.../dataflow/worker/StreamingDataflowWorker.java | 77 +++---
.../FanOutStreamingEngineWorkerHarness.java | 19 +-
.../harness/SingleSourceWorkerHarness.java | 13 +-
.../streaming/harness/StreamingCounters.java | 4 -
.../streaming/harness/StreamingWorkerHarness.java | 3 +-
.../harness/StreamingWorkerStatusReporter.java | 10 -
.../streaming/harness/WindmillStreamSender.java | 16 +-
.../worker/windmill/WindmillServerBase.java | 6 -
.../worker/windmill/WindmillServerStub.java | 3 -
.../windmill/client/AbstractWindmillStream.java | 12 -
.../windmill/client/grpc/GrpcCommitWorkStream.java | 13 -
.../client/grpc/GrpcDirectGetWorkStream.java | 12 -
.../windmill/client/grpc/GrpcGetDataStream.java | 12 -
.../windmill/client/grpc/GrpcGetWorkStream.java | 12 -
.../client/grpc/GrpcGetWorkerMetadataStream.java | 11 -
.../windmill/client/grpc/GrpcWindmillServer.java | 15 +-
.../client/grpc/GrpcWindmillStreamFactory.java | 23 +-
.../throttling/StreamingEngineThrottleTimers.java | 41 ---
.../windmill/client/throttling/ThrottleTimer.java | 69 -----
.../client/throttling/ThrottledTimeTracker.java | 32 ---
.../dataflow/worker/FakeWindmillServer.java | 5 -
.../FanOutStreamingEngineWorkerHarnessTest.java | 14 +-
.../harness/SingleSourceWorkerHarnessTest.java | 2 -
.../harness/StreamingWorkerStatusReporterTest.java | 2 -
.../harness/WindmillStreamSenderTest.java | 32 +--
.../worker/util/BoundedQueueExecutorTest.java | 5 +-
.../client/AbstractWindmillStreamTest.java | 3 -
.../client/grpc/GrpcCommitWorkStreamTest.java | 5 +-
.../client/grpc/GrpcDirectGetWorkStreamTest.java | 38 +--
.../client/grpc/GrpcGetDataStreamTest.java | 5 +-
.../grpc/GrpcGetWorkerMetadataStreamTest.java | 2 -
.../client/grpc/GrpcWindmillServerTest.java | 116 --------
.../beam/sdk/extensions/avro/coders/AvroCoder.java | 172 ++++++++++--
.../extensions/avro/coders/AvroGenericCoder.java | 12 +-
.../sdk/extensions/avro/coders/AvroCoderTest.java | 92 +++++++
.../beam/fn/harness/BeamFnDataReadRunner.java | 42 ++-
.../beam/fn/harness/BeamFnDataWriteRunner.java | 16 +-
.../org/apache/beam/fn/harness/CombineRunners.java | 31 ++-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 4 +-
sdks/python/apache_beam/ml/anomaly/transforms.py | 131 +++++----
.../apache_beam/ml/anomaly/transforms_test.py | 302 +++++++++++----------
sdks/python/apache_beam/transforms/resources.py | 4 +
.../apache_beam/transforms/resources_test.py | 23 ++
sdks/python/tox.ini | 2 +
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.65.0.md | 88 ++++++
.../www/site/content/en/get-started/downloads.md | 8 +
51 files changed, 748 insertions(+), 823 deletions(-)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/throttling/StreamingEngineThrottleTimers.java
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/throttling/ThrottleTimer.java
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/throttling/ThrottledTimeTracker.java
create mode 100644 website/www/site/content/en/blog/beam-2.65.0.md
