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 f9d5de34ae1 update Java version from 11 to 17 (#24839)
add de0cf60eb28 Modify windmill DirectStreamObserver to call isReady only
every 10 messages by default. This provides more output buffering which ensures
that output is not throttled on synchronization when message sizes exceed 32KB
grpc isready limit.
add c162f4c13de Merge pull request #24853: Modify windmill
DirectStreamObserver to call isReady only every 10 messages by default
add a388568da54 [#21384] Add unit tests to the sql package (#24811)
No new revisions were added by this update.
Summary of changes:
.../options/StreamingDataflowWorkerOptions.java | 9 ++
.../worker/windmill/DirectStreamObserver.java | 77 ++++++++++-------
.../worker/windmill/GrpcWindmillServer.java | 3 +-
.../worker/windmill/StreamObserverFactory.java | 12 ++-
sdks/go/pkg/beam/transforms/sql/sql_test.go | 96 ++++++++++++++++++++++
5 files changed, 164 insertions(+), 33 deletions(-)
create mode 100644 sdks/go/pkg/beam/transforms/sql/sql_test.go
