Skip to content
This repository was archived by the owner on Jun 14, 2024. It is now read-only.

Commit e1dee72

Browse files
committed
test fix
1 parent 2089026 commit e1dee72

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

‎src/test/scala/com/microsoft/hyperspace/index/DeltaLakeIntegrationTest.scala‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -242,12 +242,14 @@ class DeltaLakeIntegrationTest extends QueryTest with HyperspaceSuite {
242242
spark.disableHyperspace()
243243
val dfWithHyperspaceDisabled = query()
244244
val basePlan = dfWithHyperspaceDisabled.queryExecution.optimizedPlan
245-
val resultDisabled = dfWithHyperspaceDisabled.collect().toSeq.toSet
245+
val resultDisabled = dfWithHyperspaceDisabled.collect().toSeq.sortBy(_.hashCode())
246246
spark.enableHyperspace()
247247
val dfWithHyperspaceEnabled = query()
248-
assert(!basePlan.equals(dfWithHyperspaceEnabled.queryExecution.optimizedPlan))
249-
val resultEnabled = dfWithHyperspaceEnabled.collect().toSeq.toSet
248+
val updatedPlan = dfWithHyperspaceEnabled.queryExecution.optimizedPlan
249+
val resultEnabled = dfWithHyperspaceEnabled.collect().toSeq.sortBy(_.hashCode())
250+
assert(!basePlan.equals(updatedPlan))
250251
assert(resultEnabled.equals(resultDisabled))
252+
checkAnswer(dfWithHyperspaceDisabled, dfWithHyperspaceEnabled)
251253
}
252254
}
253255
}

0 commit comments

Comments
 (0)