Merge pull request apache#10931 from ibzib/flink-test-log

[BEAM-9356] reduce Flink test logs to warn
mransley · Feb 25, 2020 · 85259c2 · 85259c2
2 parents 5369582 + ce8cf6b
commit 85259c2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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',