Skip to content

Commit 02ff297

Browse files
authored
[Dataflow Streaming] Remove finalizeCommits from processWork (#39648)
1 parent 8bf709c commit 02ff297

1 file changed

Lines changed: 0 additions & 4 deletions

File tree

  • runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/StreamingWorkScheduler.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -232,10 +232,6 @@ private void processWork(
232232
KeyTransitionListener keyTransitionListener = createKeyTransitionListener();
233233
keyTransitionListener.onKeyTransition(null, work);
234234

235-
// Before any processing starts, call any pending OnCommit callbacks. Nothing that requires
236-
// cleanup should be done before this, since we might exit early here.
237-
commitFinalizer.finalizeCommits(workItem.getSourceState().getFinalizeIdsList());
238-
239235
if (workItem.getSourceState().getOnlyFinalize()) {
240236
handleOnlyFinalize(computationState, work, workItem);
241237
return;

0 commit comments

Comments
 (0)