Org.apache.flink.runtime.io.network.net ty. Exception. RemoteTransportException: Connection unexpectedly closed by remote task manager 'xxx.com/xxx:36769'. This took indicate that the remote task manager was lost.
The at org.apache.flink.runtime.io.network.net ty. CreditBasedPartitionRequestClientHandler. ChannelInactive (CreditBasedPartitionRequestClientHandler. Java: 143)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. InvokeChannelInactive (AbstractChannelHandlerContext. Java: 237)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. FireChannelInactive (AbstractChannelHandlerContext. Java: 223)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. ChannelInboundHandlerAdapter. ChannelInactive (ChannelInboundHandlerAdapter. Java: 75)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. InvokeChannelInactive (AbstractChannelHandlerContext. Java: 237)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. FireChannelInactive (AbstractChannelHandlerContext. Java: 223)
The at org.apache.flink.shaded.netty4.io.net ty. Handler. Codec. ByteToMessageDecoder. ChannelInactive (ByteToMessageDecoder. Java: 294)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. InvokeChannelInactive (AbstractChannelHandlerContext. Java: 237)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannelHandlerContext. FireChannelInactive (AbstractChannelHandlerContext. Java: 223)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. DefaultChannelPipeline. FireChannelInactive (DefaultChannelPipeline. Java: 829)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. AbstractChannel $AbstractUnsafe $7. The run (AbstractChannel. Java: 610)
The at org.apache.flink.shaded.netty4.io.net ty. Util. Concurrent. SingleThreadEventExecutor. RunAllTasks (SingleThreadEventExecutor. Java: 357)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. Nio. NioEventLoop. Run (NioEventLoop. Java: 357)
At org.apache.flink.shaded.netty4.io.net ty. Util. Concurrent. SingleThreadEventExecutor $2. The run (111) SingleThreadEventExecutor. Java:
The at Java. Lang. Thread. The run (Thread. Java: 748)

CodePudding user response:

Flink upstream from kafka receiving data partition 2
Internal calculation of concurrent taskmanager set of 16 operator 8

CodePudding user response:

Task stack information below

"Flink Netty Server (0) Thread 0" daemon prio=5 # 60 os_prio=0 tid=0 x00007f5b91b43000 nid=0 x9307 runnable x00007f5b5f59c000 [0]
Java. Lang. Thread. The State: a RUNNABLE
At sun. Nio. Ch. EPollArrayWrapper. EpollWait (Native Method)
At sun. Nio. Ch. EPollArrayWrapper. Poll (EPollArrayWrapper. Java: 269)
At sun. Nio. Ch. EPollSelectorImpl. DoSelect (EPollSelectorImpl. Java: 93)
At sun. Nio. Ch. SelectorImpl. LockAndDoSelect (SelectorImpl. Java: 86)
- locked & lt; 0 x0000000730a3dc40 & gt; (a org.apache.flink.shaded.netty4.io.net ty. Channel. Nio. SelectedSelectionKeySet)
- locked & lt; 0 x00000007317b2bb8 & gt; (a Java. Util. Collections $UnmodifiableSet)
- locked & lt; 0 x00000007320b56b8 & gt; (a sun. Nio. Ch. EPollSelectorImpl)
At sun. Nio. Ch. SelectorImpl. Select (SelectorImpl. Java: 97)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. Nio. NioEventLoop. Select (NioEventLoop. Java: 622)
The at org.apache.flink.shaded.netty4.io.net ty. Channel. Nio. NioEventLoop. Run (NioEventLoop. Java: 310)
At org.apache.flink.shaded.netty4.io.net ty. Util. Concurrent. SingleThreadEventExecutor $2. The run (111) SingleThreadEventExecutor. Java:
The at Java. Lang. Thread. The run (Thread. Java: 748)

"The Timer 1" daemon prio=5 # 58 os_prio=0 tid=0 x00007f5b92edd800 nid=0 x92da Object. In wait () [0 x00007f5b5f89d000]
Java. Lang. Thread. The State: TIMED_WAITING (on object monitor)
The at Java. Lang. Object. Wait (Native Method)
The at Java. Util. TimerThread. MainLoop (Timer. Java: 552)
- locked & lt; 0 x00000007329fba78 & gt; (a Java. Util. TaskQueue)
The at Java. Util. TimerThread. Run (Timer. Java: 505)

"Timer 0 # 56 daemon prio=5 os_prio=0 tid=0 x00007f5b92eda000 nid=0 x92d9 Object. In wait () [0 x00007f5b5f99e000]
Java. Lang. Thread. The State: TIMED_WAITING (on object monitor)
The at Java. Lang. Object. Wait (Native Method)
The at Java. Util. TimerThread. MainLoop (Timer. Java: 552)
- locked & lt; 0 x00000007329f6048 & gt; (a Java. Util. TaskQueue)
The at Java. Util. TimerThread. Run (Timer. Java: 505)

"Flink - MetricRegistry - thread - 1" daemon prio=5 # 54 os_prio=0 tid=0 x00007f5b91e67000 nid=0 x92d3 waiting on condition x00007f5b5fa9f000 [0]
Java. Lang. Thread. The State: TIMED_WAITING (parking)
At sun. Misc. Unsafe. Park (Native Method)
- parking to wait for & lt; 0 x000000073221fa98 & gt; (a Java. Util. Concurrent. The locks. AbstractQueuedSynchronizer $ConditionObject)
The at Java. Util. Concurrent. The locks. LockSupport. ParkNanos (LockSupport. Java: 215)
The at Java. Util. Concurrent. The locks. AbstractQueuedSynchronizer $ConditionObject. AwaitNanos (AbstractQueuedSynchronizer. Java: 2078)
nullnullnullnullnullnull