Skip to content

Commit 8ff299d

Browse files
committed
[hotfix][test] Use assertThatExceptionOfType instead of assertThatThrownBy in OverAggregateTest.scala
1 parent 35d1d8a commit 8ff299d

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/agg/OverAggregateTest.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import org.apache.flink.table.planner.plan.utils.FlinkRelOptUtil
2222
import org.apache.flink.table.planner.runtime.utils.JavaUserDefinedAggFunctions.OverAgg0
2323
import org.apache.flink.table.planner.utils.{TableTestBase, TableTestUtil}
2424

25-
import org.assertj.core.api.Assertions.{assertThat, assertThatExceptionOfType, assertThatThrownBy}
25+
import org.assertj.core.api.Assertions.{assertThat, assertThatExceptionOfType}
2626
import org.junit.jupiter.api.Test
2727
import org.junit.jupiter.params.ParameterizedTest
2828
import org.junit.jupiter.params.provider.ValueSource
@@ -492,9 +492,11 @@ class OverAggregateTest extends TableTestBase {
492492
|FROM MyTable
493493
""".stripMargin
494494

495-
assertThatThrownBy(() => util.verifyExecPlan(sql))
496-
.hasRootCauseMessage("CHARACTER type is not allowed for window boundary")
497-
.hasRootCauseInstanceOf(classOf[ValidationException])
495+
assertThatExceptionOfType(classOf[RuntimeException])
496+
.isThrownBy(() => util.verifyExecPlan(sql))
497+
.havingRootCause()
498+
.withMessage("CHARACTER type is not allowed for window boundary")
499+
.isExactlyInstanceOf(classOf[ValidationException])
498500
}
499501

500502
@ParameterizedTest

0 commit comments

Comments
 (0)