From ce8cf6bba29e3c3cea9e98beb7d4273f328cce7e Mon Sep 17 00:00:00 2001 From: Kyle Weaver Date: Fri, 21 Feb 2020 13:59:26 -0800 Subject: [PATCH] [BEAM-9356] reduce Flink test logs to warn --- runners/flink/job-server/test_flink_uber_jar.sh | 2 +- .../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 f24c32ac879c5..dce124c9a4eaa 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 2801f9bbfb3b7..b7dc097193627 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 @@ def _subprocess_command(cls, job_port, expansion_port): try: return [ 'java', + '-Dorg.slf4j.simpleLogger.defaultLogLevel=warn', '-jar', flink_job_server_jar, '--flink-master',