[beam] branch master updated: Fix small typo in ProcessBundleHandlerTest.java

[yichi]

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

yichi 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 84201a5  Fix small typo in ProcessBundleHandlerTest.java
     new 88429b2  Merge pull request #16097 from y1chi/fix_typo
84201a5 is described below

commit 84201a5ea4eb669a2998886d0ba057bfff3cece9
Author: Yichi Zhang <zyi...@google.com>
AuthorDate: Wed Dec 1 10:13:41 2021 -0800

    Fix small typo in ProcessBundleHandlerTest.java
---
 .../apache/beam/fn/harness/control/ProcessBundleHandlerTest.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
 
b/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
index 467f414..2b890b2 100644
--- 
a/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
+++ 
b/sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/ProcessBundleHandlerTest.java
@@ -832,7 +832,7 @@ public class ProcessBundleHandlerTest {
     }
   }
 
-  private ProcessBundleHandler setupProcessBundleHanlderForSimpleRecordingDoFn(
+  private ProcessBundleHandler setupProcessBundleHandlerForSimpleRecordingDoFn(
       List<String> dataOutput, List<String> timerOutput) throws Exception {
     DoFnWithExecutionInformation doFnWithExecutionInformation =
         DoFnWithExecutionInformation.of(
@@ -970,7 +970,7 @@ public class ProcessBundleHandlerTest {
     List<String> dataOutput = new ArrayList<>();
     List<String> timerOutput = new ArrayList<>();
     ProcessBundleHandler handler =
-        setupProcessBundleHanlderForSimpleRecordingDoFn(dataOutput, 
timerOutput);
+        setupProcessBundleHandlerForSimpleRecordingDoFn(dataOutput, 
timerOutput);
 
     ByteString.Output encodedData = ByteString.newOutput();
     KvCoder.of(StringUtf8Coder.of(), StringUtf8Coder.of()).encode(KV.of("", 
"data"), encodedData);
@@ -1037,7 +1037,7 @@ public class ProcessBundleHandlerTest {
     List<String> dataOutput = new ArrayList<>();
     List<String> timerOutput = new ArrayList<>();
     ProcessBundleHandler handler =
-        setupProcessBundleHanlderForSimpleRecordingDoFn(dataOutput, 
timerOutput);
+        setupProcessBundleHandlerForSimpleRecordingDoFn(dataOutput, 
timerOutput);
 
     ByteString.Output encodedData = ByteString.newOutput();
     KvCoder.of(StringUtf8Coder.of(), StringUtf8Coder.of()).encode(KV.of("", 
"data"), encodedData);
@@ -1093,7 +1093,7 @@ public class ProcessBundleHandlerTest {
     List<String> dataOutput = new ArrayList<>();
     List<String> timerOutput = new ArrayList<>();
     ProcessBundleHandler handler =
-        setupProcessBundleHanlderForSimpleRecordingDoFn(dataOutput, 
timerOutput);
+        setupProcessBundleHandlerForSimpleRecordingDoFn(dataOutput, 
timerOutput);
 
     ByteString.Output encodedTimer = ByteString.newOutput();
     Timer.Coder.of(StringUtf8Coder.of(), GlobalWindow.Coder.INSTANCE)