[flink] branch master updated: [hotfix] Fix typo in AbstractStreamOperator

[dwysakowicz]

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

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new a70f503  [hotfix] Fix typo in AbstractStreamOperator
a70f503 is described below

commit a70f503c091be33e526661cc7ec5335a4349e82b
Author: boshu Zheng <blues....@gmail.com>
AuthorDate: Wed Dec 19 19:27:06 2018 +0800

    [hotfix] Fix typo in AbstractStreamOperator
---
 .../apache/flink/streaming/api/operators/AbstractStreamOperator.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
index d9a195c..fa5231e 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -639,7 +639,7 @@ public abstract class AbstractStreamOperator<OUT>
                if (keyedStateBackend != null) {
                        return keyedStateBackend.getCurrentKey();
                } else {
-                       throw new UnsupportedOperationException("Key can only 
be retrieven on KeyedStream.");
+                       throw new UnsupportedOperationException("Key can only 
be retrieved on KeyedStream.");
                }
        }