Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5522

Storm LocalCluster can't run with powermock

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.3.0
    • Component/s: DataStream API
    • Labels:
      None

      Description

      Strom LocalCluster can't run with powermock. For example:

      The codes which commented in WrapperSetupHelperTest.testCreateTopologyContext

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          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.

          Show
          githubbot ASF GitHub Bot added a comment - 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.
          Hide
          StephanEwen Stephan Ewen added a comment -

          Fixed via d05fc377ee688b231fb1b0daeb8a34fd054f3ca1

          Show
          StephanEwen Stephan Ewen added a comment - Fixed via d05fc377ee688b231fb1b0daeb8a34fd054f3ca1

            People

            • Assignee:
              Unassigned
              Reporter:
              liuyuzhong7 liuyuzhong7
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development