Apache Storm 1.1.0、streamsparse 3.11.0序列化错误。int'对象不是subscriptab

2024-06-16 13:33:21 发布

您现在位置:Python中文网/ 问答频道 /正文

apachestorm1.1.0和streamparse存在一个问题。将序列化程序配置为“msgpack”后,我看到以下错误。你知道有什么办法吗?你知道吗

java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. 

Serializer Exception:
Traceback (most recent call last): 

File "/home/ab/topology/bin/streamparse_run", line 11, in <module> sys.exit(main()) 
File "/home/ab/topology/lib/python3.6/site-packages/streamparse/run.py", line 45, in main cls(serializer=args.serializer).run() 
File "/home/ab/topology/lib/python3.6/site-packages/pystorm/component.py", line 483, in run storm_conf, context = self.read_handshake() 
File "/home/ab/topology/lib/python3.6/site-packages/pystorm/component.py", line 311, in read_handshake pid_dir, _conf, _context = msg['pidDir'], msg['conf'], msg['context'] 

TypeError: 'int' object is not subscriptable 

at org.apache.storm.utils.ShellProcess.launch(ShellProcess.java:96) 
at org.apache.storm.spout.ShellSpout.open(ShellSpout.java:111) 
at org.apache.storm.daemon.executor$fn__4976$fn__4991.invoke(executor.clj:600) 
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:482) 
at clojure.lang.AFn.run(AFn.java:22) 
at java.lang.Thread.run(Thread.java:748)

相关项目包括:


Tags: runinorghomelangabapacheline