diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java index 79a1f397ac78c..fac413210af63 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java @@ -1554,7 +1554,8 @@ void testUsingAddJarWithCheckpointing() throws Exception { "create function lowerUdf as '%s' LANGUAGE JAVA", udfClassName)), "drop function lowerUdf"); - assertThat(contextClassLoader.equals(Thread.currentThread().getContextClassLoader())); + assertThat(contextClassLoader.equals(Thread.currentThread().getContextClassLoader())) + .isTrue(); } @Test