Skip to content
This repository was archived by the owner on Oct 8, 2020. It is now read-only.

Commit 8620a23

Browse files
Reduce logging.
1 parent 5f17cb7 commit 8620a23

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

sansa-inference-flink/src/main/resources/log4j.properties

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,5 @@ log4j.appender.console=org.apache.log4j.ConsoleAppender
2222
log4j.appender.console.layout=org.apache.log4j.PatternLayout
2323
log4j.appender.console.layout.ConversionPattern=%d{HH:mm:ss,SSS} %-5p %-60c %x - %m%n
2424

25-
log4j.logger.org.apache.flink.runtime=ERROR
25+
log4j.logger.org.apache.flink=ERROR
26+
log4j.logger.akka.event.slf4j=OFF

sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/RDFGraphMaterializer.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ object RDFGraphMaterializer {
3232

3333
// set up the execution environment
3434
val env = ExecutionEnvironment.getExecutionEnvironment
35+
env.getConfig.disableSysoutLogging()
3536

3637
// make parameters available in the web interface
3738
env.getConfig.setGlobalJobParameters(params)
@@ -53,7 +54,7 @@ object RDFGraphMaterializer {
5354
// write triples to disk
5455
RDFGraphWriter.writeToDisk(inferredGraph, output)
5556

56-
println(env.getExecutionPlan())
57+
// println(env.getExecutionPlan())
5758

5859
// run the program
5960
env.execute(s"RDF ${profile} Reasoning")

0 commit comments

Comments
 (0)