Skip to content

Commit

Permalink
Fix broken IT
Browse files Browse the repository at this point in the history
Signed-off-by: Chen Dai <daichen@amazon.com>
  • Loading branch information
dai-chen committed Jun 30, 2023
1 parent 692b9b7 commit 0bbfe8f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,4 +49,4 @@ object FlintSparkIndex {
* ID column name.
*/
val ID_COLUMN: String = "id"
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ import org.apache.spark.sql.flint.config.FlintSparkConf._
import org.apache.spark.sql.functions.col
import org.apache.spark.sql.streaming.StreamTest

class FlintSparkSkippingIndexSuite
class FlintSparkSkippingIndexITSuite
extends QueryTest
with FlintSuite
with OpenSearchSuite
Expand Down Expand Up @@ -205,12 +205,14 @@ class FlintSparkSkippingIndexSuite
flint
.skippingIndex()
.onTable(testTable)
.addPartitions("year")
.create()

assertThrows[IllegalStateException] {
flint
.skippingIndex()
.onTable(testTable)
.addPartitions("year")
.create()
}
}
Expand Down

0 comments on commit 0bbfe8f

Please sign in to comment.