Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2084#discussion_r176077283
--- Diff:
streaming/src/main/scala/org/apache/carbondata/streaming/StreamHandoffRDD.scala
---
@@ -299,8 +302,8 @@ object StreamHandoffRDD {
def executeStreamingHandoff(
carbonLoadModel: CarbonLoadModel,
sparkSession: SparkSession,
- handoffSegmenId: String
- ): Unit = {
+ operationContext: OperationContext,
--- End diff --
why operationContext is needed---
