You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/01/09 18:45:36 UTC

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

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