Github user manishgupta88 commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2644#discussion_r214313170
  
    --- Diff: 
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/StreamHandoffRDD.scala
 ---
    @@ -205,8 +205,9 @@ class StreamHandoffRDD[K, V](
         segmentList.add(Segment.toSegment(handOffSegmentId, null))
         val splits = inputFormat.getSplitsOfStreaming(
           job,
    -      
carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable.getAbsoluteTableIdentifier,
    -      segmentList
    +      segmentList,
    +      carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable,
    +      null
    --- End diff --
    
    Once you add the overloaded method as explained in above comment you can 
call the method with 3 arguments from here


---

Reply via email to