Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-13175 Cleanup deprecation warnings from Scala 2.11 upgrade
  3. SPARK-13170

Investigate replacing SynchronizedQueue as it is deprecated

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Trivial
    • Resolution: Fixed
    • None
    • 2.0.0
    • DStreams, Tests
    • None

    Description

      In some of our tests we use SynchronizedQueue to append to the queue after creating a queue stream. SynchronizedQueue is deprecated and we should see if we can replace it. This is a bit tricky since the queue stream API is public, and while it doesn't depend on having a SynchronizedQueue as input (thankfully) it does require a Queue. We could possibly change the tests to not depend on the SynchronizedQueue or change the QueueStream to also work with Iterables.

      Attachments

        Activity

          People

            srowen Sean R. Owen
            holden Holden Karau
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: