[
https://issues.apache.org/jira/browse/FLINK-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nick Dimiduk resolved FLINK-3004.
---------------------------------
Resolution: Invalid
Looked into creating a demo project; I believe this comes from a bug in my test
code. Sorry for the noise.
> 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)
