(flink-connector-aws) branch main updated: [FLINK-41047] Do not assert JDK-specific connection-refused text in sink writer tests

[fcsaky]

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

ferenc-csaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git


The following commit(s) were added to refs/heads/main by this push:
     new fb57a23a [FLINK-41047] Do not assert JDK-specific connection-refused 
text in sink writer tests
fb57a23a is described below

commit fb57a23a60777b20fbb8bf16c57f8e778f1abee0
Author: Abhi Gupta <112846463+ggu...@users.noreply.github.com>
AuthorDate: Thu Oct 29 20:54:08 2026 +0530

    [FLINK-41047] Do not assert JDK-specific connection-refused text in sink 
writer tests
---
 .../flink/connector/firehose/sink/KinesisFirehoseSinkWriterTest.java   | 3 +--
 .../java/org/apache/flink/connector/sqs/sink/SqsSinkWriterTest.java    | 3 +--
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriterTest.java
 
b/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriterTest.java
index 6d686aa2..41b9aca9 100644
--- 
a/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriterTest.java
+++ 
b/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriterTest.java
@@ -98,8 +98,7 @@ public class KinesisFirehoseSinkWriterTest {
         assertThatExceptionOfType(CompletionException.class)
                 .isThrownBy(() -> writer.flush(true))
                 .withCauseInstanceOf(SdkClientException.class)
-                .withMessageContaining(
-                        "Unable to execute HTTP request: Connection refused: 
localhost/127.0.0.1:443");
+                .withMessageContaining("Unable to execute HTTP request: 
Connection refused");
         
assertThat(ctx.metricGroup().getNumRecordsOutErrorsCounter().getCount()).isEqualTo(12);
         
assertThat(ctx.metricGroup().getNumRecordsSendErrorsCounter().getCount()).isEqualTo(12);
     }
diff --git 
a/flink-connector-aws/flink-connector-sqs/src/test/java/org/apache/flink/connector/sqs/sink/SqsSinkWriterTest.java
 
b/flink-connector-aws/flink-connector-sqs/src/test/java/org/apache/flink/connector/sqs/sink/SqsSinkWriterTest.java
index 8ea60f97..75fbdad1 100644
--- 
a/flink-connector-aws/flink-connector-sqs/src/test/java/org/apache/flink/connector/sqs/sink/SqsSinkWriterTest.java
+++ 
b/flink-connector-aws/flink-connector-sqs/src/test/java/org/apache/flink/connector/sqs/sink/SqsSinkWriterTest.java
@@ -213,8 +213,7 @@ public class SqsSinkWriterTest {
         assertThatExceptionOfType(CompletionException.class)
                 .isThrownBy(() -> writer.flush(true))
                 .withCauseInstanceOf(SdkClientException.class)
-                .withMessageContaining(
-                        "Unable to execute HTTP request: Connection refused: 
localhost/127.0.0.1:443");
+                .withMessageContaining("Unable to execute HTTP request: 
Connection refused");
         
assertThat(ctx.metricGroup().getNumRecordsOutErrorsCounter().getCount()).isEqualTo(10);
         
assertThat(ctx.metricGroup().getNumRecordsSendErrorsCounter().getCount()).isEqualTo(10);
     }