the run method in WriterTask class may take too much cpu.

[lpn666]

when there is no data to sink, the while endless loop will take too much cpu. Maybe we can improve it with Scheduled task and counting task。