Details

    • Sub-task
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • 3.1.0
    • None
    • SQL
    • None

    Description

      sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/WriteToMicroBatchDataSource.scala

      Warning:Warning:line (36)class WriteToDataSourceV2 in package v2 is deprecated (since 2.4.0): Use specific logical plans like AppendData instead
        def createPlan(batchId: Long): WriteToDataSourceV2 = {
          Warning:Warning:line (37)class WriteToDataSourceV2 in package v2 is deprecated (since 2.4.0): Use specific logical plans like AppendData instead
          WriteToDataSourceV2(new MicroBatchWrite(batchId, write), query)
      

      sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQuerySuite.scala

       Warning:Warning:line (703)a pure expression does nothing in statement position; multiline expressions might require enclosing parentheses
            q1
      

      sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingAggregationSuite.scala

      Warning:Warning:line (285)object typed in package scalalang is deprecated (since 3.0.0): please use untyped builtin aggregate functions.
          val aggregated = inputData.toDS().groupByKey(_._1).agg(typed.sumLong(_._2))
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            jobitmathew jobit mathew
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: