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

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

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 2.0.0, 2.0.1, 2.0.2, 2.1.0
    • Fix Version/s: 2.1.1, 2.2.0
    • Component/s: Structured Streaming
    • Labels:
      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

            • Assignee:
              CodingCat Nan Zhu
              Reporter:
              CodingCat Nan Zhu
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: