You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/10/02 13:50:11 UTC
flink git commit: [FLINK-2796][cli] fix -q flag to suppress log output
Repository: flink
Updated Branches:
refs/heads/master df871b3ca -> d486cde76
[FLINK-2796][cli] fix -q flag to suppress log output
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d486cde7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d486cde7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d486cde7
Branch: refs/heads/master
Commit: d486cde762fe64b8527eb02ba32931640597c364
Parents: df871b3
Author: Maximilian Michels <mx...@apache.org>
Authored: Fri Oct 2 13:48:39 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Fri Oct 2 13:48:39 2015 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/client/CliFrontend.java | 1 -
.../java/org/apache/flink/client/cli/CliFrontendParser.java | 5 ++---
2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d486cde7/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
index 034227e..527c0df 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
@@ -666,7 +666,6 @@ public class CliFrontend {
JobSubmissionResult result;
try {
- client.setPrintStatusDuringExecution(true);
result = client.runBlocking(program, parallelism);
}
catch (ProgramInvocationException e) {
http://git-wip-us.apache.org/repos/asf/flink/blob/d486cde7/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
index 0a9af8d..52f1260 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
@@ -51,9 +51,8 @@ public class CliFrontendParser {
"The parallelism with which to run the program. Optional flag to override the default value " +
"specified in the configuration.");
- static final Option LOGGING_OPTION = new Option("q", "sysoutLogging", false, "Whether sysout" +
- " " +
- "logging is required or not");
+ static final Option LOGGING_OPTION = new Option("q", "sysoutLogging", false, "If present, " +
+ "supress logging output to standard out.");
static final Option ARGS_OPTION = new Option("a", "arguments", true,
"Program arguments. Arguments can also be added without -a, simply as trailing parameters.");