This is an automated email from the ASF dual-hosted git repository.
xqhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 659cc4dfbd6 Add pipeline option to enforce gbek (#36321)
add 9f8e00e4393 Switch streaming engine worker harness based on job
settings (#35901)
No new revisions were added by this update.
Summary of changes:
.../options/DataflowStreamingPipelineOptions.java | 3 +
.../dataflow/worker/StreamingDataflowWorker.java | 512 +++++++++++++++------
.../harness/SingleSourceWorkerHarness.java | 13 +-
.../dataflow/worker/FakeWindmillServer.java | 47 ++
.../worker/StreamingDataflowWorkerTest.java | 148 ++++++
.../worker/windmill/src/main/proto/windmill.proto | 9 +
6 files changed, 587 insertions(+), 145 deletions(-)
