??????flink on kubernetes ????????????????

Thu, 07 May 2020 19:10:25 -0700 

Map??????????????????????????????????????es????




------------------ ???????? ------------------
??????: "a511955993"<[email protected]&gt;; 
????????: 2020??5??7??(??????) ????9:51
??????: "user-zh"<[email protected]&gt;; 
????: flink on kubernetes ????????????????



hi??&nbsp;all


??????????
flink??????1.10????????kubernetes????kubernetes??????1.17.4??docker??????19.03??&nbsp;cni????????weave??


??????
??????????????????????????operation??????????????????????????????????????????????????????????????????kill??????????


????jstack????????????????????????


&quot;Map&nbsp;(152/200)&quot;&nbsp;#155&nbsp;prio=5&nbsp;os_prio=0&nbsp;tid=0x00007f67a4076800&nbsp;nid=0x31f&nbsp;waiting&nbsp;on&nbsp;condition&nbsp;[0x00007f66b04ed000]
&nbsp;&nbsp;&nbsp;java.lang.Thread.State:&nbsp;WAITING&nbsp;(parking)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;sun.misc.Unsafe.park(Native&nbsp;Method)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;-&nbsp;parking&nbsp;to&nbsp;wait&nbsp;for&nbsp;&nbsp;<0x0000000608f3c600&gt;&nbsp;(a&nbsp;java.util.concurrent.CompletableFuture$Signaller)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestMemorySegmentBlocking(LocalBufferPool.java:231)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBufferBuilderBlocking(LocalBufferPool.java:209)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.partition.ResultPartition.getBufferBuilder(ResultPartition.java:189)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.api.writer.ChannelSelectorRecordWriter.requestNewBufferBuilder(ChannelSelectorRecordWriter.java:103)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.api.writer.RecordWriter.copyFromSerializerToTargetChannel(RecordWriter.java:145)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:116)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.runtime.io.network.api.writer.ChannelSelectorRecordWriter.emit(ChannelSelectorRecordWriter.java:60)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:107)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:89)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;at&nbsp;org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:45)




??????????????????????????????????????????????????
taskmanager.network.request-backoff.max:&nbsp;300000
akka.ask.timeout:&nbsp;120s
akka.watch.heartbeat.interval:&nbsp;10s


??????????buffer??????????????
taskmanager.network.memory.floating-buffers-per-gate:&nbsp;16
taskmanager.network.memory.buffers-per-channel:&nbsp;6




??????????????????????????????????????????????????????????????????????

Looking&nbsp;forward&nbsp;to&nbsp;your&nbsp;reply&nbsp;and&nbsp;help.

Best

回复