Github user ManoharVanam commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1562#discussion_r153193864
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/LoadTableCommand.scala
---
@@ -139,6 +140,15 @@ case class LoadTableCommand(
carbonLoadModel,
hadoopConf
)
+ val operationContext = new OperationContext
+ val loadTablePreExecutionEvent: LoadTablePreExecutionEvent =
+ new LoadTablePreExecutionEvent(sparkSession,
+ null,
+ carbonLoadModel,
+ factPath,
+ dataFrame.isDefined,
+ optionsFinal)
--- End diff --
yeah , Iam getting bad records info from optionsFinal for validation
purpose in pre event listener.
after validating we are setting to carbonLoadModel, so this is required
---
