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();
}
