beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [beam] 01/01: Fixing minor type
Date Mon, 18 Mar 2019 20:08:31 GMT
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 <aaltay@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. */


Mime
View raw message