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 fd84229 commit c06e42fCopy full SHA for c06e42f
core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala
@@ -157,8 +157,8 @@ private[spark] class PythonRDD(
157
released = true
158
logInfo(s"Communication with worker ended cleanly, re-use it: $worker")
159
} else {
160
- logInfo(s"Communication with worker did not end cleanly (ending with $ending), " +
161
- s"close it: $worker")
+ logInfo(s"Communication with worker did not end cleanly " +
+ s"(ending with $ending), close it: $worker")
162
}
163
164
logInfo(s"The ending mark from worker is not available, close it: $worker")
0 commit comments