【发布时间】:2016-06-29 13:08:14
【问题描述】:
我正在尝试使用 intellij 运行风暴拓扑。直到今天,拓扑运行得非常好,但今天每次我尝试运行它时,我都会收到以下错误:
Error:maven-resources-test:twitter_storm_new: java.lang.NegativeArraySizeException
谁能告诉我是否有办法解决它以及如何解决?
这是我的拓扑代码:
public class AuthorsAndFeaturesTopology {
public static final String PATH_TO_AUTHORS_AND_FEATURES_FILE="/home/christina/twitter_storm_new/CSV/features.csv";
public static final String PATH_TO_AUTHORS_AND_NEW_FEATURES_FILE="/home/christina/twitter_storm_new/CSV/featuresnew.csv";
public static final String keyword1="#blacklivesmatter";
public static final String keyword2="#germanwings";
public static final String keyword3="#bigdata";
public static void main(String[]args ) throws Exception {
TopologyBuilder topologyBuilder = new TopologyBuilder();
//topologyBuilder.setSpout("PROCESS_AUTHORS_AND_FEATURES_FILE", new ProcessAuthorsAndFeaturesFromCSVFileSpout(PATH_TO_AUTHORS_AND_FEATURES_FILE,keyword1,keyword2,keyword3),4);
Config config = new Config();
if (args != null && args.length > 0) {
config.setNumWorkers(10);
config.setMaxSpoutPending(100);
StormSubmitter.submitTopology(args[0], config, topologyBuilder.createTopology());
} else {
LocalCluster localCluster = new LocalCluster();
localCluster.submitTopology("Test", config, topologyBuilder.createTopology());
Utils.sleep(2*10000);
localCluster.killTopology("Test");
localCluster.shutdown();
}
}
}
【问题讨论】:
标签: java maven intellij-idea apache-storm