[beam] branch master updated: [BEAM-9356] reduce Flink test logs to warn

[ib...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new ce8cf6b  [BEAM-9356] reduce Flink test logs to warn
     new 85259c2  Merge pull request #10931 from ibzib/flink-test-log
ce8cf6b is described below

commit ce8cf6bba29e3c3cea9e98beb7d4273f328cce7e
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Fri Feb 21 13:59:26 2020 -0800

    [BEAM-9356] reduce Flink test logs to warn
---
 runners/flink/job-server/test_flink_uber_jar.sh                  | 2 +-
 sdks/python/apache_beam/runners/portability/flink_runner_test.py | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/runners/flink/job-server/test_flink_uber_jar.sh b/runners/flink/job-server/test_flink_uber_jar.sh
index f24c32a..dce124c 100755
--- a/runners/flink/job-server/test_flink_uber_jar.sh
+++ b/runners/flink/job-server/test_flink_uber_jar.sh
@@ -91,7 +91,7 @@ s.close()
 FLINK_PORT=$(python -c "$SOCKET_SCRIPT")
 
 echo "Starting Flink mini cluster listening on port $FLINK_PORT"
-java -jar "$FLINK_MINI_CLUSTER_JAR" --rest-port "$FLINK_PORT" &
+java -Dorg.slf4j.simpleLogger.defaultLogLevel=warn -jar "$FLINK_MINI_CLUSTER_JAR" --rest-port "$FLINK_PORT" &
 
 PIPELINE_PY="
 import apache_beam as beam
diff --git a/sdks/python/apache_beam/runners/portability/flink_runner_test.py b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
index 2801f9b..b7dc097 100644
--- a/sdks/python/apache_beam/runners/portability/flink_runner_test.py
+++ b/sdks/python/apache_beam/runners/portability/flink_runner_test.py
@@ -138,6 +138,7 @@ if __name__ == '__main__':
       try:
         return [
             'java',
+            '-Dorg.slf4j.simpleLogger.defaultLogLevel=warn',
             '-jar',
             flink_job_server_jar,
             '--flink-master',