Github user zzcclp commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1959#discussion_r167423204 --- Diff: integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala --- @@ -775,6 +776,8 @@ class TestStreamingTableOperation extends QueryTest with BeforeAndAfterAll { .option("bad_records_action", badRecordAction) .option("dbName", tableIdentifier.database.get) .option("tableName", tableIdentifier.table) + .option(CarbonStreamParser.CARBON_STREAM_PARSER, + "org.apache.carbondata.streaming.parser.CSVStreamParserImp") --- End diff -- After PR#1962 is merged, I will modify it , otherwise there is error when write complex type data.
---