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 72a5ec0 commit 876f9f9Copy full SHA for 876f9f9
core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala
@@ -104,7 +104,7 @@ private[spark] class PythonRunner(
104
argOffsets: Array[Array[Int]])
105
extends Logging {
106
107
- require(funcs.length == argOffsets.length, "numArgs should have the same length as funcs")
+ require(funcs.length == argOffsets.length, "argOffsets should have the same length as funcs")
108
109
// All the Python functions should have the same exec, version and envvars.
110
private val envVars = funcs.head.funcs.head.envVars
0 commit comments