Merge b5573d0 into 7cd7623

apache · Dec 18, 2018 · 4244ebd · 4244ebd
2 parents 7cd7623 + b5573d0
commit 4244ebd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../src/main/scala/org/apache/spark/sql/execution/streaming/CarbonAppendableStreamSink.scala b/.../src/main/scala/org/apache/spark/sql/execution/streaming/CarbonAppendableStreamSink.scala
@@ -50,6 +50,7 @@ import org.apache.carbondata.processing.loading.constants.DataLoadProcessorConst
 import org.apache.carbondata.processing.loading.events.LoadEvents.{LoadTablePostExecutionEvent, LoadTablePreExecutionEvent}
 import org.apache.carbondata.processing.loading.model.CarbonLoadModel
 import org.apache.carbondata.spark.rdd.StreamHandoffRDD
+import org.apache.carbondata.spark.util.CommonUtil
 import org.apache.carbondata.streaming.{CarbonStreamException, CarbonStreamOutputFormat}
 import org.apache.carbondata.streaming.index.StreamFileIndex
 import org.apache.carbondata.streaming.parser.CarbonStreamParser
@@ -93,6 +94,7 @@ class CarbonAppendableStreamSink(
       carbonLoadModel.getDateFormat())
     conf
   }
+  CommonUtil.configureCSVInputFormat(hadoopConf, carbonLoadModel)
   // segment max size(byte)
   private val segmentMaxSize = hadoopConf.getLong(
     CarbonCommonConstants.HANDOFF_SIZE,