On Mon, Nov 7, 2016 at 12:41 AM, Demin Alexey <[email protected]> wrote:
> How workaround I tried set withWatermarkFn2 in Instant.now() > This work around should have unblocked DirectRunner as well. I haven't looked at UnboundedReadEvaluatorFactory:142.
