Skip to content

Commit 3b0709d

Browse files
cleanup
1 parent 416f847 commit 3b0709d

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestLanceDataSource.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -581,7 +581,7 @@ class TestLanceDataSource extends HoodieSparkClientTestBase {
581581

582582
// Verify commit action types based on table type
583583
val expectedAction = if (tableType == "COPY_ON_WRITE") "commit" else "deltacommit"
584-
val commits = metaClient.getCommitsTimeline.filterCompletedInstants().getInstants.iterator().asScala.toList
584+
val commits = metaClient.getCommitsTimeline.filterCompletedInstants().getInstants.asScala
585585
commits.foreach { instant =>
586586
assertEquals(expectedAction, instant.getAction,
587587
s"Instant ${instant.requestedTime()} should be a $expectedAction action for $tableType table")
@@ -663,7 +663,7 @@ class TestLanceDataSource extends HoodieSparkClientTestBase {
663663

664664
// Verify commit action types based on table type
665665
val expectedAction = if (tableType == "COPY_ON_WRITE") "commit" else "deltacommit"
666-
val commits = metaClient.getCommitsTimeline.filterCompletedInstants().getInstants.iterator().asScala.toList
666+
val commits = metaClient.getCommitsTimeline.filterCompletedInstants().getInstants.asScala
667667
commits.foreach { instant =>
668668
assertEquals(expectedAction, instant.getAction,
669669
s"Instant ${instant.requestedTime()} should be a $expectedAction action for $tableType table")

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -241,8 +241,8 @@
241241
<spring.shell.version>2.1.1</spring.shell.version>
242242
<snappy.version>1.1.10.7</snappy.version>
243243
<arrow.version>18.3.0</arrow.version>
244-
<lance.version>0.38.0</lance.version>
245-
<lance.spark.connector.version>0.0.13</lance.spark.connector.version>
244+
<lance.version>0.39.0</lance.version>
245+
<lance.spark.connector.version>0.0.15</lance.spark.connector.version>
246246
<lance.spark.artifact>lance-spark-3.5_${scala.binary.version}</lance.spark.artifact>
247247
<lance.skip.tests>false</lance.skip.tests>
248248
<!-- The following properties are only used for Jacoco coverage report aggregation -->

0 commit comments

Comments
 (0)