Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5997
@zentol you mean change all places in this PR? current change can fix the
issue, for others, I think in a new issue we could do the refactor. what's your
idea?
if you agree this suggestion, I could create a new refactor issue. if not I
will change all the places.---
