You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2018/09/19 06:05:51 UTC
[flink] 02/02: [hotfix][flink-streaming-java] Fix typo in
OperatorChain.
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3292dc5a5fb8ab589f17f90192931fd224936358
Author: unknown <ma...@ad1-zwt.corp.qihoo.net>
AuthorDate: Mon Aug 27 21:14:33 2018 +0800
[hotfix][flink-streaming-java] Fix typo in OperatorChain.
This closes #6619.
---
.../java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
index 015b7db..d49b023 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
@@ -315,7 +315,7 @@ public class OperatorChain<OUT, OP extends StreamOperator<OUT>> implements Strea
return allOutputs.get(0).f0;
}
else {
- // send to N outputs. Note that this includes teh special case
+ // send to N outputs. Note that this includes the special case
// of sending to zero outputs
@SuppressWarnings({"unchecked", "rawtypes"})
Output<StreamRecord<T>>[] asArray = new Output[allOutputs.size()];