[flink] branch master updated: [FLINK-32236][yarn][tests] Ease allow-list regex

[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 37d686e4565 [FLINK-32236][yarn][tests] Ease allow-list regex
37d686e4565 is described below

commit 37d686e4565a0f5d2827920d53a62da92ace1ad5
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Thu Jun 1 11:29:19 2023 +0200

    [FLINK-32236][yarn][tests] Ease allow-list regex
---
 .../src/test/java/org/apache/flink/yarn/YarnTestBase.java             | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
index 7afeb19708f..e63dc6becea 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
@@ -148,9 +148,9 @@ public abstract class YarnTestBase {
         // very specific on purpose; whitelist meaningless exceptions that 
occur during akka
         // shutdown:
         Pattern.compile(
-                "Remote connection to \\[null\\] failed with 
java.net.ConnectException: Connection refused"),
+                "Remote connection to \\[.*\\] failed with 
java.net.ConnectException: Connection refused"),
         Pattern.compile(
-                "Remote connection to \\[null\\] failed with 
java.nio.channels.NotYetConnectedException"),
+                "Remote connection to \\[.*\\] failed with 
java.nio.channels.NotYetConnectedException"),
         Pattern.compile("java\\.io\\.IOException: Connection reset by peer"),
         Pattern.compile(
                 "Association with remote system \\[akka.tcp://flink@[^]]+\\] 
has failed, address is now gated for \\[50\\] ms. Reason: \\[Association failed 
with \\[akka.tcp://flink@[^]]+\\]\\] Caused by: \\[java.net.ConnectException: 
Connection refused: [^]]+\\]"),