We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5927325 commit f310b4fCopy full SHA for f310b4f
sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/CoreDataflowNodeProcessor.scala
@@ -219,9 +219,9 @@ private class FlowResolver(rawGraph: DataflowGraph) extends Logging {
219
case _: UnresolvedFlow => new CompleteFlow(flow, funcResult)
220
}
221
if (!funcResult.resolved) {
222
- logError(s"Failed to resolve ${flow.displayName}: ${funcResult.failure.mkString("\n\n\n")}")
+ logError(log"Failed to resolve ${flow.displayName}: ${funcResult.failure.mkString("\n\n\n")}")
223
} else {
224
- logInfo(s"Successfully resolved ${flow.displayName}")
+ logInfo(log"Successfully resolved ${flow.displayName}")
225
226
typedFlow
227
0 commit comments