[
https://issues.apache.org/jira/browse/FLINK-5522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825858#comment-15825858
]
ASF GitHub Bot commented on FLINK-5522:
---------------------------------------
Github user liuyuzhong7 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3037#discussion_r96388944
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
---
@@ -186,15 +186,15 @@ public void testCreateTopologyContext() {
.shuffleGrouping("bolt2",
TestDummyBolt.groupingStreamId)
.shuffleGrouping("bolt2",
TestDummyBolt.shuffleStreamId);
- LocalCluster cluster = new LocalCluster();
- Config c = new Config();
- c.setNumAckers(0);
- cluster.submitTopology("test", c, builder.createTopology());
-
- while (TestSink.result.size() != 8) {
- Utils.sleep(100);
- }
- cluster.shutdown();
+// LocalCluster cluster = new LocalCluster();
--- End diff --
OK, I open new issue in
[FLINK-5522](https://issues.apache.org/jira/browse/FLINK-5522)
The reason is: Local Cluster can't run with powermock.
> Storm LocalCluster can't run with powermock
> -------------------------------------------
>
> Key: FLINK-5522
> URL: https://issues.apache.org/jira/browse/FLINK-5522
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API
> Affects Versions: 1.3.0
> Reporter: liuyuzhong7
> Fix For: 1.3.0
>
>
> Strom LocalCluster can't run with powermock. For example:
> The codes which commented in WrapperSetupHelperTest.testCreateTopologyContext
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
