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:33 UTC
[1/7] flink git commit: [FLINK-4500][docs] Update cassandra
documentation regarding data loss
Repository: flink
Updated Branches:
refs/heads/release-1.4 8b7698dbc -> fcc79c0ed
[FLINK-4500][docs] Update cassandra documentation regarding data loss
As of FLINK-4500 the Cassandra connector will wait for pending updates to finish upon checkpoint.
This closes #5002.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24970a9f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24970a9f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/24970a9f
Branch: refs/heads/release-1.4
Commit: 24970a9f258c36c3406500ab8f383ded38c25216
Parents: c2d3d6a
Author: Michael Fong <mc...@gmail.com>
Authored: Mon Nov 13 10:17:02 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:14 2017 +0100
----------------------------------------------------------------------
docs/dev/connectors/cassandra.md | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/24970a9f/docs/dev/connectors/cassandra.md
----------------------------------------------------------------------
diff --git a/docs/dev/connectors/cassandra.md b/docs/dev/connectors/cassandra.md
index dd8a775..64d81b5 100644
--- a/docs/dev/connectors/cassandra.md
+++ b/docs/dev/connectors/cassandra.md
@@ -101,8 +101,6 @@ Note that that enabling this feature will have an adverse impact on latency.
### Checkpointing and Fault Tolerance
With checkpointing enabled, Cassandra Sink guarantees at-least-once delivery of action requests to C* instance.
-<p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>: However, current Cassandra Sink implementation does not flush the pending mutations before the checkpoint was triggered. Thus, some in-flight mutations might not be replayed when the job recovered. </p>
-
More details on [checkpoints docs]({{ site.baseurl }}/dev/stream/state/checkpointing.html) and [fault tolerance guarantee docs]({{ site.baseurl }}/dev/connectors/guarantees.html)
## Examples
[4/7] flink git commit: [hotfix][docs] Fix typos in deployment AWS
documentation
Posted by ch...@apache.org.
[hotfix][docs] Fix typos in deployment AWS documentation
This closes #5000.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c2d3d6ae
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c2d3d6ae
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c2d3d6ae
Branch: refs/heads/release-1.4
Commit: c2d3d6aec42170a9962c47556f0e88f4e6815633
Parents: cf099f1
Author: yew1eb <ye...@gmail.com>
Authored: Sat Nov 11 21:08:21 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:14 2017 +0100
----------------------------------------------------------------------
docs/ops/deployment/aws.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c2d3d6ae/docs/ops/deployment/aws.md
----------------------------------------------------------------------
diff --git a/docs/ops/deployment/aws.md b/docs/ops/deployment/aws.md
index 709ecd1..bd11bec 100644
--- a/docs/ops/deployment/aws.md
+++ b/docs/ops/deployment/aws.md
@@ -338,7 +338,7 @@ Caused by: java.lang.ClassNotFoundException: Class org.apache.hadoop.fs.s3native
### IOException: `400: Bad Request`
-If you you have configured everything properly, but get a `Bad Request` Exception **and** your S3 bucket is located in region `eu-central-1`, you might be running an S3 client, which does not support [Amazon's signature version 4](http://docs.aws.amazon.com/AmazonS3/latest/API/sig-v4-authenticating-requests.html).
+If you have configured everything properly, but get a `Bad Request` Exception **and** your S3 bucket is located in region `eu-central-1`, you might be running an S3 client, which does not support [Amazon's signature version 4](http://docs.aws.amazon.com/AmazonS3/latest/API/sig-v4-authenticating-requests.html).
Currently, this includes all Hadoop versions up to 2.7.2 running `NativeS3FileSystem`, which depend on `JetS3t 0.9.0` instead of a version [>= 0.9.4](http://www.jets3t.org/RELEASE_NOTES.html).
[7/7] flink git commit: [FLINK-8006] [Startup Shell Scripts] - Fixing
$pid
Posted by ch...@apache.org.
[FLINK-8006] [Startup Shell Scripts] - Fixing $pid
This closes #4968.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fcc79c0e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fcc79c0e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fcc79c0e
Branch: refs/heads/release-1.4
Commit: fcc79c0ed76818e147381117ea735f5796be6066
Parents: 8d8c52f
Author: Alejandro Alcalde <al...@gmail.com>
Authored: Tue Nov 7 13:09:46 2017 +0100
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:15 2017 +0100
----------------------------------------------------------------------
.../src/main/flink-bin/bin/flink-daemon.sh | 24 ++++++++++----------
1 file changed, 12 insertions(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/fcc79c0e/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
----------------------------------------------------------------------
diff --git a/flink-dist/src/main/flink-bin/bin/flink-daemon.sh b/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
index 6985776..b337a17 100644
--- a/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
+++ b/flink-dist/src/main/flink-bin/bin/flink-daemon.sh
@@ -84,7 +84,7 @@ fi
# Ascending ID depending on number of lines in pid file.
# This allows us to start multiple daemon of each type.
-id=$([ -f "$pid" ] && echo $(wc -l < $pid) || echo "0")
+id=$([ -f "$pid" ] && echo $(wc -l < "$pid") || echo "0")
FLINK_LOG_PREFIX="${FLINK_LOG_DIR}/flink-${FLINK_IDENT_STRING}-${DAEMON}-${id}-${HOSTNAME}"
log="${FLINK_LOG_PREFIX}.log"
@@ -108,7 +108,7 @@ case $STARTSTOP in
rotateLogFilesWithPrefix "$FLINK_LOG_DIR" "$FLINK_LOG_PREFIX"
# Print a warning if daemons are already running on host
- if [ -f $pid ]; then
+ if [ -f "$pid" ]; then
active=()
while IFS='' read -r p || [[ -n "$p" ]]; do
kill -0 $p >/dev/null 2>&1
@@ -134,7 +134,7 @@ case $STARTSTOP in
# Add to pid file if successful start
if [[ ${mypid} =~ ${IS_NUMBER} ]] && kill -0 $mypid > /dev/null 2>&1 ; then
- echo $mypid >> $pid
+ echo $mypid >> "$pid"
else
echo "Error starting $DAEMON daemon."
exit 1
@@ -142,18 +142,18 @@ case $STARTSTOP in
;;
(stop)
- if [ -f $pid ]; then
+ if [ -f "$pid" ]; then
# Remove last in pid file
- to_stop=$(tail -n 1 $pid)
+ to_stop=$(tail -n 1 "$pid")
if [ -z $to_stop ]; then
- rm $pid # If all stopped, clean up pid file
+ rm "$pid" # If all stopped, clean up pid file
echo "No $DAEMON daemon to stop on host $HOSTNAME."
else
- sed \$d $pid > $pid.tmp # all but last line
+ sed \$d "$pid" > "$pid.tmp" # all but last line
# If all stopped, clean up pid file
- [ $(wc -l < $pid.tmp) -eq 0 ] && rm $pid $pid.tmp || mv $pid.tmp $pid
+ [ $(wc -l < "$pid.tmp") -eq 0 ] && rm "$pid" "$pid.tmp" || mv "$pid.tmp" "$pid"
if kill -0 $to_stop > /dev/null 2>&1; then
echo "Stopping $DAEMON daemon (pid: $to_stop) on host $HOSTNAME."
@@ -168,8 +168,8 @@ case $STARTSTOP in
;;
(stop-all)
- if [ -f $pid ]; then
- mv $pid ${pid}.tmp
+ if [ -f "$pid" ]; then
+ mv "$pid" "${pid}.tmp"
while read to_stop; do
if kill -0 $to_stop > /dev/null 2>&1; then
@@ -178,8 +178,8 @@ case $STARTSTOP in
else
echo "Skipping $DAEMON daemon (pid: $to_stop), because it is not running anymore on $HOSTNAME."
fi
- done < ${pid}.tmp
- rm ${pid}.tmp
+ done < "${pid}.tmp"
+ rm "${pid}.tmp"
fi
;;
[3/7] flink git commit: [FLINK-7845][runtime] Make NettyMessage public
Posted by ch...@apache.org.
[FLINK-7845][runtime] Make NettyMessage public
This a walkaround strange javaassist bug. The issue should go away
once we upgrade netty dependency.
Please check the ticket for more information.
This closes #5007.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f9ab721
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6f9ab721
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6f9ab721
Branch: refs/heads/release-1.4
Commit: 6f9ab7217266f5458263fdd976214c1b4c552576
Parents: 8b7698d
Author: Piotr Nowojski <pi...@gmail.com>
Authored: Mon Nov 13 16:51:18 2017 +0100
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:14 2017 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/io/network/netty/NettyMessage.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6f9ab721/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
index e73f61d..89fb9e8 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
@@ -52,8 +52,11 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
/**
* A simple and generic interface to serialize messages to Netty's buffer space.
+ *
+ * <p>This class must be public as long as we are using a Netty version prior to 4.0.45. Please check FLINK-7845 for
+ * more information.
*/
-abstract class NettyMessage {
+public abstract class NettyMessage {
// ------------------------------------------------------------------------
// Note: Every NettyMessage subtype needs to have a public 0-argument
[5/7] flink git commit: [hotfix][docs] Fix broken link to FLINK-7811
Posted by ch...@apache.org.
[hotfix][docs] Fix broken link to FLINK-7811
This closes #4995.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4b99967
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a4b99967
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a4b99967
Branch: refs/heads/release-1.4
Commit: a4b99967cf83084bfa037a507b503b43846431d3
Parents: 24970a9
Author: gyao <ga...@data-artisans.com>
Authored: Fri Nov 10 14:54:32 2017 +0100
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:15 2017 +0100
----------------------------------------------------------------------
docs/start/building.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a4b99967/docs/start/building.md
----------------------------------------------------------------------
diff --git a/docs/start/building.md b/docs/start/building.md
index 455ebbfe..cbf1d1f 100644
--- a/docs/start/building.md
+++ b/docs/start/building.md
@@ -109,7 +109,7 @@ Flink has APIs, libraries, and runtime modules written in [Scala](http://scala-l
Flink 1.4 currently builds only with Scala version 2.11.
-We are working on supporting Scala 2.12, but certain breaking changes in Scala 2.12 make this a more involved effort. Please check out (this JIRA issue)[https://issues.apache.org/jira/browse/FLINK-7811] for updates.
+We are working on supporting Scala 2.12, but certain breaking changes in Scala 2.12 make this a more involved effort. Please check out [this JIRA issue](https://issues.apache.org/jira/browse/FLINK-7811) for updates.
{% top %}
[6/7] flink git commit: [FLINK-8011][dist] Set flink-python to
provided
Posted by ch...@apache.org.
[FLINK-8011][dist] Set flink-python to provided
This closes #4973.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8d8c52f8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8d8c52f8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8d8c52f8
Branch: refs/heads/release-1.4
Commit: 8d8c52f876b79524393d2604b5bedc54c0764ae7
Parents: a4b9996
Author: zentol <ch...@apache.org>
Authored: Tue Nov 7 17:13:57 2017 +0100
Committer: zentol <ch...@apache.org>
Committed: Tue Nov 14 15:15:15 2017 +0100
----------------------------------------------------------------------
flink-dist/pom.xml | 15 ++++++++-------
flink-dist/src/main/assemblies/bin.xml | 11 ++++++++++-
2 files changed, 18 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8d8c52f8/flink-dist/pom.xml
----------------------------------------------------------------------
diff --git a/flink-dist/pom.xml b/flink-dist/pom.xml
index d009ead..dad3b95 100644
--- a/flink-dist/pom.xml
+++ b/flink-dist/pom.xml
@@ -99,12 +99,6 @@ under the License.
<dependency>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-python_${scala.binary.version}</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
<artifactId>flink-scala-shell_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>
@@ -263,6 +257,14 @@ under the License.
<!-- end optional Flink metrics reporters -->
<!-- start optional Flink libraries -->
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-python_${scala.binary.version}</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
+
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-cep_${scala.binary.version}</artifactId>
@@ -485,7 +487,6 @@ under the License.
</filters>
<artifactSet>
<excludes>
- <exclude>org.apache.flink:flink-python_${scala.binary.version}</exclude>
<exclude>org.slf4j:slf4j-log4j12</exclude>
<exclude>log4j:log4j</exclude>
</excludes>
http://git-wip-us.apache.org/repos/asf/flink/blob/8d8c52f8/flink-dist/src/main/assemblies/bin.xml
----------------------------------------------------------------------
diff --git a/flink-dist/src/main/assemblies/bin.xml b/flink-dist/src/main/assemblies/bin.xml
index 8b4526d..eb6867d 100644
--- a/flink-dist/src/main/assemblies/bin.xml
+++ b/flink-dist/src/main/assemblies/bin.xml
@@ -39,7 +39,6 @@ under the License.
<useTransitiveFiltering>true</useTransitiveFiltering>
<includes>
- <include>org.apache.flink:flink-python_${scala.binary.version}</include>
<include>org.slf4j:slf4j-log4j12</include>
<include>log4j:log4j</include>
</includes>
@@ -184,6 +183,16 @@ under the License.
</includes>
</fileSet>
+ <!-- copy python jar -->
+ <fileSet>
+ <directory>../flink-libraries/flink-python/target</directory>
+ <outputDirectory>lib</outputDirectory>
+ <fileMode>0644</fileMode>
+ <includes>
+ <include>flink-python_${scala.binary.version}-${project.version}.jar</include>
+ </includes>
+ </fileSet>
+
<!-- copy python package -->
<fileSet>
<directory>../flink-libraries/flink-python/src/main/python/org/apache/flink/python/api</directory>
[2/7] flink git commit: [hotfix][docs][javadocs] Remove double "of"
Posted by ch...@apache.org.
[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.
*/