You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ozan (Jira)" <ji...@apache.org> on 2021/11/16 11:23:00 UTC
[jira] [Created] (FLINK-24923) Flink v1.13.2 restarts itself while Tenable Nessus Vulnerability scans the machines
ozan created FLINK-24923:
----------------------------
Summary: Flink v1.13.2 restarts itself while Tenable Nessus Vulnerability scans the machines
Key: FLINK-24923
URL: https://issues.apache.org/jira/browse/FLINK-24923
Project: Flink
Issue Type: Bug
Affects Versions: 1.13.2
Reporter: ozan
Every day at the same time (1:00 AM), we are scanning all the machines with nessus. But only flink machines fails and restart itself.
We are using flink v.1.13.2, with java 8
I have also opened stackoverflow issue, but it was not solved.
In the log: 1.2.3.4 is the nessus scanner ip address:
{code:java}
2021-11-16 01:02:25,020 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:52128] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1195725860 - discarded
2021-11-16 01:02:25,021 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:59658] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1195725860 - discarded
2021-11-16 01:02:27,872 INFO org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-kafkaGroup-15, groupId=kafkaGroup] Node 5 was unable to process the fetch request with (sessionId=715318048, epoch=18189): FETCH_SESSION_ID_NOT_FOUND.
2021-11-16 01:02:28,837 INFO org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-kafkaGroup-14, groupId=kafkaGroup] Node 7 was unable to process the fetch request with (sessionId=1922249004, epoch=18126): FETCH_SESSION_ID_NOT_FOUND.
2021-11-16 01:02:29,415 INFO org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-kafkaGroup-12, groupId=kafkaGroup] Node 5 was unable to process the fetch request with (sessionId=511071171, epoch=18261): FETCH_SESSION_ID_NOT_FOUND.
2021-11-16 01:02:33,006 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions
org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer
2021-11-16 01:02:33,062 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:56542] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1224736772 - discarded
2021-11-16 01:02:33,063 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:35858] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1224736772 - discarded
2021-11-16 01:02:33,069 ERROR akka.actor.OneForOneStrategy [] - Error while decoding incoming Akka PDU of length: 22
akka.remote.transport.AkkaProtocolException: Error while decoding incoming Akka PDU of length: 22
Caused by: akka.remote.transport.PduCodecException: Decoding PDU failed.
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:174) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.2.jar:1.13.2]
Caused by: akka.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero).
at akka.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:93) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.CodedInputStream.readTag(CodedInputStream.java:112) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8964) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8928) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9024) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9019) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:145) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:181) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:192) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:197) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:53) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.parseFrom(WireFormats.java:9142) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:175) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
2021-11-16 01:02:33,089 ERROR akka.actor.OneForOneStrategy [] - Error while decoding incoming Akka PDU of length: 22
akka.remote.transport.AkkaProtocolException: Error while decoding incoming Akka PDU of length: 22
Caused by: akka.remote.transport.PduCodecException: Decoding PDU failed.
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:174) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
Caused by: akka.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero).
at akka.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:93) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.CodedInputStream.readTag(CodedInputStream.java:112) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8964) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8928) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9024) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9019) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:145) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:181) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:192) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:197) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:53) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.parseFrom(WireFormats.java:9142) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:175) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
2021-11-16 01:02:33,080 ERROR akka.actor.OneForOneStrategy [] - Error while decoding incoming Akka PDU of length: 64
akka.remote.transport.AkkaProtocolException: Error while decoding incoming Akka PDU of length: 64
Caused by: akka.remote.transport.PduCodecException: Decoding PDU failed.
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:174) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.2.jar:1.13.2]
Caused by: akka.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero).
at akka.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:93) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.CodedInputStream.readTag(CodedInputStream.java:112) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8964) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8928) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9024) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9019) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:145) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:181) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:192) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:197) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:53) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.parseFrom(WireFormats.java:9142) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:175) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
2021-11-16 01:02:33,098 ERROR akka.actor.OneForOneStrategy [] - Error while decoding incoming Akka PDU of length: 64
akka.remote.transport.AkkaProtocolException: Error while decoding incoming Akka PDU of length: 64
Caused by: akka.remote.transport.PduCodecException: Decoding PDU failed.
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:174) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
Caused by: akka.protobuf.InvalidProtocolBufferException: Protocol message contained an invalid tag (zero).
at akka.protobuf.InvalidProtocolBufferException.invalidTag(InvalidProtocolBufferException.java:93) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.CodedInputStream.readTag(CodedInputStream.java:112) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8964) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.<init>(WireFormats.java:8928) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9024) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage$1.parsePartialFrom(WireFormats.java:9019) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:145) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:181) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:192) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:197) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.protobuf.AbstractParser.parseFrom(AbstractParser.java:53) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.WireFormats$AkkaProtocolMessage.parseFrom(WireFormats.java:9142) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.AkkaPduProtobufCodec$.decodePdu(AkkaPduCodec.scala:175) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.akka$remote$transport$ProtocolStateActor$$decodePdu(AkkaProtocolTransport.scala:658) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:412) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor$$anonfun$3.applyOrElse(AkkaProtocolTransport.scala:375) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.processEvent(FSM.scala:684) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.processEvent(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:678) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:672) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.remote.transport.ProtocolStateActor.aroundReceive(AkkaProtocolTransport.scala:286) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
2021-11-16 01:02:33,123 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:35898] failed with java.io.IOException: Connection reset by peer
2021-11-16 01:02:33,123 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions
org.apache.flink.shaded.netty4.io.netty.handler.codec.DecoderException: java.lang.IllegalStateException: Network stream corrupted: received incorrect magic number.
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:471) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:276) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [flink-dist_2.11-1.13.2.jar:1.13.2]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.lang.IllegalStateException: Network stream corrupted: received incorrect magic number.
at org.apache.flink.runtime.io.network.netty.NettyMessage$NettyMessageDecoder.decode(NettyMessage.java:210) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:332) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:501) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:440) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
... 14 more
2021-11-16 01:02:33,123 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions
org.apache.flink.shaded.netty4.io.netty.handler.codec.DecoderException: java.lang.IllegalStateException: Network stream corrupted: received incorrect magic number.
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:471) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:276) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [flink-dist_2.11-1.13.2.jar:1.13.2]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.lang.IllegalStateException: Network stream corrupted: received incorrect magic number.
at org.apache.flink.runtime.io.network.netty.NettyMessage$NettyMessageDecoder.decode(NettyMessage.java:210) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:332) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:501) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:440) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
... 14 more
2021-11-16 01:02:33,127 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions
org.apache.flink.shaded.netty4.io.netty.handler.codec.CorruptedFrameException: Adjusted frame length (0) is less than lengthFieldEndOffset: 4
at org.apache.flink.shaded.netty4.io.netty.handler.codec.LengthFieldBasedFrameDecoder.failOnFrameLengthLessThanLengthFieldEndOffset(LengthFieldBasedFrameDecoder.java:358) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:415) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.runtime.io.network.netty.NettyMessage$NettyMessageDecoder.decode(NettyMessage.java:201) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:332) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:501) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:440) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:404) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:371) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:354) ~[flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:818) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) [flink-dist_2.11-1.13.2.jar:1.13.2]
at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [flink-dist_2.11-1.13.2.jar:1.13.2]
at java.lang.Thread.run(Thread.java:829) [?:?]
2021-11-16 01:02:33,164 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:56838] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1212501076 - discarded
2021-11-16 01:02:33,164 WARN akka.remote.transport.netty.NettyTransport [] - Remote connection to [/1.2.3.4:36148] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1212501076 - discarded
2021-11-16 01:02:37,009 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions
org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)