Hi! I just saw that all tests in the streaming API are declared as Unit tests, even though the vast majority are integration tests (spawn mini clusters).
That leads to problems, because the streaming test mini clusters do not properly clean up after themselves and unit tests reuse JVMs (for speed, they are expected to be quick). The streaming API is under quite some rework anyways right now, for all new and changes tests, we need to absolutely fix this! Greetings, Stephan
