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
---