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