@@ -460,13 +460,13 @@ project.tasks.register("xlangSpannerIOIT") {
460460 " --environment_type=LOOPBACK" ,
461461 " --temp_location=gs://temp-storage-for-end-to-end-tests/temp-it" ,
462462 " --flink_job_server_jar=${ project(":runners:flink:${latestFlink1Version}:job-server").shadowJar.archivePath} " ,
463- ' --sdk_harness_log_level_overrides= ' +
464- // suppress info level flink.runtime log flood
465- ' { \\ " org.apache.flink.runtime \\ ": \\ "WARN \\ ", ' +
466- // suppress full __metricscontainers log printed in FlinkPipelineRunner.createPortablePipelineResult
467- ' \\ " org.apache.beam.runners.flink.FlinkPipelineRunner\\ ": \\ "WARN \\ ", ' +
468- // suppress metric name collision warning logs
469- ' \\ " org.apache.flink.runtime.metrics.groups \\ ": \\ "ERROR \\ "} '
463+ // Log spam for Flink runner with embedded jar
464+ ' --job_server_jvm_properties=-Dslf4j.provider=org.slf4j.simple.SimpleServiceProvider ' ,
465+ ' --job_server_jvm_properties=-Dorg.slf4j.simpleLogger.log. org.apache.flink.streaming=error ' ,
466+ ' --job_server_jvm_properties=-Dorg.slf4j.simpleLogger. log.org.apache.flink.runtime=error ' ,
467+ ' --job_server_jvm_properties=-Dorg.slf4j.simpleLogger.log. org.apache.beam.runners.flink.FlinkPipelineRunner=warn ' ,
468+ ' --job_server_jvm_properties=-Dorg.slf4j.simpleLogger.log.org.apache.beam.runners.fnexecution.control=warn ' ,
469+ ' --job_server_jvm_properties=-Dorg.slf4j.simpleLogger.log. org.apache.beam.runners.flink.FlinkPipelineRunner=warn ' ,
470470 ]
471471 def cmdArgs = mapToArgString([
472472 " test_opts" : testOpts,
0 commit comments