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. */