[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 <[email protected]> Authored: Thu Jun 1 12:25:42 2017 +0200 Committer: zentol <[email protected]> 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);
