sparse submit -o supervisor.worker.timeout.secs=600 -n count
An error occurred when I submitted the task:
raceback (most recent call last):
File "/usr/local/python351/bin/sparse", line 10, in
sys.exit(main())
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/cli/sparse.py", line 87, in main
args.func(args)
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/cli/submit.py", line 394, in main
active=args.active,
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/cli/submit.py", line 204, in submit_topology
topology_class = get_topology_from_file(topology_file)
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/util.py", line 573, in get_topology_from_file
mod = importlib.import_module(mod_name)
File "/usr/local/python351/lib/python3.5/importlib/init.py", line 126, in import_module
return _bootstrap._gcd_import(name[level:], package, level)
File "", line 986, in _gcd_import
File "", line 969, in _find_and_load
File "", line 958, in _find_and_load_unlocked
File "", line 673, in _load_unlocked
File "", line 662, in exec_module
File "", line 222, in _call_with_frames_removed
File "topologies/count_topology.py", line 24, in
class RealtimeAction(Topology):
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/dsl/topology.py", line 38, in new
TopologyType.clean_spec_inputs(spec, specs)
File "/usr/local/python351/lib/python3.5/site-packages/streamparse/dsl/topology.py", line 114, in clean_spec_inputs
if isinstance(stream_id.componentId, ComponentSpec):
AttributeError: 'ShellSpoutSpec' object has no attribute 'componentId'
pystorm
