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