[jira] [Created] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open

[Shang Yuanchun (Jira)]

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)