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 ed71866 commit bc48bbdCopy full SHA for bc48bbd
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
@@ -211,7 +211,7 @@ object FileFormatWriter extends Logging {
211
committer,
212
iterator = iter)
213
},
214
- 0 until rddWithNonEmptyPartitions.partitions.length,
+ rddWithNonEmptyPartitions.partitions.indices,
215
(index, res: WriteTaskResult) => {
216
committer.onTaskCommit(res.commitMsg)
217
ret(index) = res
0 commit comments