Skip to content

Commit 1dd705f

Browse files
committed
fix compile
1 parent 2bee70f commit 1dd705f

File tree

5 files changed

+10
-10
lines changed

5 files changed

+10
-10
lines changed

kernel/kernel-api/src/test/scala/io/delta/kernel/internal/SnapshotManagerSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -618,7 +618,7 @@ class SnapshotManagerSuite extends AnyFunSuite with MockFileSystemClientUtils {
618618
// corrupt incomplete multi-part checkpoint
619619
val corruptedCheckpointStatuses = FileNames.checkpointFileWithParts(logPath, 10, 5).asScala
620620
.map(p => FileStatus.of(p.toString, 10, 10))
621-
.take(4)
621+
.take(4).toSeq
622622
val deltas = deltaFileStatuses(10L to 13L)
623623
testExpectedError[RuntimeException](
624624
corruptedCheckpointStatuses ++ deltas,
@@ -667,7 +667,7 @@ class SnapshotManagerSuite extends AnyFunSuite with MockFileSystemClientUtils {
667667
// _last_checkpoint refers to incomplete multi-part checkpoint
668668
val corruptedCheckpointStatuses = FileNames.checkpointFileWithParts(logPath, 20, 5).asScala
669669
.map(p => FileStatus.of(p.toString, 10, 10))
670-
.take(4)
670+
.take(4).toSeq
671671
testExpectedError[RuntimeException](
672672
files = corruptedCheckpointStatuses ++ deltaFileStatuses(10L to 20L) ++
673673
singularCheckpointFileStatuses(Seq(10L)),

kernel/kernel-defaults/src/test/scala/io/delta/kernel/defaults/DeltaTableReadsSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -261,12 +261,12 @@ class DeltaTableReadsSuite extends AnyFunSuite with TestUtils {
261261
Seq(TestRow(2), TestRow(2), TestRow(2)),
262262
TestRow("2", "2", TestRow(2, 2L)),
263263
"2"
264-
) :: Nil)
264+
) :: Nil).toSeq
265265

266266
checkTable(
267267
path = path,
268268
expectedAnswer = expectedAnswer,
269-
readCols = readCols
269+
readCols = readCols.toSeq
270270
)
271271
}
272272

kernel/kernel-defaults/src/test/scala/io/delta/kernel/defaults/LogReplayMetricsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ trait FileReadMetrics { self: Object =>
342342
}
343343
}
344344

345-
def getVersionsRead: Seq[Long] = versionsRead
345+
def getVersionsRead: Seq[Long] = versionsRead.toSeq
346346

347347
def resetMetrics(): Unit = {
348348
versionsRead.clear()

kernel/kernel-defaults/src/test/scala/io/delta/kernel/defaults/utils/TestRow.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ object TestRow {
105105
case _: StructType => TestRow(row.getStruct(i))
106106
case _ => throw new UnsupportedOperationException("unrecognized data type")
107107
}
108-
})
108+
}.toSeq)
109109
}
110110

111111
def apply(row: SparkRow): TestRow = {

kernel/kernel-defaults/src/test/scala/io/delta/kernel/defaults/utils/TestUtils.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ trait TestUtils extends Assertions with SQLHelper {
7373
while (iter.hasNext) {
7474
result.append(iter.next())
7575
}
76-
result
76+
result.toSeq
7777
} finally {
7878
iter.close()
7979
}
@@ -153,7 +153,7 @@ trait TestUtils extends Assertions with SQLHelper {
153153
// for all primitive types
154154
Seq(new Column((basePath :+ field.getName).asJava.toArray(new Array[String](0))));
155155
case _ => Seq.empty
156-
}
156+
}.toSeq
157157
}
158158

159159
def collectScanFileRows(scan: Scan, tableClient: TableClient = defaultTableClient): Seq[Row] = {
@@ -231,7 +231,7 @@ trait TestUtils extends Assertions with SQLHelper {
231231
}
232232
}
233233
}
234-
result
234+
result.toSeq
235235
}
236236

237237
/**
@@ -623,7 +623,7 @@ trait TestUtils extends Assertions with SQLHelper {
623623
toSparkType(field.getDataType),
624624
field.isNullable
625625
)
626-
})
626+
}.toSeq)
627627
}
628628
}
629629

0 commit comments

Comments
 (0)