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

Add more notes in the comments of Sink.addBatch()

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 2.0.0, 2.0.1, 2.0.2, 2.1.0
    • 2.1.1, 2.2.0
    • Structured Streaming
    • None

    Description

      addBatch method in Sink trait is supposed to be a synchronous method to coordinate with the fault-tolerance design in StreamingExecution (being different with the compute() method in DStream)

      We need to add more notes in the comments of this method to remind the developers

      Attachments

        Activity

          People

            codingcat Nan Zhu
            codingcat Nan Zhu
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: