Nick Dimiduk created FLINK-3004:
-----------------------------------
Summary: ForkableMiniCluster does not call RichFunction#open
Key: FLINK-3004
URL: https://issues.apache.org/jira/browse/FLINK-3004
Project: Flink
Issue Type: Bug
Affects Versions: 0.9.1, 0.10
Reporter: Nick Dimiduk
I have a n "integration test" of my streaming flow. It creates a
{{ForkableFlinkMiniCluster}} in the JUnit {{@BeforeClass}} method, to which
test streams are submitted. My flow involves a custom
{{RichCoFlatMapFunction}}. In this function, I finish object initialization via
the {{void open(Configuration)}} method.
When I submit the flow to a local streaming cluster, it runs without incident.
However, submitting the flow in my integration test via maven surefire plugin
has the effect of {{open}} never being called and my object being consumed
without complete initialization.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
