Arvid Heise created FLINK-23803:
-----------------------------------
Summary: Improve instantiation of InMemoryReporter
Key: FLINK-23803
URL: https://issues.apache.org/jira/browse/FLINK-23803
Project: Flink
Issue Type: Technical Debt
Components: Test Infrastructure
Affects Versions: 1.14.0
Reporter: Arvid Heise
Currently, InMemoryReporter assumes it's used with the MiniCluster from the
main thread. (It internally uses thread locals)
A better approach would be to create a unique id in the MiniCluster and use the
factory to fetch the appropriate instance from a global map. In this way,
different threading model and even concurrent MiniCluster instances would be
supported.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)