Re: OutputFlusher线程创建太多

2019-09-19 文章 Yun Gao
理论上来说每个ResultPartition会创建一个OutputFlush线程，这个作业一个TM上面有多少个Task? 每个Task有多少个ResultPartition？ -- From:李杰 Send Time:2019 Sep. 19 (Thu.) 10:02 To:user-zh Subject:OutputFlusher线程创建太多 flink 1.7.0 on yarn模式 = 程序运行了大概

OutputFlusher线程创建太多

2019-09-18 文章 李杰
flink 1.7.0 on yarn模式 = 程序运行了大概一周，检测发现YarnTaskExecutorRunner，线程数达彪到了1左右，正常来说应该不到400. dump线程栈发现大量 的【接近1w】 的 TIMED_WAITING (sleeping) 状态的outputFluster "OutputFlusher for -> " #1017018 daemon prio=5 os_prio=0 tid=0x01bb6000 nid=0x894a sleeping[0x2b0f6c4