Github user WeichenXu123 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20837#discussion_r174995768
--- Diff:
mllib/src/main/scala/org/apache/spark/ml/util/Instrumentation.scala ---
@@ -55,6 +55,11 @@ private[spark] class Instrumentation[E <: Estimator[_]]
private (
s" storageLevel=${dataset.getStorageLevel}")
}
+ override def logWarning(msg: => String): Unit = {
+ logNamedValue(Instrumentation.loggerTags.warning, msg)
+ super.logWarning(msg)
--- End diff --
Why not add a `level` param into `Instrumentation : def log(msg: String)`.
instead of the `logWarning` method.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
