Skip to content

Commit

Permalink
Initial
Browse files Browse the repository at this point in the history
  • Loading branch information
PHILO-HE committed Aug 21, 2024
1 parent eedc6cd commit f2a5210
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -117,15 +117,15 @@ class GlutenInsertSuite
}

testGluten("Cleanup staging files if job is failed") {
withTable("t") {
spark.sql("CREATE TABLE t (c1 int, c2 string) USING PARQUET")
val table = spark.sessionState.catalog.getTableMetadata(TableIdentifier("t"))
withTable("t1") {
spark.sql("CREATE TABLE t1 (c1 int, c2 string) USING PARQUET")
val table = spark.sessionState.catalog.getTableMetadata(TableIdentifier("t1"))
assert(new File(table.location).list().length == 0)

intercept[Exception] {
spark.sql(
"""
|INSERT INTO TABLE t
|INSERT INTO TABLE t1
|SELECT id, assert_true(SPARK_PARTITION_ID() = 1) FROM range(1, 3, 1, 2)
|""".stripMargin
)
Expand Down

0 comments on commit f2a5210

Please sign in to comment.