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:30 UTC

[beam] branch aaltay-patch-1 created (now 26c7e5e)

This is an automated email from the ASF dual-hosted git repository.

altay pushed a change to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 26c7e5e  Fixing minor type

This branch includes the following new commits:

     new 26c7e5e  Fixing minor type

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[beam] 01/01: Fixing minor type

Posted by al...@apache.org.
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. */