issues
search
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
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Relative path reference in a spout or bolt
#410
steveyang90
opened
6 years ago
0
Add CLI options
#409
codywilbourn
closed
6 years ago
2
How can we insert tuples into a relational database?
#408
wildboarking
opened
6 years ago
1
Add CONTRIBUTING
#407
codywilbourn
closed
6 years ago
2
Suggestion: Ability to pass the cli run command a pre-built jar
#406
jcallin
opened
6 years ago
0
Small fix args !- arg for custom class builder
#405
aldraco
closed
6 years ago
2
pystorm.serializers.serializer - ERROR without fail
#404
fedelemantuano
closed
6 years ago
1
Serializer Exception with msgpack Serializer
#403
LImoritakeU
opened
6 years ago
0
Support multiple versions of python in same project
#402
codywilbourn
closed
7 years ago
2
sparse submit error: TypeError: pre_submit() takes 3 positional arguments but 4 were given
#401
ltang78
closed
6 years ago
3
[WIP] switch to parallel-ssh from fabric
#400
tanaysoni
closed
6 years ago
11
Support multiple versions of python
#399
anuraguniyal
closed
7 years ago
5
Add ability to pass resource/config files
#398
anuraguniyal
opened
7 years ago
5
Suggestion: support for Pyleus yml topologies
#397
westover
opened
7 years ago
1
make cli options available to pre_submit_hooks
#396
emmettbutler
closed
7 years ago
3
Pass storm workers to topology on deploy as storm.workers.list
#395
dan-blanchard
closed
7 years ago
1
Switching to parallel-ssh instead of fabric for SSH bits
#394
dan-blanchard
opened
7 years ago
4
Make sparse tail and sparse remove_logs work better with Storm 1.x
#393
dan-blanchard
closed
7 years ago
5
Fix #391 where sparse run needed nimbus configured in config.json
#392
dan-blanchard
closed
7 years ago
1
Broken `sparse run` functionality after the 3.7.0 upgrade!
#391
malaref
closed
7 years ago
2
Allow passing config_file objects instead of always assuming we have a config.json file
#390
dan-blanchard
closed
7 years ago
2
Add dynamic lookup of storm supervisors
#389
codywilbourn
closed
7 years ago
4
Fix document's FAQ (?
#388
LImoritakeU
closed
7 years ago
0
How to define and use storm metrics ?
#387
tinduong94
closed
7 years ago
5
Topology inheritance
#386
fedelemantuano
closed
5 years ago
6
how to send optional parameters to bolts or spouts?
#385
aminalaee
closed
7 years ago
3
channel 2: open failed: administratively prohibited: open failed
#384
ProgSys
opened
7 years ago
3
ClassNotFoundException when using KafkaSpout
#383
VivaLaVile
opened
7 years ago
0
Set serializer for sparse run
#382
dan-blanchard
closed
7 years ago
1
Add --timeout option to commands that talk to Nimbus via Thrift
#381
dan-blanchard
closed
7 years ago
1
Make it so we no longer need to do extra storm_thrift import stuff
#380
dan-blanchard
closed
7 years ago
1
Support ruamel.yaml 0.15+ API
#379
dan-blanchard
closed
7 years ago
1
Fix issue where we couldn't get_user_tasks on Python 3
#378
dan-blanchard
closed
7 years ago
1
No module named streamparse.run ?
#377
BreakTom
closed
7 years ago
3
[Question]fabfile.py not working?
#376
LImoritakeU
closed
7 years ago
0
[Question] Worker crashed with 'Cannot run program "streamparse_run" '
#375
caden714
closed
7 years ago
1
fix ruamel.yaml on 0.14.X for now
#374
AvdN
closed
7 years ago
2
added virtualenv_name config
#373
tanaysoni
closed
7 years ago
3
No such file: quickstart
#372
shubhamagarwal003
closed
7 years ago
2
Virtualenv name in config.json when `install_virtualenv` is set to false
#371
tanaysoni
closed
7 years ago
1
setNumTasks() function in streamparse?
#370
LImoritakeU
closed
7 years ago
3
how to specify parameter for spout
#369
chestarss
closed
7 years ago
2
Serialize error java.lang.NumberFormatException with long type
#368
fedelemantuano
closed
7 years ago
2
how can i use ioloop in next_tunple
#367
chestarss
closed
7 years ago
1
Storm 1.0.3+ Mulitlang resource path support, (#362)
#366
rwatler
closed
7 years ago
3
Propagate parallelism to Flux YAML DSL from Python Topology DSL, (#364)
#365
rwatler
closed
7 years ago
2
Parallelism hint not propagated to Flux YAML Topology
#364
rwatler
closed
7 years ago
1
Show output from sparse run.
#363
j-bennet
closed
7 years ago
1
streamparse wordcount demo not working with storm 1.0.3
#362
chenjingping
closed
7 years ago
9
flux YAML constructorArgs incorrect formatting for string:number
#361
Richard-Mathie
closed
7 years ago
12
Previous
Next