This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 369409ea492 [IcebergIO] Serialize using json partition (#39705)
add 6ddc7fec3b8 Log the System name in more places instead of the
computationId (#39665)
add e818a0c4ad5 Feat: implementing active cleanup of orphaned
subscriptions for the `taxirides` topic. (#39728)
add dd896e2b239 [Dataflow Streaming] [Multi Key] Drop failed work in
BoundedQueueExecutor::pollWork (#38920)
No new revisions were added by this update.
Summary of changes:
.test-infra/tools/stale_cleaner.py | 2 +-
.../worker/StreamingModeExecutionContext.java | 17 ++-
.../worker/streaming/ComputationWorkExecutor.java | 6 +-
.../worker/streaming/FailedWorkHandler.java | 8 +-
.../dataflow/worker/util/BoundedQueueExecutor.java | 26 +++-
.../work/processing/StreamingWorkScheduler.java | 30 ++--
.../processing/failures/WorkFailureProcessor.java | 31 +++--
.../worker/StreamingDataflowWorkerTest.java | 154 ++++++++++++++++++++-
.../worker/StreamingModeExecutionContextTest.java | 95 +++++++++++--
.../dataflow/worker/WorkerCustomSourcesTest.java | 9 +-
.../worker/util/BoundedQueueExecutorTest.java | 129 ++++++++++++++++-
.../failures/WorkFailureProcessorTest.java | 49 +++++--
12 files changed, 484 insertions(+), 72 deletions(-)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ThrowingRunnable.java =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/FailedWorkHandler.java
(83%)
