Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1469#discussion_r152584958
  
    --- Diff: 
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala
 ---
    @@ -80,7 +80,13 @@ case class CarbonCreateTableCommand(
               val fields = new Array[Field](cm.dimCols.size + cm.msrCols.size)
               cm.dimCols.foreach(f => fields(f.schemaOrdinal) = f)
               cm.msrCols.foreach(f => fields(f.schemaOrdinal) = f)
    -
    +//
    +//          sparkSession.sql(
    +//            s"""CREATE TABLE $dbName.$tbName
    +//               |(${ fields.map(f => f.rawSchema.replace("`", 
"")).mkString(",") })
    +//               |USING org.apache.spark.sql.CarbonSource""".stripMargin +
    +//            s""" OPTIONS (tableName "$tbName", dbName "$dbName", 
tablePath """.stripMargin +
    +//            s""""$tablePath"$carbonSchemaString) """)
    --- End diff --
    
    remove commented code


---

Reply via email to