alibaba / jstorm

Enterprise Stream Process Engine
http://jstorm.io
Apache License 2.0
3.91k stars 1.81k forks source link

under flow control 错误 #579

Closed whaon closed 6 years ago

whaon commented 7 years ago
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:78-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:102-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:98-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:62-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:74-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:118-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:86-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:82-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:90-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:110-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 
[INFO 2017-09-15 09:31:06 c.a.j.m.n.NettyClientAsync:372 transform-bolt:114-TransferRunnable-0] Pending total time=30000 since target task-37 is under flow control 

看了下源码,貌似和netty有关,请问怎么解决呢

@unsleepy22 @zhuzhaoyuan @Dollyn

longdafeng commented 6 years ago

对方节点接收不过来, 你优化下游节点既可