This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8ff299d77826260aa21521f4cb8d952d70d2c696 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sun Feb 22 21:23:32 2026 +0100 [hotfix][test] Use `assertThatExceptionOfType` instead of `assertThatThrownBy` in OverAggregateTest.scala --- .../table/planner/plan/stream/sql/agg/OverAggregateTest.scala | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/agg/OverAggregateTest.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/agg/OverAggregateTest.scala index b42f6617ddc..dc173006604 100644 --- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/agg/OverAggregateTest.scala +++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/agg/OverAggregateTest.scala @@ -22,7 +22,7 @@ import org.apache.flink.table.planner.plan.utils.FlinkRelOptUtil import org.apache.flink.table.planner.runtime.utils.JavaUserDefinedAggFunctions.OverAgg0 import org.apache.flink.table.planner.utils.{TableTestBase, TableTestUtil} -import org.assertj.core.api.Assertions.{assertThat, assertThatExceptionOfType, assertThatThrownBy} +import org.assertj.core.api.Assertions.{assertThat, assertThatExceptionOfType} import org.junit.jupiter.api.Test import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ValueSource @@ -492,9 +492,11 @@ class OverAggregateTest extends TableTestBase { |FROM MyTable """.stripMargin - assertThatThrownBy(() => util.verifyExecPlan(sql)) - .hasRootCauseMessage("CHARACTER type is not allowed for window boundary") - .hasRootCauseInstanceOf(classOf[ValidationException]) + assertThatExceptionOfType(classOf[RuntimeException]) + .isThrownBy(() => util.verifyExecPlan(sql)) + .havingRootCause() + .withMessage("CHARACTER type is not allowed for window boundary") + .isExactlyInstanceOf(classOf[ValidationException]) } @ParameterizedTest
