Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol , please take a look when you get the chance.
I think testSimpleAfterMatchSkip() is failing
[here](https://api.travis-ci.org/v3/job/392551505/log.txt) because the program
arrived at the assert statement before the result stream was fully added to the
sink. This test was passing in the travis ci build of my fork. Maybe we can add
a countdownlatch to control for the size of the array list VALUES? A rich sink
function would then countdown upon closing. What would you suggest?
---
