Details
Description
Currently the no. of cores is (N + 1), where N is no. of shards in a Kinesis Stream.
My Requirement is that if I use this Resharding util for Amazon Kinesis :
Amazon Kinesis Resharding : https://github.com/awslabs/amazon-kinesis-scaling-utils
Then there should be some way to allocate executors on the basis of no. of shards directly (for Spark Streaming only).
Attachments
Issue Links
- is related to
-
SPARK-12133 Support dynamic allocation in Spark Streaming
- Resolved