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


---

Reply via email to