pystorm/streamparse
Run Python in Apache Storm topologies. Pythonic API, CLI tooling, and a topology DSL.
PythonApache-2.0
Issues
- 0
`LegacySpecifier` and `LegacyVersion` have been dropped in `setuptools>=67`, causing `InvalidVersion`
#500 opened by maciej-lech - 0
Wordcount example use Anaconda environment
#485 opened by colonder - 0
- 1
Is it possible to define bolts with windowing?
#473 opened by ozturkberkay - 0
sparse submit error thriftpy2.thrift.TApplicationException: Internal error processing beginFileUpload
#488 opened by farons - 1
Can't run sparse run on wordcount example: RuntimeError: dictionary keys changed during iteration
#487 opened by frank-switchdin - 3
Unable to run 'lein deps :tree'!
#472 opened by tanjiarui - 1
- 0
- 1
- 6
Does it support Python3 ?
#457 opened by tab-1 - 0
- 0
issue with logging sometimes not writing to the file
#476 opened by z11373 - 1
using PYTHONPATH or alternative in streamparse
#474 opened by z11373 - 0
Adding new handler to the storm logger
#475 opened by yugansh20 - 6
- 0
Fix simple typo: occassions, -> occasions,
#470 opened by timgates42 - 0
- 2
sparse run taking 10 minutes to create topology Uber-JAR
#465 opened by hz97 - 1
- 0
InvalidTopologyException
#467 opened by dpelkmann - 1
how to troubleshoot storm worker crash
#466 opened by z11373 - 2
is Storm 2.0.0 supported with streamparse 4.0?
#464 opened by Bimal-Gangawal - 1
fail_tuple without any clue
#463 opened by mbande - 6
- 0
virtualenv_name optoin doesn't make effect
#458 opened - 0
Read the Docs webhook needs to be updated
#456 opened by jeffgodwyll - 1
Does streamparse provide windowing api?
#449 opened by jerry-pca - 2
- 0
- 0
no logging at all
#450 opened by RushPu - 1
Fatal error: local() encountered an error (return code 1) while executing 'storm jar /path_to_project/_build/try-0.0.1-kafka-standalone.jar org.apache.storm.flux.Flux --local --no-splash --sleep 9223372036854775807
#430 opened by shahidammer - 0
Allow deploying of deactivated topology
#422 opened by Darkless012 - 1
Pass system property to Storm
#433 opened by Darkless012 - 2
Updating to 3.14.0: submit throws errors
#446 opened by mbande - 0
Implementing a Spout from a Kafka Consumer
#443 opened by SioKCronin - 0
- 0
How to access multiple tuples in Bolt
#440 opened by Dcoder-D - 0
I found some bug when i use ‘sparse submit’
#439 opened by elfgzp - 0
- 0
- 0
Submitting my topology
#435 opened by binglin1 - 0
wordcount example fails with -t
#434 opened by coolsurf - 1
- 1
- 3
TypeError when changing the serializer
#428 opened by kbruegge - 3
[Question] Storm crashed with Error 'Cannot run program ... "streamparse_run" ... in directory ...error=2, No such file or directory ....'
#426 opened by liujiaqiid - 3
invalid topology name
#424 opened by NoahLiot - 0
- 1
Support/use venv module with Python 3.3+
#423 opened by dan-blanchard