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 0bfe06b61a4 Merge pull request #30587 Properly handle timestamp
prefixing of unkown window types.
add 5697c67421a [runners-flink] #30621 use groupBy for Reshuffle in batch
add 52c0d5a3f86 Merge pull request #30622: [runners-flink] #30621 use
groupBy for Reshuffle in batch
add 14d25c3da76 Fix flaky streaming dataflow tests (#30572)
add ef919e2603f Bump google.golang.org/protobuf in /.test-infra/mock-apis
(#30628)
add 5b2516a7e45 Add hamcrest as an implementation dependency (#30635)
add 4498f35cec5 update containers (#30636)
add dbbfb80232c Add translator for Flink DataStreams. (#30486)
add 49c7864f0ad add flag for direct path that reads from system properties
(#30588)
No new revisions were added by this update.
Summary of changes:
.test-infra/mock-apis/go.mod | 2 +-
.test-infra/mock-apis/go.sum | 4 +-
runners/flink/flink_runner.gradle | 2 -
.../flink/FlinkBatchTransformTranslators.java | 17 +-
.../FlinkStreamingPortablePipelineTranslator.java | 22 +-
.../runners/flink/adapter/BeamAdapterUtils.java | 24 +-
.../flink/adapter/BeamFlinkDataSetAdapter.java | 47 ++--
.../flink/adapter/BeamFlinkDataStreamAdapter.java | 304 +++++++++++++++++++++
.../beam/runners/flink/adapter/FlinkInput.java | 7 +-
.../adapter/BeamFlinkDataStreamAdapterTest.java | 221 +++++++++++++++
runners/google-cloud-dataflow-java/build.gradle | 2 +-
.../options/DataflowStreamingPipelineOptions.java | 8 +
.../dataflow/worker/StreamingDataflowWorker.java | 4 +-
.../worker/windmill/state/WindmillStateCache.java | 30 +-
.../worker/StreamingModeExecutionContextTest.java | 2 +-
.../dataflow/worker/WorkerCustomSourcesTest.java | 3 +-
.../windmill/state/WindmillStateCacheTest.java | 2 +-
.../windmill/state/WindmillStateInternalsTest.java | 2 +-
.../work/budget/GetWorkBudgetRefresherTest.java | 84 +++---
.../refresh/DispatchedActiveWorkRefresherTest.java | 31 ++-
sdks/java/io/google-cloud-platform/build.gradle | 4 +-
21 files changed, 710 insertions(+), 112 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/adapter/BeamFlinkDataStreamAdapter.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/adapter/BeamFlinkDataStreamAdapterTest.java
