Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1837#discussion_r162627861
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonInsertIntoCommand.scala
---
@@ -45,10 +47,10 @@ case class CarbonInsertIntoCommand(
updateModel = None,
tableInfoOp = None,
internalOptions = Map.empty,
- partition = partition).run(sparkSession)
- // updating relation metadata. This is in case of auto detect high
cardinality
- relation.carbonRelation.metaData =
- CarbonSparkUtil.createSparkMeta(relation.carbonRelation.carbonTable)
- load
+ partition = partition)
+ loadCommand.processMetadata(sparkSession)
+ }
+ override def processData(sparkSession: SparkSession): Seq[Row] = {
+ loadCommand.processData(sparkSession)
--- End diff --
add `if (loadCommand != null)` check
---
