Description
1. Build a test bench for generating different workloads and data with varying rates - DONE
2. Enable backpressure and test whether things it works with different workloads - DONE
3. Test whether it works with multiple receivers - BUMPED TO FUTURE TESTING
4. Test whether it works with Kinesis - BUMPED TO FUTURE TESTING
5. Test whether it works with Direct Kafka - DONE by cody@koeninger.org
Attachments
Issue Links
- relates to
-
SPARK-9966 Handle a couple of corner cases in the PID rate estimator
- Resolved
-
SPARK-9968 BlockGenerator lock structure can cause lock starvation of the block updating thread
- Resolved
-
SPARK-10072 BlockGenerator can deadlock when the queue block queue of generate blocks fills up to capacity
- Resolved
- links to