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.


---

Reply via email to