java.lang.OutOfMemoryError: unable to create newnative thread??????????????????????Xmx????????MaxDirectMemorySize??????
------------------ ???????? ------------------ ??????: "LakeShen"<shenleifight...@gmail.com>; ????????: 2020??4??29??(??????) ????10:39 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: ???????? Hi yanggang, ???????????????????????????????????????????????????????????????????????????????? -p 200 -ys 5?? ?????????????? Flink ?????????????? 200?????????? TaskManger ?????????? ?????????????????? TaskManager ???????? 1 / 5?? ?????????? TaskManager ??????1 G ?????????????????????????? 200 M???????? JVM ???????????????????????? ?????????????????????? java.lang.OutOfMemoryError: unable to create newnative thread???????? Flink ?????????????????????? Thread, ???? Thread ?? JVM?????????????????????????? 1M ?? ???????????????????????????????????????????????????? Flink ???? Task ???????????????????????? Running -> Canceling -> Canceled?????????????????????????????? cancel. ???????????????????????????????????? Task ?????? hang ??(????)???????????????????? Canceling. ?????????????????????? -p 64 -ytm 2048???????????????? Best, LakeShen Weihua Hu <huweihua....@gmail.com> ??2020??4??27?????? ????6:27?????? > ???????? jobmanager.execution.failover-strategy ???????????????? region ?????????????????? Task > ?????????????????? > ??????WEB ui ???????????????????? task ?????? > > > Best > Weihua Hu > > > 2020??4??26?? 11:43??yanggang_it_job <yanggang_it_...@163.com> ?????? > > > > ???????????????????????????????????????????????????????????????????? > > ?????????????????????????????????????? > > ???????????????????????? > > 1??????????????????kafka??????????????onGroup????left > join??????????????????????????????600??10????????????????CoGroupFunction?????????????????? > > 2????????????????????CoGruopFunction??Window(TumblingEventTimeWindows(600000), > EventTimeTrigger, CoGroupWindowFunction) (15/200)????OOM???????????? > > java.lang.OutOfMemoryError: unable to create newnative thread > > at java.lang.Thread.start0(NativeMethod) > > at java.lang.Thread.start(Thread.java:717) > > at > java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:957) > > at > java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1378) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask$CheckpointingOperation.executeCheckpointing(StreamTask.java:1237) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.checkpointState(StreamTask.java:872) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:777) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:708) > > at org.apache.flink.streaming.runtime.io > .CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:88) > > at org.apache.flink.streaming.runtime.io > .CheckpointBarrierTracker.processBarrier(CheckpointBarrierTracker.java:137) > > at org.apache.flink.streaming.runtime.io > .CheckpointedInputGate.pollNext(CheckpointedInputGate.java:155) > > at org.apache.flink.streaming.runtime.io > .StreamTaskNetworkInput.pollNextNullable(StreamTaskNetworkInput.java:102) > > at org.apache.flink.streaming.runtime.io > .StreamTaskNetworkInput.pollNextNullable(StreamTaskNetworkInput.java:47) > > at org.apache.flink.streaming.runtime.io > .StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:135) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:279) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:301) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:406) > > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) > > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) > > at java.lang.Thread.run(Thread.java:748) > > > > 3??????????????vertice??FAILED??????vertice????CANCELED??JobManager??????RUNNING > > > > > > ??????????????????????JM????????????????????????TM???????????????????????????????? > > ????????????????????????RUNNING????????RUNNING???????????????????????????? > > > > > > > > > > > > > > > > thanks > > > > > > ?? 2020-04-26 11:01:04??"Zhefu PENG" <pengzf0...@gmail.com> ?????? > >> ???????????????????????????????????????????????? > >> > >> [1] http://apache-flink.147419.n8.nabble.com/flink-kafka-td2386.html > >> [2] http://apache-flink.147419.n8.nabble.com/Flink-Kafka-td2390.html > >> On Sun, Apr 26, 2020 at 10:58 yanggang_it_job <yanggang_it_...@163.com> > >> wrote: > >> > >>> 1??Flink-UI???? > >>> ?????????????????? -p 200 -ys 5??????????????40??TM??????????????????????????????40??TM????????????1??TM???????? > >>> ??????????????????????????????????????????????????????????????????????????????????RUNNING?? > >>> ????????????tm????????????????????????????????????????????FINISHED???????????????????????????????? > >>> ???????????????????????????? > >>> > >>> thanks > >>> > >>> > >>> > >>> > >>> > >>> > >
