You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/03/18 17:49:02 UTC
[13/13] flink git commit: [FLINK-1671] [optimizer] Fix comment typos
[FLINK-1671] [optimizer] Fix comment typos
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a49a73a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4a49a73a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4a49a73a
Branch: refs/heads/master
Commit: 4a49a73a751822c0bca715e7b889c0a05d2a73bd
Parents: cf6c63c
Author: Ufuk Celebi <uc...@apache.org>
Authored: Tue Mar 17 10:47:27 2015 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed Mar 18 17:44:41 2015 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/io/network/DataExchangeMode.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4a49a73a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java
index 7810c3e..c124383 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java
@@ -34,12 +34,12 @@ public enum DataExchangeMode {
/**
* The data exchange is decoupled. The sender first produces its entire result and finishes.
- * After that, the receiver is stated and may consume the data.
+ * After that, the receiver is started and may consume the data.
*/
BATCH,
/**
- * The data exchange starts like ine {@link #PIPELINED} and falls back to {@link #BATCH}
+ * The data exchange starts like in {@link #PIPELINED} and falls back to {@link #BATCH}
* for recovery runs.
*/
PIPELINE_WITH_BATCH_FALLBACK;
@@ -59,7 +59,7 @@ public enum DataExchangeMode {
}
/**
- * Computes the mode of data exchange to be used for a, given an execution mode and ship strategy.
+ * Computes the mode of data exchange to be used for a given execution mode and ship strategy.
* The type of the data exchange depends also on whether this connection has been identified to require
* pipeline breaking for deadlock avoidance.
* <ul>