Flink-4450 update storm version to 1.0 #3037
Conversation
| Utils.sleep(100); | ||
| } | ||
| cluster.shutdown(); | ||
| // LocalCluster cluster = new LocalCluster(); |
There was a problem hiding this comment.
Are these lines accidentally commented out, or is this not working with Storm 1.0 any more?
There was a problem hiding this comment.
Yes , It can't work with Strom 1.0.
There was a problem hiding this comment.
Is there an alternative way to do this, or is there no local cluster in Storm 1.0 any more?
There was a problem hiding this comment.
Local Cluster still work in Storm post 1.0, but It can't work in this version by this code, and I didn't find the solution.
How about I solve it later in new pull request?
There was a problem hiding this comment.
That's okay. Can you open a JIRA issue for that?
There was a problem hiding this comment.
OK, I open new issue in FLINK-5522
The reason is: Local Cluster can't run with powermock.
|
Discussions have been resolved, thanks! Merging this... |
@StephanEwen @mxm
The old pull request #2439 was wrong , I use this account make a new pull request.
Please me to review this pull request.
Storm example Test:
