0
그래서 지금 문제를 알고 있기 때문에 질문과 제목을 업데이트했습니다. 이것은 작업자 로그입니다.이 질문과 같은 질문이 많지만 (i) 어떤 솔루션이든 내가 할 수있는 모든 작업을 수행 할 수는 없습니다.여러 defaults.yaml 리소스를 찾았습니다. 스톰 항아리와 토폴로지 항아리를 번들로 묶어 두었을 것입니다.
편집 : 링크에 언급 된 것과 같은 문제이지만 아래 답변에 언급 된 의 다른 원인이 있습니다.
이것은 작업자 로그입니다.
2016-06-23 00:10:56.115 STDERR [INFO] Exception in thread "main" java.lang.ExceptionInInitializerError
2016-06-23 00:10:56.122 STDERR [INFO] at org.apache.storm.config$read_storm_config.invoke(config.clj:78)
2016-06-23 00:10:56.124 STDERR [INFO] at org.apache.storm.daemon.worker$_main.invoke(worker.clj:768)
2016-06-23 00:10:56.124 STDERR [INFO] at clojure.lang.AFn.applyToHelper(AFn.java:165)
2016-06-23 00:10:56.124 STDERR [INFO] at clojure.lang.AFn.applyTo(AFn.java:144)
2016-06-23 00:10:56.125 STDERR [INFO] at org.apache.storm.daemon.worker.main(Unknown Source)
2016-06-23 00:10:56.125 STDERR [INFO] Caused by: java.lang.RuntimeException: java.io.IOException: Found multiple defaults.yaml resources. You're probably bundling the Storm jars with your topology jar. [jar:file:/media/bishoymak/All/College/New%20GP/Second/Programs/storm/lib/storm-core-1.0.1.jar!/defaults.yaml, jar:file:/media/bishoymak/All/College/New%20GP/Second/Programs/storm/storm-local/supervisor/stormdist/LogAnalyserStorm-1-1466632686/stormjar.jar!/defaults.yaml]
2016-06-23 00:10:56.126 STDERR [INFO] at org.apache.storm.utils.Utils.findAndReadConfigFile(Utils.java:307)
2016-06-23 00:10:56.126 STDERR [INFO] at org.apache.storm.utils.Utils.readDefaultConfig(Utils.java:351)
2016-06-23 00:10:56.127 STDERR [INFO] at org.apache.storm.utils.Utils.readStormConfig(Utils.java:387)
2016-06-23 00:10:56.127 STDERR [INFO] at org.apache.storm.utils.Utils.<clinit>(Utils.java:119)
2016-06-23 00:10:56.127 STDERR [INFO] ... 5 more
2016-06-23 00:10:56.128 STDERR [INFO] Caused by: java.io.IOException: Found multiple defaults.yaml resources. You're probably bundling the Storm jars with your topology jar. [jar:file:/media/bishoymak/All/College/New%20GP/Second/Programs/storm/lib/storm-core-1.0.1.jar!/defaults.yaml, jar:file:/media/bishoymak/All/College/New%20GP/Second/Programs/storm/storm-local/supervisor/stormdist/LogAnalyserStorm-1-1466632686/stormjar.jar!/defaults.yaml]
여기 내 pom.xml 파일
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>StormExample</groupId>
<artifactId>StormExample</artifactId>
<version>0.0.1-SNAPSHOT</version>
<build>
<sourceDirectory>src</sourceDirectory>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.3</version>
<configuration>
<source/>
<target/>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>2.6</version>
<executions>
<execution>
<id>LogAnalyserStorm</id>
<phase>package</phase>
<goals>
<goal>jar</goal>
</goals>
<configuration>
<includes>
<include>LogAnalyserStorm.class</include>
<include>FakeCallLogReaderSpout.class</include>
<include>CallLogCounterBolt.class</include>
<include>CallLogCreatorBolt.class</include>
</includes>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>clojars.org</id>
<url>http://clojars.org/repo</url>
</repository>
</repositories>
<dependencies>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>1.0.1</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.1.Final</version>
<scope>provided</scope>
</dependency>
</dependencies>
이다 나는 MVN 항아리를 사용 : 항아리와 MVN 패키지하지만 항상 내가 그것을 만 포함하는 4 개 개의 클래스가 포함한다는하고 있지만 폭풍 코어를 포함 , 그래서 내가 뭘 잘못하고 있는지 말해주십시오.
public static void main(String[] args) throws Exception{
//Create Config instance for cluster configuration
Config config = new Config();
config.setDebug(true);
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("call-log-reader-spout", new FakeCallLogReaderSpout());
builder.setBolt("call-log-creator-bolt", new CallLogCreatorBolt())
.shuffleGrouping("call-log-reader-spout");
builder.setBolt("call-log-counter-bolt", new CallLogCounterBolt())
.fieldsGrouping("call-log-creator-bolt", new Fields("call"));
System.setProperty("storm.jar", "/media/bishoymak/All/College/New GP/Second/Programs/storm/lib/storm-core-1.0.1.jar");
StormSubmitter.submitTopology("LogAnalyserStorm", config, builder.createTopology());
를 제거 pom.xml 파일에 대해 아무것도하지 않는했다 :
여기 내 토폴로지 코드? 또한 StormSubmitter에 부여한 구성을 통해 디버그 모드를 활성화하여 로그에서 자세한 정보를 얻을 수 있습니다. 토폴로지 구축 코드를 추가 할 수 있습니까? –
나는 불행히도 아직 질문을 업데이트하지 않았으므로 다시 확인하고 도움을 주셔서 감사합니다. –
방금 언급 한 솔루션을 게시 한 사람이 같은 사람임을 깨달았습니다. 따라서 pom.xml에서 내가 잘못하고있는 부분을 확인하거나 잘못 작성한 경우 감사합니다. 중복에 대해 죄송합니다. –