pystorm / streamparse

Run Python in Apache Storm topologies. Pythonic API, CLI tooling, and a topology DSL.
http://streamparse.readthedocs.io/
Apache License 2.0
1.5k stars 218 forks source link

InvalidTopologyException #467

Open dpelkmann opened 5 years ago

dpelkmann commented 5 years ago

Hello streamparse,

I have the following error message, which I cannot interpret:

wordcount]$ ~/anaconda3/bin/sparse submit --environment prod --name wordcount -dv
[...]
Cleaning from prior builds...
Creating topology JAR...
JAR created: /home/pelk_da/Desktop/wordcount/_build/wordcount-0.0.1-SNAPSHOT.jar
Removing _resources temporary directory...done
Deploying "wordcount" topology...
ssh tunnel to Nimbus dtn01:6627 established.
Uploading topology jar /home/pelk_da/Desktop/wordcount/_build/wordcount-0.0.1-SNAPSHOT.jar to assigned location: /hadoop/storm/nimbus/inbox/stormjar-c60860bd-ffee-4cf8-a217-412885d3080d.jar
Uploaded 7668/7668 bytes
Submitting wordcount topology to nimbus...Traceback (most recent call last):
  File "/home/pelk_da/anaconda3/bin/sparse", line 11, in <module>
    sys.exit(main())
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/streamparse/cli/sparse.py", line 87, in main
    args.func(args)
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/streamparse/cli/submit.py", line 395, in main
    active=args.active,
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/streamparse/cli/submit.py", line 309, in submit_topology
    active=active,
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/streamparse/cli/submit.py", line 133, in _submit_topology
    options=submit_options,
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/thriftpy/thrift.py", line 198, in _req
    return self._recv(_api)
  File "/home/pelk_da/anaconda3/lib/python3.7/site-packages/thriftpy/thrift.py", line 230, in _recv
    raise v
storm_thrift.InvalidTopologyException: InvalidTopologyException(msg='Field TOPOLOGY_DEBUG must be of type class java.lang.Boolean. Object: v actual type: class java.lang.String')

I am working on HDP Cluster (3.0.0.0-1634). Do you have any ideas how to solve it or what I could try?

Best regards David