carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipesala <...@git.apache.org>
Subject [GitHub] carbondata pull request #1677: [CARBONDATA-1860][PARTITION] Support insertov...
Date Wed, 20 Dec 2017 18:25:53 GMT
Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1677#discussion_r158099643
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonLoadDataCommand.scala
---
    @@ -567,14 +568,18 @@ case class CarbonLoadDataCommand(
               carbonLoadModel,
               sparkSession)
         }
    -    Dataset.ofRows(
    -      sparkSession,
    +    val convertedPlan =
           CarbonReflectionUtils.getInsertIntoCommand(
             convertRelation,
             partition,
             query,
    -        isOverwriteTable,
    -        false))
    +        false,
    +        false)
    +    if (isOverwriteTable && partition.nonEmpty && table.isHivePartitionTable)
{
    --- End diff --
    
    ok


---

Mime
View raw message