You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@carbondata.apache.org by QiangCai <gi...@git.apache.org> on 2018/02/11 01:26:53 UTC

[GitHub] carbondata pull request #1959: [CARBONDATA-2148][CARBONDATA-2147] Add new Ro...

Github user QiangCai commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1959#discussion_r167416315
  
    --- 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 --
    
    Better to use default parser, 
    Can you modify it, like CarbonStructuredStreamingExample.scala


---