File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -456,7 +456,7 @@ class StateStoreSuite extends SparkFunSuite with BeforeAndAfter with PrivateMeth
456456 }
457457 }
458458
459- test(" commit fails when rename fails" ) {
459+ test(" SPARK-18342: commit fails when rename fails" ) {
460460 import RenameReturnsFalseFileSystem ._
461461 val dir = scheme + " ://" + Utils .createDirectory(tempDir, Random .nextString(5 )).toString
462462 val conf = new Configuration ()
@@ -613,8 +613,9 @@ private[state] object StateStoreSuite {
613613 }
614614}
615615
616- /** Fake FileSystem to test whether the method `fs.exists` is called during
617- * `DataSource.resolveRelation`.
616+ /**
617+ * Fake FileSystem to test that the StateStore throws an exception while committing the
618+ * delta file, when `fs.rename` returns `false`.
618619 */
619620class RenameReturnsFalseFileSystem extends RawLocalFileSystem {
620621 import RenameReturnsFalseFileSystem ._
You can’t perform that action at this time.
0 commit comments