Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-7661

Support for dynamic allocation of resources in Kinesis Spark Streaming

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 1.3.1
    • 2.0.0
    • DStreams
    • None
    • AWS-EMR

    • Important

    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

          Activity

            People

              Unassigned Unassigned
              mkanchwala Murtaza Kanchwala
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: