Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2084#discussion_r176076016
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
@@ -199,9 +199,12 @@ object LoadPostAggregateListener extends
OperationEventListener {
* @param event
*/
override def onEvent(event: Event, operationContext: OperationContext):
Unit = {
- val loadEvent = event.asInstanceOf[LoadTablePreStatusUpdateEvent]
+ val carbonLoadModel =
+ event match {
+ case e: LoadTablePreStatusUpdateEvent => e.getCarbonLoadModel
+ case e: LoadTablePostExecutionEvent => e.getCarbonLoadModel
+ }
--- End diff --
add a case for others
---