proxima-platform icon indicating copy to clipboard operation
proxima-platform copied to clipboard

batchUpdates(long, long).count() broken

Open je-ik opened this issue 5 years ago • 0 comments

On Flink, the above statement fails job. Workaround

batchUpdates(long, long).asUnbounded().withEarlyEmitting(....).count()

works as expected.

je-ik avatar Sep 30 '20 14:09 je-ik