Storm InvalidTopologyException: null

异常信息：

backtype.storm.generated.InvalidTopologyException: nullat backtype.storm.daemon.common$validate_structure_BANG_.invoke(common.clj:151) ~[storm-core-0.9.0.1.jar:na]at backtype.storm.daemon.common$system_topology_BANG_.invoke(common.clj:287) ~[storm-core-0.9.0.1.jar:na]at backtype.storm.daemon.nimbus$fn__5528$exec_fn__1229__auto__$reify__5541.submitTopologyWithOpts(nimbus.clj:932) ~[storm-core-0.9.0.1.jar:na]at backtype.storm.daemon.nimbus$fn__5528$exec_fn__1229__auto__$reify__5541.submitTopology(nimbus.clj:950) ~[storm-core-0.9.0.1.jar:na]at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.6.0_65]at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) ~[na:1.6.0_65]at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) ~[na:1.6.0_65]at java.lang.reflect.Method.invoke(Method.java:597) ~[na:1.6.0_65]at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) ~[clojure-1.4.0.jar:na]at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) ~[clojure-1.4.0.jar:na]at backtype.storm.testing$submit_local_topology.invoke(testing.clj:236) ~[storm-core-0.9.0.1.jar:na]at backtype.storm.LocalCluster$_submitTopology.invoke(LocalCluster.clj:19) ~[storm-core-0.9.0.1.jar:na]at backtype.storm.LocalCluster.submitTopology(Unknown Source) ~[storm-core-0.9.0.1.jar:na]at storm.starter.ApacheAccessLogTopology.main(ApacheAccessLogTopology.java:68) ~[classes/:na]at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.6.0_65]at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) ~[na:1.6.0_65]at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) ~[na:1.6.0_65]at java.lang.reflect.Method.invoke(Method.java:597) ~[na:1.6.0_65]at com.......

原因：

在Bolt中的declareOutputFields中的declareStream与execute中的collector.emit指定的名称不一致，

导致出现问题。

Storm InvalidTopologyException: null相关推荐

backtype.storm.generated.InvalidTopologyException:null问题的解决
程序启动报错: backtype.storm.generated.InvalidTopologyException:null 问题解决方法: 这个错误一般都是没有定义输出列造成的检查Spout和Bo ...
中国最新行政地区表（mysql）
在网上找了很多行政地区表,但是都没有最新的mysql版本,我自己整理了一份,供xdjm们参考: DROP TABLE IF EXISTS `region`; CREATE TABLE `region` ...
2019年全国省市区代码Oracle数据库脚本
delete from DM_GB_B_ZHRMGHGXZQHDM; insert into DM_GB_B_ZHRMGHGXZQHDM (DM, MC, SM, ZT, ZHGXSJ) values ...
聊聊storm的stream的分流与合并
序本文主要研究一下storm的stream的分流与合并实例 @Testpublic void testStreamSplitJoin() throws InvalidTopologyExcepti ...
Storm构建分布式实时处理应用初探（转）
最近利用闲暇时间,又重新研读了一下Storm.认真对比了一下Hadoop,前者更擅长的是,实时流式数据处理,后者更擅长的是基于HDFS,通过MapReduce方式的离线数据分析计算.对于Hadoop, ...
Storm 01之 Storm基本概念及第一个demo
2.1 Storm基本概念在运行一个Storm任务之前,需要了解一些概念: Topologies :[tə'pɑ:lədʒɪ]拓扑结构 Streams Spouts:[spaʊt]喷出; 喷射; 滔 ...
Storm的StreamID使用样例（版本1.0.2）
随手尝试了一下StreamID的的用法.留个笔记. ==数据样例== {"Address": "小桥镇小桥中学对面","CityCode": ...
在线实时大数据平台Storm集成redis开发（分布锁）
1.需求场景:spout从ftp列表中拿到未读取的文件读取并发射行到Bolt,bolt进行业务处理后提交下一Bolt入库.用redis主要是:保存文件列表对象,使用分布锁来同步互斥访问共享对象,使文件 ...
在线实时大数据平台Storm并行度试验
集群模式试验:同一文件输入数据如何处理,数据变量共享 1)集群模式一个worker内一个spout一个Bolt jps:1个worker storm list:1个wokers,4个tasks 2)集 ...

Storm InvalidTopologyException: null

Storm InvalidTopologyException: null相关推荐

最新文章

热门文章