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 2023/01/08 04:51:02 UTC

[beam] branch nightly-refs/heads/master updated (f9d5de34ae1 -> a388568da54)

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