This might indicate that the remote task manager has been lost.Īt .io.$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:197)Īt .io.$ConnectingChannel.access$000(PartitionRequestClientFactory.java:132)Īt .io.(PartitionRequestClientFactory.java:84)Īt .io.圜onnectionManager.createPartitionRequestClient(Nett圜onnectionManager.java:59)Īt .io.requestSubpartition(RemoteInputChannel.java:156)Īt .io.requestPartitions(SingleInputGate.java:480)Īt .io.getNextBufferOrEvent(SingleInputGate.java:502)Īt .io.getNextRecord(AbstractRecordReader.java:86)Īt .io.next(MutableRecordReader.java:42)Īt .(ReaderIterator.java:73)Īt .(NoOpDriver.java:94)Īt .(BatchTask.java:490)Īt .(BatchTask.java:355)Īt .(Task.java:718)Ĭaused by: .io.: Connecting to remote task manager + 'hostname/127.0.0.1:46537' has failed. java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'hostname/127.0.0.1:46537' has failed. flink dashboard shows both task managers actvive. When a batch task/job is submitted, one of the task manager is throwing the below error. I have created a flink standalone cluster with 1 job manager and 2 taskmanager.
0 Comments
Leave a Reply. |