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 1bbe07e1653 Fix Python postcommits (#30333)
add 3693174c042 [Dataflow Streaming] Add Channelz staus page exporting
GRPC channelz data (#30211)
add f373e7169eb Revert "Update to libraries-bom 26.32.0 (#30324)" (#30334)
add f5e33785ffe clarify sentence.
add d27e7a2aed2 Merge pull request #30330 from svetakvsundhar/minor_typo
add 0d46e304f17 Introduce JmsIO.Read.requiresDeduping (#30253)
add 48adde999b9 [#29917][prism] Initial TestStream support (#30072)
add 8a74a1c279c Upgrade GCP BOM to 26.32.0 (#30335)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Java_DataflowV2.json | 0
.github/trigger_files/beam_PostCommit_Python.json | 0
.../beam_PostCommit_Python_Examples_Direct.json | 0
.../beam_PostCommit_Python_Xlang_Gcp_Direct.json | 1 -
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 14 +-
.../options/DataflowPipelineDebugOptions.java | 6 +
.../dataflow/worker/StreamingDataflowWorker.java | 10 +
.../worker/windmill/WindmillServerBase.java | 6 +
.../worker/windmill/WindmillServerStub.java | 6 +
.../windmill/client/grpc/ChannelzServlet.java | 292 +++++++++++++++++++++
.../windmill/client/grpc/GrpcDispatcherClient.java | 4 +
.../windmill/client/grpc/GrpcWindmillServer.java | 5 +
.../client/grpc/stubs/WindmillChannelFactory.java | 2 +
.../dataflow/worker/FakeWindmillServer.java | 22 +-
.../windmill/client/grpc/ChannelzServletTest.java | 104 ++++++++
scripts/tools/bomupgrader.py | 93 +++++--
.../prism/internal/engine/elementmanager.go | 99 +++++--
.../runners/prism/internal/engine/engine_test.go | 47 ++++
.../runners/prism/internal/engine/teststream.go | 269 +++++++++++++++++++
sdks/go/pkg/beam/runners/prism/internal/execute.go | 54 ++++
.../prism/internal/jobservices/management.go | 18 ++
.../runners/prism/internal/unimplemented_test.go | 43 ++-
sdks/go/pkg/beam/testing/teststream/teststream.go | 8 +-
sdks/go/test/integration/integration.go | 7 +-
sdks/go/test/integration/primitives/teststream.go | 43 ++-
.../test/integration/primitives/teststream_test.go | 10 +
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 5 +-
.../beam/sdk/io/gcp/datastore/V1TestUtil.java | 5 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 100 +++++--
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 37 +++
.../pipelines/design-your-pipeline.md | 2 +-
31 files changed, 1189 insertions(+), 123 deletions(-)
delete mode 100644 .github/trigger_files/beam_PostCommit_Java_DataflowV2.json
delete mode 100644 .github/trigger_files/beam_PostCommit_Python.json
delete mode 100644
.github/trigger_files/beam_PostCommit_Python_Examples_Direct.json
delete mode 100644
.github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Direct.json
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/ChannelzServlet.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/ChannelzServletTest.java
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go
