proxima-platform
proxima-platform copied to clipboard
batchUpdates(long, long).count() broken
On Flink, the above statement fails job. Workaround
batchUpdates(long, long).asUnbounded().withEarlyEmitting(....).count()
works as expected.