Merge pull request #461 from n-shiota/debug

Fixed concurrency problem in FlowPusher