You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by sc...@apache.org on 2024/03/04 09:51:39 UTC

(beam) branch master updated (935ca9c58d6 -> be1526b7b57)

This is an automated email from the ASF dual-hosted git repository.

scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 935ca9c58d6 fix alerting path for grafana provisioning (#30464)
     add be1526b7b57 Register streaming specific options with DataflowPipelineRegistrar (#30474)

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/dataflow/DataflowRunner.java      |   3 +-
 .../options/DataflowPipelineDebugOptions.java      | 111 -----------------
 .../dataflow/options/DataflowPipelineOptions.java  |   1 +
 .../options/DataflowStreamingPipelineOptions.java} | 134 +++++++++++++++++++--
 .../dataflow/worker/StreamingDataflowWorker.java   |  25 ++--
 .../worker/streaming/sideinput/SideInputCache.java |   4 +-
 .../streaming/sideinput/SideInputStateFetcher.java |   4 +-
 .../windmill/client/grpc/ChannelzServlet.java      |   6 +-
 .../windmill/client/grpc/GrpcWindmillServer.java   |  20 +--
 .../worker/DataflowWorkerHarnessHelperTest.java    |   9 +-
 .../worker/StreamingDataflowWorkerTest.java        |  40 +++---
 .../dataflow/worker/status/DebugCaptureTest.java   |   8 +-
 .../sideinput/SideInputStateFetcherTest.java       |   8 +-
 .../windmill/client/grpc/ChannelzServletTest.java  |  10 +-
 14 files changed, 192 insertions(+), 191 deletions(-)
 rename runners/google-cloud-dataflow-java/{worker/src/main/java/org/apache/beam/runners/dataflow/worker/options/StreamingDataflowWorkerOptions.java => src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java} (56%)