carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jackylk <...@git.apache.org>
Subject [GitHub] carbondata pull request #1697: [CARBONDATA-1719][Pre-Aggregate][Bug] Fixed b...
Date Sat, 23 Dec 2017 13:36:10 GMT
Github user jackylk commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1697#discussion_r158582511
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
    @@ -38,7 +40,9 @@ object LoadPostAggregateListener extends OperationEventListener {
         val loadEvent = event.asInstanceOf[LoadTablePreStatusUpdateEvent]
         val sparkSession = loadEvent.sparkSession
         val carbonLoadModel = loadEvent.carbonLoadModel
    -    val table = carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable
    +    val metastore = CarbonEnv.getInstance(sparkSession).carbonMetastore
    +    val table = metastore.lookupRelation(Some(carbonLoadModel.getDatabaseName),
    --- End diff --
    
    You can use CarbonEnv to get CarbonTable


---

Mime
View raw message