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 35c6636 commit 1818cb2Copy full SHA for 1818cb2
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/CheckpointFileManagerSuite.scala
@@ -119,12 +119,10 @@ class CheckpointFileManagerSuite extends SparkFunSuite with SharedSparkSession {
119
assert(metadataLog.get(0) === Some("batch0"))
120
assert(metadataLog.get(None, Some(0)) === Array(0 -> "batch0"))
121
122
-
123
val metadataLog2 = new HDFSMetadataLog[String](spark, s"$scheme://${temp.toURI.getPath}")
124
assert(metadataLog2.get(0) === Some("batch0"))
125
assert(metadataLog2.getLatest() === Some(0 -> "batch0"))
126
assert(metadataLog2.get(None, Some(0)) === Array(0 -> "batch0"))
127
128
}
129
130
0 commit comments