You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/11/14 14:15:34 UTC
[2/7] flink git commit: [hotfix][docs][javadocs] Remove double "of"
[hotfix][docs][javadocs] Remove double "of"
This closes #4999.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf099f1d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf099f1d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cf099f1d
Branch: refs/heads/release-1.4
Commit: cf099f1d5c3234efa058351c221089c4e124e82d
Parents: 6f9ab72
Author: yew1eb <ye...@gmail.com>
Authored: Sat Nov 11 20:45:42 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:14 2017 +0100
----------------------------------------------------------------------
docs/ops/config.md | 2 +-
.../java/org/apache/flink/configuration/ConfigConstants.java | 4 ++--
.../scala/org/apache/flink/table/plan/schema/RowSchema.scala | 2 +-
.../apache/flink/runtime/clusterframework/BootstrapTools.java | 2 +-
.../flink/runtime/instance/SlotSharingGroupAssignment.java | 2 +-
.../org/apache/flink/runtime/io/network/netty/NettyClient.java | 2 +-
.../org/apache/flink/yarn/configuration/YarnConfigOptions.java | 2 +-
7 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/docs/ops/config.md
----------------------------------------------------------------------
diff --git a/docs/ops/config.md b/docs/ops/config.md
index 9ee7106..55dec4c 100644
--- a/docs/ops/config.md
+++ b/docs/ops/config.md
@@ -316,7 +316,7 @@ The following parameters configure Flink's JobManager and TaskManagers.
- `taskmanager.exit-on-fatal-akka-error`: Whether the TaskManager shall be terminated in case of a fatal Akka error (quarantining event). (DEFAULT: **false**)
-- `jobmanager.tdd.offload.minsize`: Maximum size of of the `TaskDeploymentDescriptor`'s serialized task and job information to still transmit them via RPC. Larger blobs may be offloaded to the BLOB server. (DEFAULT: **1 KiB**).
+- `jobmanager.tdd.offload.minsize`: Maximum size of the `TaskDeploymentDescriptor`'s serialized task and job information to still transmit them via RPC. Larger blobs may be offloaded to the BLOB server. (DEFAULT: **1 KiB**).
### Distributed Coordination (via Akka)
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
index 4153e45..f9e4735 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
@@ -420,7 +420,7 @@ public final class ConfigConstants {
* The maximum number of failed YARN containers before entirely stopping
* the YARN session / job on YARN.
*
- * By default, we take the number of of initially requested containers.
+ * By default, we take the number of initially requested containers.
* @deprecated in favor of {@code YarnConfigOptions#MAX_FAILED_CONTAINERS}.
*/
@Deprecated
@@ -523,7 +523,7 @@ public final class ConfigConstants {
* The maximum number of failed Mesos tasks before entirely stopping
* the Mesos session / job on Mesos.
*
- * By default, we take the number of of initially requested tasks.
+ * By default, we take the number of initially requested tasks.
* @deprecated in favor of {@code MesosOptions#MAX_FAILED_TASKS}.
*/
@Deprecated
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/RowSchema.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/RowSchema.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/RowSchema.scala
index cfe6683..f5f463c 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/RowSchema.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/RowSchema.scala
@@ -48,7 +48,7 @@ class RowSchema(private val logicalRowType: RelDataType) {
def relDataType: RelDataType = logicalRowType
/**
- * Returns the [[TypeInformation]] of of the schema
+ * Returns the [[TypeInformation]] of the schema
*/
def typeInfo: TypeInformation[Row] = physicalRowTypeInfo
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
index 5849c21..d1efd77 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
@@ -288,7 +288,7 @@ public class BootstrapTools {
}
/**
- * Sets the value of of a new config key to the value of a deprecated config key. Taking into
+ * Sets the value of a new config key to the value of a deprecated config key. Taking into
* account the changed prefix.
* @param config Config to write
* @param deprecatedPrefix Old prefix of key
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupAssignment.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupAssignment.java b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupAssignment.java
index a071e50..7618b18 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupAssignment.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupAssignment.java
@@ -53,7 +53,7 @@ import org.slf4j.LoggerFactory;
* the {@link SimpleSlot}s.</p>
*
* <p>An exception are the co-location-constraints, that define that the i-th subtask of one
- * vertex needs to be scheduled strictly together with the i-th subtasks of of the vertices
+ * vertex needs to be scheduled strictly together with the i-th subtasks of the vertices
* that share the co-location-constraint. To manage that, a co-location-constraint gets its
* own shared slot inside the shared slots of a sharing group.</p>
*
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
index 485af2d..c845cb3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
@@ -208,7 +208,7 @@ class NettyClient {
{
throw new ChannelException(
"The operating system does not offer enough file handles to open the network connection. " +
- "Please increase the number of of available file handles.", e.getCause());
+ "Please increase the number of available file handles.", e.getCause());
}
else {
throw e;
http://git-wip-us.apache.org/repos/asf/flink/blob/cf099f1d/flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java b/flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
index 3773352..02ab6a0 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
@@ -62,7 +62,7 @@ public class YarnConfigOptions {
/**
* The maximum number of failed YARN containers before entirely stopping
* the YARN session / job on YARN.
- * By default, we take the number of of initially requested containers.
+ * By default, we take the number of initially requested containers.
*
* <p>Note: This option returns a String since Integer options must have a static default value.
*/