Thanks for the clarification. I'm not familiar enough with the
internals of flink to offer any technical suggestions, but it'd be
nice to have some more documentation around testing flink and possible
pitfalls like this.
For anybody with the same issue, note that IngestionTime also works,
and is s
Hi,
I'm afraid there is no way of making this work with the current
implementation. Especially getting this to work in a distributed setting
seems hard.
I'm very open for suggestions on this topic, though. :-)
Cheers,
Aljoscha
On Mon, 23 Jan 2017 at 23:19 Steven Ruppert wrote:
> Hi,
>
> I'm at
Hi,
I'm attempting to unit test link with the flink-test-utils support, on
flink 1.1.4. I've got basic flatMap stuff flowing through just fine,
but when running any processing time-based windowing functions,
`env.execute()` will return before any values are flushed out of the
windows.
import org.
