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/03/18 20:08:31 UTC

[beam] 01/01: Fixing minor type

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 26c7e5e7d3f8eb0c0e63fc4b34af9258749b6e1f
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Mon Mar 18 13:08:09 2019 -0700

    Fixing minor type
---
 .../beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
index 485a789..598dc44 100644
--- a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
+++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
@@ -195,7 +195,7 @@ public class DoFnOperator<InputT, OutputT> extends AbstractStreamOperator<Window
   private transient ScheduledFuture<?> checkFinishBundleTimer;
   /** Time that the last bundle was finished (to set the timer). */
   private transient long lastFinishBundleTime;
-  /** Callback to be executed after the current bundle was finshed. */
+  /** Callback to be executed after the current bundle was finished. */
   private transient Runnable bundleFinishedCallback;
 
   /** Constructor for DoFnOperator. */