[flink] branch master updated: [hotfix][tests] Replace deprecated AbstractThrowableAssert#getRootCause

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 44119780ff3 [hotfix][tests] Replace deprecated 
AbstractThrowableAssert#getRootCause
44119780ff3 is described below

commit 44119780ff3c065c581a8292cba7eead015b7a41
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Wed Aug 31 12:11:57 2022 +0200

    [hotfix][tests] Replace deprecated AbstractThrowableAssert#getRootCause
---
 .../org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java     | 2 +-
 .../org/apache/flink/connectors/hive/HiveDynamicTableFactoryTest.java | 2 +-
 .../org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java   | 4 ++--
 .../runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
index d780b85df57..c3f8a4e7388 100644
--- 
a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
+++ 
b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/AsyncSinkBaseITCase.java
@@ -58,7 +58,7 @@ public class AsyncSinkBaseITCase {
                 .sinkTo(new ArrayListAsyncSink(1, 1, 2, 10, 1000, 10));
         assertThatThrownBy(() -> env.execute("Integration Test: 
AsyncSinkBaseITCase"))
                 .isInstanceOf(JobExecutionException.class)
-                .getRootCause()
+                .rootCause()
                 .hasMessageContaining(
                         "Intentional error on persisting 1_000_000 to 
ArrayListDestination");
     }
diff --git 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDynamicTableFactoryTest.java
 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDynamicTableFactoryTest.java
index 2703044a140..aa4bfffaa54 100644
--- 
a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDynamicTableFactoryTest.java
+++ 
b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDynamicTableFactoryTest.java
@@ -220,7 +220,7 @@ public class HiveDynamicTableFactoryTest {
                         STREAMING_SOURCE_MONITOR_INTERVAL.key(),
                         STREAMING_SOURCE_CONSUME_START_OFFSET.key()));
         assertThatThrownBy(() -> getTableSource("table9"))
-                .getRootCause()
+                .rootCause()
                 .hasMessage(
                         "The 'streaming-source.consume-start-offset' is not 
supported when "
                                 + "set 'streaming-source.partition.include' to 
'latest'");
diff --git 
a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
 
b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
index a9c11656b57..e870873414e 100644
--- 
a/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
+++ 
b/flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcOutputFormatTest.java
@@ -181,7 +181,7 @@ public class JdbcOutputFormatTest extends JdbcDataTestBase {
                             outputFormat.writeRecord(row);
                             outputFormat.close();
                         })
-                .getRootCause()
+                .rootCause()
                 .isInstanceOf(ClassCastException.class);
     }
 
@@ -221,7 +221,7 @@ public class JdbcOutputFormatTest extends JdbcDataTestBase {
                             outputFormat.writeRecord(row);
                             outputFormat.close();
                         })
-                .getRootCause()
+                .rootCause()
                 .isInstanceOf(ClassCastException.class);
     }
 
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java
index a90a245a7c2..9b2a6ac9f88 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessTest.java
@@ -361,7 +361,7 @@ public class SessionDispatcherLeaderProcessTest {
         terminationFuture.completeExceptionally(expectedFailure);
 
         final Throwable error = fatalErrorHandler.getErrorFuture().join();
-        assertThat(error).getRootCause().isEqualTo(expectedFailure);
+        assertThat(error).rootCause().isEqualTo(expectedFailure);
 
         fatalErrorHandler.clearError();
     }