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/06/02 13:14:20 UTC
[2/6] flink git commit: [FLINK-6795] Activate checkstyle for
runtime/process
[FLINK-6795] Activate checkstyle for runtime/process
This closes #4040.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c041dd81
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c041dd81
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c041dd81
Branch: refs/heads/master
Commit: c041dd81f66b5f53ae8e1911016949eb4c3ff530
Parents: 00a2666
Author: zentol <ch...@apache.org>
Authored: Thu Jun 1 12:25:42 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Fri Jun 2 15:13:55 2017 +0200
----------------------------------------------------------------------
flink-runtime/pom.xml | 1 -
.../main/java/org/apache/flink/runtime/process/ProcessReaper.java | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c041dd81/flink-runtime/pom.xml
----------------------------------------------------------------------
diff --git a/flink-runtime/pom.xml b/flink-runtime/pom.xml
index 0f8e2e9..38ab32b 100644
--- a/flink-runtime/pom.xml
+++ b/flink-runtime/pom.xml
@@ -450,7 +450,6 @@ under the License.
**/runtime/net/**,
**/runtime/operators/**,
**/runtime/plugable/**,
- **/runtime/process/**,
**/runtime/query/**,
**/runtime/registration/**,
**/runtime/resourcemanager/**,
http://git-wip-us.apache.org/repos/asf/flink/blob/c041dd81/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java b/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java
index 09e1839..77ec3eb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java
@@ -50,7 +50,7 @@ public class ProcessReaper extends UntypedActor {
String name = term.actor().path().toSerializationFormat();
if (log != null) {
log.error("Actor " + name + " terminated, stopping process...");
-
+
// give the log some time to reach disk
try {
Thread.sleep(100);