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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2237c69  [BEAM-11581] Minor fix to skip ExecutionStateSampler.reset() 
in ProcessBundleHandler
     new 0e91f1f  Merge pull request #13876 from [BEAM-11581] Minor fix to skip 
ExecutionStateSampler.reset() in ProcessBundleHandler
2237c69 is described below

commit 2237c69b9be739fde89b083a6a8bb4507d429659
Author: Yichi Zhang <[email protected]>
AuthorDate: Mon Feb 1 16:37:12 2021 -0800

    [BEAM-11581] Minor fix to skip ExecutionStateSampler.reset() in 
ProcessBundleHandler
---
 .../java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java
 
b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java
index 4ecb5f5..fbcd71e 100644
--- 
a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java
+++ 
b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java
@@ -699,7 +699,6 @@ public class ProcessBundleHandler {
       getpCollectionConsumerRegistry().reset();
       getMetricsContainerRegistry().reset();
       getStateTracker().reset();
-      ExecutionStateSampler.instance().reset();
       getBundleFinalizationCallbackRegistrations().clear();
       for (ThrowingRunnable resetFunction : getResetFunctions()) {
         resetFunction.run();

Reply via email to