Issues

Go to advanced search
Select view

Select search mode

Bug
Set ContextWaiter's var stopped to be true if wait() has been triggered
Unassigned
Qiuzhuang Lian
Minor
Unresolved
Feb 13, 2014
Feb 13, 2014
Bug
programming guide spell mistake?
Unassigned
Chen Chao
Minor
Unresolved
Feb 10, 2014
Feb 10, 2014
Bug
runJob() fails to deserialize tasks closing over ActorRefs
Unassigned
Paul Snively
Major
Unresolved
Oct 3, 2013
Oct 3, 2013
New Feature
Make DStream Iterable
Unassigned
Paul Snively
Minor
Unresolved
Sep 21, 2013
Sep 21, 2013
Bug
Update Twitter examples due to Twitter API retirement
Unassigned
Josh Rosen
Major
Fixed
Jun 14, 2013
Sep 1, 2013
Bug
Support recovery of a crashed receiver.
Unassigned
Prashant Sharma
Blocker
Unresolved
Feb 22, 2013
Feb 23, 2013
Bug
Add Twitter Stream to Java Streaming API
Unassigned
Patrick Wendell
Major
Fixed
Feb 20, 2013
Feb 23, 2013
Improvement
Add RDD type as a type parameter in JavaDStreamLike
Unassigned
Patrick Wendell
Major
Fixed
Feb 16, 2013
Feb 19, 2013
Bug
Add `transform` function to JavaPairDStream
Unassigned
Patrick Wendell
Major
Fixed
Feb 12, 2013
Feb 14, 2013
New Feature
Add a Python API for Spark Streaming
Unassigned
Matei Zaharia
Major
Unresolved
Feb 8, 2013
Feb 12, 2014
Task
CountByKeyAndWindow vs CountValuesByWindow
Unassigned
Tathagata Das
Major
Fixed
Feb 7, 2013
Feb 14, 2013
Task
Add a filter function to remove old keys with no values from reduceByKeyAndWindow operation
Unassigned
Tathagata Das
Major
Fixed
Feb 7, 2013
Feb 14, 2013
Task
Fix and test master fault tolerance with filestream
Unassigned
Tathagata Das
Major
Fixed
Feb 7, 2013
Feb 23, 2013
Task
Run a spark job before starting spark streaming
Unassigned
Tathagata Das
Major
Fixed
Feb 7, 2013
Feb 13, 2013
Task
Add Twitter stream to Streaming Context
Unassigned
Tathagata Das
Major
Fixed
Feb 7, 2013
Feb 14, 2013
Improvement
Cleaning ttl should be specified in seconds rather than minutes
Unassigned
Patrick Wendell
Major
Fixed
Feb 4, 2013
Feb 13, 2013
Bug
change spark.cleaner.delay --> spark.cleaner.ttl
Unassigned
Patrick Wendell
Major
Incomplete
Feb 4, 2013
Aug 10, 2013
Sub-task
Clearly state master/worker failure semantics in docs
Unassigned
Patrick Wendell
Major
Unresolved
Jan 28, 2013
Jan 28, 2013
Bug
Test failure scenarios
Unassigned
Patrick Wendell
Major
Fixed
Jan 28, 2013
Mar 5, 2013
Bug
BroadcastCleaner will delete still-active broadcast files
Unassigned
Patrick Wendell
Major
Unresolved
Jan 23, 2013
Oct 29, 2013
Bug
Slave has too many BlockInfo objects
Unassigned
Patrick Wendell
Major
Cannot Reproduce
Jan 22, 2013
Feb 13, 2013
Bug
Master has too many BlockManagerID instances
Unassigned
Patrick Wendell
Major
Fixed
Jan 21, 2013
Jan 23, 2013
Bug
Default behavior should be to checkpoint DStreams
Unassigned
Patrick Wendell
Major
Won't Fix
Jan 20, 2013
Jan 20, 2013
Bug
Review or finish all documentation (user guide, etc)
Unassigned
Patrick Wendell
Major
Fixed
Jan 18, 2013
Mar 5, 2013
New Feature
Allow custom DStream's in Java API
Unassigned
Patrick Wendell
Major
Unresolved
Jan 17, 2013
Aug 10, 2013
Task
Add checkpointing support to Python and Java API
Unassigned
Tathagata Das
Major
Fixed
Jan 17, 2013
Jan 20, 2013
Bug
All receivers get scheduled on the same machine
Unassigned
Tathagata Das
Major
Fixed
Jan 15, 2013
Feb 13, 2013
Improvement
Add a filter function to remove keys from state stream
Unassigned
Tathagata Das
Major
Unresolved
Jan 14, 2013
Jan 14, 2013
Bug
Check whether checkpoint directory has been set invertible reduce and updateState is being used
Unassigned
Tathagata Das
Major
Fixed
Jan 14, 2013
Jan 20, 2013
New Feature
Add a web-based output stream for Spark Streaming
Unassigned
Patrick Wendell
Major
Unresolved
Jan 8, 2013
Aug 2, 2013
Task
Create a more interesting Twitter demo for Strata
Unassigned
Patrick Wendell
Major
Fixed
Jan 2, 2013
Jan 17, 2013
Sub-task
Add Twitter API that uses NetworkInputReceiver
Unassigned
Patrick Wendell
Major
Fixed
Jan 2, 2013
Jan 14, 2013
Bug
Improve code quality of DataHandler
Unassigned
Patrick Wendell
Major
Fixed
Jan 2, 2013
Jan 2, 2013
Bug
Rare bug related to invertible reduceByKeyAndWindow
Unassigned
Tathagata Das
Major
Fixed
Dec 29, 2012
Jan 14, 2013
New Feature
Add Java API to streaming
Unassigned
Patrick Wendell
Minor
Fixed
Dec 21, 2012
Jan 17, 2013
Task
Stability testing with complex example
Unassigned
Tathagata Das
Major
Fixed
Dec 20, 2012
Jan 28, 2013
Task
Refactoring
Unassigned
Tathagata Das
Major
Fixed
Dec 20, 2012
Jan 14, 2013
Task
Additional documentation
Unassigned
Tathagata Das
Major
Fixed
Dec 20, 2012
Jan 14, 2013
Bug
Lineage truncation by checkpointing fails for CartesianRDD, CoalescedRDD, etc
Unassigned
Tathagata Das
Major
Fixed
Nov 19, 2012
Dec 20, 2012
Bug
Synchronization bug when DAGScheduler access RDD splits while splits are being changed
Unassigned
Tathagata Das
Major
Fixed
Nov 14, 2012
Dec 4, 2012
Improvement
Add code documentation to major streaming classes
Unassigned
Patrick Wendell
Major
Fixed
Nov 14, 2012
Aug 10, 2013
Improvement
Take batch interval in streaming constructor
Unassigned
Patrick Wendell
Major
Fixed
Nov 13, 2012
Dec 4, 2012
Improvement
Master fault tolerance with Kafka input stream + stateless operations
Unassigned
Tathagata Das
Blocker
Unresolved
Nov 13, 2012
Nov 19, 2012
Improvement
Saving of input stream data
Unassigned
Tathagata Das
Critical
Unresolved
Nov 13, 2012
Nov 13, 2012
Improvement
More optimized shuffle+window and state operation
Unassigned
Tathagata Das
Major
Unresolved
Nov 13, 2012
Nov 13, 2012
Task
Truncation of lineage in stateful operations like updateStateByKey and invertible reduceByKeyAndWindow
Unassigned
Tathagata Das
Blocker
Fixed
Nov 13, 2012
Dec 20, 2012
Task
Advanced example - Click counts using network stream and fake click count server
Unassigned
Tathagata Das
Major
Fixed
Nov 13, 2012
Nov 16, 2012
Task
Advanced example - Twitter trending topics with HTTP input stream
Unassigned
Tathagata Das
Major
Fixed
Nov 13, 2012
Jan 14, 2013
Bug
Local files cleanup
Unassigned
Tathagata Das
Blocker
Fixed
Nov 13, 2012
Dec 4, 2012
Improvement
Better checkpointing of DStreams
Unassigned
Tathagata Das
Minor
Unresolved
Oct 30, 2012
Nov 13, 2012
1-50 of 56