This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
commit b848cc239cdf197b18431f384d52b2e8555a8228 Author: Danny Cranmer <[email protected]> AuthorDate: Thu Oct 6 08:40:50 2022 +0100 [FLINK-29476][connector][kinesis] Backport unit test to Flink 1.15 --- .../flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java index 72d34ad8271..b07136b1105 100644 --- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java +++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java @@ -103,7 +103,7 @@ public class KinesisProxyTest { new SdkClientException( "Unable to execute HTTP request", new EOFException("SSL peer shut down incorrectly")); - assertThat(kinesisProxy.isRecoverableSdkClientException(ex)).isTrue(); + assertTrue(kinesisProxy.isRecoverableSdkClientException(ex)); } @Test
