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();