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

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15001944#comment-15001944 ] 

Aljoscha Krettek commented on FLINK-3004:
-----------------------------------------

Could you please post example code where this happens. Then I could have a look into it.

> 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)