Skip to content

Commit

Permalink
Reduce logging level for ADAMKryoRegistrator.
Browse files Browse the repository at this point in the history
  • Loading branch information
heuermh committed Feb 28, 2018
1 parent 0696fea commit 34ed36f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -287,7 +287,7 @@ class ADAMKryoRegistrator extends KryoRegistrator with Logging {
kryo.register(Class.forName("org.apache.spark.sql.execution.datasources.ExecutedWriteSummary"))
} catch {
case cnfe: java.lang.ClassNotFoundException => {
log.info("Did not find Spark internal class. This is expected for earlier Spark versions.")
if (log.isDebugEnabled) log.debug("Did not find Spark internal class. This is expected for earlier Spark versions.")
}
}
kryo.register(classOf[org.apache.spark.sql.catalyst.expressions.UnsafeRow])
Expand Down

0 comments on commit 34ed36f

Please sign in to comment.