[beam] branch aaltay-patch-1 created (now 07d0a95)

[al...@apache.org]

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

altay pushed a change to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 07d0a95  Fix typo in comment.

This branch includes the following new commits:

     new 07d0a95  Fix typo in comment.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[beam] 01/01: Fix typo in comment.

[al...@apache.org]

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

altay pushed a commit to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 07d0a95261dfad83b75a96942b8f76853a9d8b93
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Wed Jan 9 10:45:22 2019 -0800

    Fix typo in comment.
---
 .../beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java
index 3acbd49..8a1f57d 100644
--- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java
+++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java
@@ -718,7 +718,7 @@ public class GrpcWindmillServer extends WindmillServerStub {
     @Override
     public final void closeAfterDefaultTimeout() throws InterruptedException {
       if (!finishLatch.await(DEFAULT_STREAM_CLEAN_CLOSE_SECONDS, TimeUnit.SECONDS)) {
-        // If the stream did not close due to error in the specified ammount of time, half-close
+        // If the stream did not close due to error in the specified amount of time, half-close
         // the stream cleanly.
         close();
       }