[
https://issues.apache.org/jira/browse/FLINK-19295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199193#comment-17199193
]
Robert Metzger commented on FLINK-19295:
----------------------------------------
The prohibited string on the TaskManager is this:
{code}
2020-09-19 22:06:19,428 WARN akka.remote.transport.netty.NettyTransport
[] - Remote connection to [null] failed with
java.net.ConnectException: Connection refused: e466f3e261f3/192.168.224.2:42352
2020-09-19 22:06:19,458 WARN akka.remote.ReliableDeliverySupervisor
[] - Association with remote system
[akka.tcp://flink@e466f3e261f3:42352] has failed, address is now gated for [50]
ms. Reason: [Association failed with [akka.tcp://flink@e466f3e261f3:42352]]
Caused by: [java.net.ConnectException: Connection refused:
e466f3e261f3/192.168.224.2:42352]
2020-09-19 22:06:19,507 INFO org.apache.flink.runtime.taskmanager.Task
[] - Keyed Aggregation -> Sink: Print to Std. Out (1/1)
(b5c8d46f3e7b141acf271f12622e752b_0_0) switched from RUNNING to FINISHED.
2020-09-19 22:06:19,507 INFO org.apache.flink.runtime.taskmanager.Task
[] - Freeing task resources for Keyed Aggregation -> Sink: Print to
Std. Out (1/1) (b5c8d46f3e7b141acf271f12622e752b_0_0).
2020-09-19 22:06:19,507 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Keyed Aggregation -> Sink: Print to Std. Out (1/1)
b5c8d46f3e7b141acf271f12622e752b_0_0.
2020-09-19 22:06:19,580 WARN akka.remote.transport.netty.NettyTransport
[] - Remote connection to [null] failed with
java.net.ConnectException: Connection refused: e466f3e261f3/192.168.224.2:42352
2020-09-19 22:06:19,594 WARN akka.remote.ReliableDeliverySupervisor
[] - Association with remote system
[akka.tcp://flink@e466f3e261f3:42352] has failed, address is now gated for [50]
ms. Reason: [Association failed with [akka.tcp://flink@e466f3e261f3:42352]]
Caused by: [java.net.ConnectException: Connection refused:
e466f3e261f3/192.168.224.2:42352]
{code}
It seems that netty (the RPC netty) is trying to connect to itself (same host)
during the shutdown procedure.
> YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with
> prohibited string
> --------------------------------------------------------------------------------------
>
> Key: FLINK-19295
> URL: https://issues.apache.org/jira/browse/FLINK-19295
> Project: Flink
> Issue Type: Bug
> Components: Deployment / YARN, Tests
> Affects Versions: 1.12.0
> Reporter: Dian Fu
> Assignee: Robert Metzger
> Priority: Major
> Labels: test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=6661&view=logs&j=245e1f2e-ba5b-5570-d689-25ae21e5302f&t=e7f339b2-a7c3-57d9-00af-3712d4b15354]
> {code}
> 2020-09-19T22:08:13.5364974Z [ERROR]
> YARNSessionFIFOITCase.checkForProhibitedLogContents:83->YarnTestBase.ensureNoProhibitedStringInLogFiles:476
> Found a file
> /__w/2/s/flink-yarn-tests/target/flink-yarn-tests-fifo/flink-yarn-tests-fifo-logDir-nm-1_0/application_1600553154281_0001/container_1600553154281_0001_01_000002/taskmanager.log
> with a prohibited string (one of [Exception, Started
> [email protected]:8081]). Excerpts:
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
