Skip to content

Commit 77c139c

Browse files
committed
null naming
1 parent 75b96fc commit 77c139c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

kernel-spark/src/test/scala/io/delta/kernel/spark/snapshot/CatalogManagedSnapshotManagerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ class CatalogManagedSnapshotManagerSuite extends AnyFunSuite with UCCatalogManag
220220
val commitRange = manager.getTableChanges(
221221
defaultEngine,
222222
/* startVersion = */ 1L,
223-
Optional.of(2L) /* endVersion */ )
223+
/* endVersion = */ Optional.of(2L))
224224

225225
assert(commitRange != null, "CommitRange should not be null")
226226
} finally {

kernel-spark/src/test/scala/io/delta/kernel/spark/snapshot/unitycatalog/UnityCatalogAdapterSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ class UnityCatalogAdapterSuite extends AnyFunSuite {
7878
val adapter = new UnityCatalogAdapter(tableId, tablePath, new StubUCClient(
7979
new GetCommitsResponse(commits.asJava, /* latest */ 2L)))
8080

81-
val parsed = adapter.getRatifiedCommits(Optional.empty()).asScala.map(_.getVersion)
81+
val parsed = adapter.getRatifiedCommits(/* endVersionOpt = */ Optional.empty()).asScala.map(_.getVersion)
8282
assert(parsed == Seq(0L, 1L, 2L))
8383
assert(adapter.getLatestRatifiedVersion() == 2L)
8484
}
@@ -96,7 +96,7 @@ class UnityCatalogAdapterSuite extends AnyFunSuite {
9696
throwOnGet = Some(new IOException("boom"))))
9797

9898
assertThrows[java.io.UncheckedIOException] {
99-
adapter.getRatifiedCommits(Optional.empty())
99+
adapter.getRatifiedCommits(/* endVersionOpt = */ Optional.empty())
100100
}
101101
}
102102

@@ -106,7 +106,7 @@ class UnityCatalogAdapterSuite extends AnyFunSuite {
106106
throwOnGet = Some(new CommitLimitReachedException("boom"))))
107107

108108
assertThrows[RuntimeException] {
109-
adapter.getRatifiedCommits(Optional.empty())
109+
adapter.getRatifiedCommits(/* endVersionOpt = */ Optional.empty())
110110
}
111111
}
112112
}

0 commit comments

Comments
 (0)