Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2832#discussion_r226211539
--- Diff:
integration/spark-common/src/main/scala/org/apache/spark/sql/execution/streaming/CarbonAppendableStreamSink.scala
---
@@ -102,6 +102,16 @@ class CarbonAppendableStreamSink(
CarbonProperties.getInstance().isEnableAutoHandoff
)
+ // measure data type array
+ private lazy val msrDataTypes = {
+ val msrList =
carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable.getMeasures
--- End diff --
```suggestion
val msrList =
carbonLoadModel.getCarbonDataLoadSchema.getCarbonTable.getMeasures.asScala.map
```
---
