Sturm localcluster konnte nicht Bolt laden

Question

Ich versuche, sehr einfache Topologie zu debuggen (1 Auslauf 1 Schraube)

public class JoinerTopologyTest { 

public static void main(String[] args) throws IOException { 
    Config conf = new Config(); 
    conf.setNumWorkers(5); 
    conf.setDebug(true); 

    TopologyBuilder builder = new TopologyBuilder(); 
    builder.setSpout("SPOUT-1",new MySpout(),1); 
    builder.setBolt("BOLT-1",new Bolt1(), 3) 
      .shuffleGrouping("SPOUT-1"); 
    //builder.setBolt("JOINER", new JoinerBolt(),1) 
    //  .shuffleGrouping("BOLT-1") 
    //  .shuffleGrouping("SPOUT-1","str1"); 

    final LocalCluster cluster = new LocalCluster(); 
    cluster.submitTopology("TOPO1",conf,builder.createTopology()); 


    System.in.read(); 

    cluster.shutdown(); 
} 

}

Aber wenn ich es aus InteliJ IDEA laufen i erhalten:

java.lang.RuntimeException: java.lang.ClassNotFoundException: com.pixonic.zephyr.compaction.tests.Bolt1 bei org.apache.storm.utils.Utils.javaDeserialize (Utils.java:181) ~ [sturm- core-1.0.1.jar: 1.0.1] bei org.apache.storm.utils.Utils.getSetComponentObject (Utils.java:430) ~ [Sturm-Core-1.0.1.jar: 1.0.1]

und

[ Thread-15] FEHLER oasdworker - Fehler bei der Initialisierung des Servers mk-worker java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.storm.daemon.acker bei org.apache.storm.utils.Utils. javaDeserialize (Utils.java:181) ~ [storm-core-1.0.1.jar: 1.0.1] bei org.apache.storm.utils.Utils.getSetComponentObject (Utils.java:430) ~ [storm-core- 1.0.1.jar: 1.0.1]

aber die gleiche Topologie läuft gut im Cluster-Modus. PS in meinem pom.xml im Debug-Modus i haben:

<dependency> 
     <groupId>org.apache.storm</groupId> 
     <artifactId>storm-core</artifactId> 
     <version>1.0.1</version> 
     <scope>compile</scope> 
    </dependency> 

EDIT

Projekt Fehler zu reproduzieren: https://github.com/holinov/storm-101-localcluster/tree/master

Answer 1

Entsendung es hier wie in den Kommentaren gefragt

Gelöst

Um die Topologie in IDEA auszuführen oder zu debuggen, verwenden Sie maven runner nicht. Klicken Sie einfach mit der rechten Maustaste auf Topologie-Klasse und wählen Sie Debug-> JoinerTopologyTest ... main(), die nicht MVN-Symbol