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 LocalStreamEnvironment programmatically. Side-Info: The job is reading from a Kafka Cluster, which is programmatically started for each test run. Cheers, Konstantin -- Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 TNG Technology Consulting GmbH, Betastr. 13a, 85774 Unterföhring Geschäftsführer: Henrik Klagges, Christoph Stock, Dr. Robert Dahlke Sitz: Unterföhring * Amtsgericht München * HRB 135082
signature.asc
Description: OpenPGP digital signature
