Hi Aljoscha,
thanks for the answer. executeDetached() sounds super helpful for
testing. You could basically return a Future for stopping, cancelling
and so on.
In my current IT I dont have a special sink, I am checking the resulting
files directly, but live access to accumulators sounds very help
Hi Konstantin,
I think this is not possible with the current API but I've been thinking
about similar stuff this week. Let me quickly outline what I was thinking
and then you can tell me whether that would also be helpful for you.
The basic problem is this: I want to be able to write ITCases that
Hi everyone,
I have an integration test for which a use a LocalStreamEnvironment.
Currently, the Flink Job is started in a separated thread, which I
interrupt after some time and then do some assertions.
In this situation is there a better way to stop/cancel a running job in
LocalStreamEnvironmen
