Github user qiuchenjian commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2988#discussion_r241934868 --- Diff: integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/createTable/TestNonTransactionalCarbonTable.scala --- @@ -2490,6 +2490,47 @@ class TestNonTransactionalCarbonTable extends QueryTest with BeforeAndAfterAll { FileUtils.deleteDirectory(new File(writerPath)) } + test("check varchar with trailing space") { + FileUtils.deleteDirectory(new File(writerPath)) + val fields: Array[Field] = new Array[Field](8) + + fields(0) = new Field("Event_ID", DataTypes.STRING) + fields(1) = new Field("Event_Time", DataTypes.TIMESTAMP) + fields(2) = new Field("subject", DataTypes.VARCHAR) + fields(3) = new Field("From_Email", DataTypes.STRING) + fields(4) = new Field("To_Email", DataTypes.createArrayType(DataTypes.STRING)) + fields(5) = new Field("CC_Email", DataTypes.createArrayType(DataTypes.STRING)) + fields(6) = new Field("BCC_Email", DataTypes.createArrayType(DataTypes.STRING)) + fields(7) = new Field("messagebody ", DataTypes.VARCHAR) + + var options = Map("bAd_RECords_action" -> "FORCE").asJava + CarbonProperties.getInstance() + .addProperty(CarbonCommonConstants.CARBON_TIMESTAMP_FORMAT, "EEE, d MMM yyyy HH:mm:ss Z") + + val writer: CarbonWriter = CarbonWriter.builder + .outputPath(writerPath) + .withCsvInput(new Schema(fields)).writtenBy("TestNonTransactionalCarbonTable").build() + + writer + .write(Array("aaa", + "Fri, 4 May 2001 13:51:00 -0700 (PDT)", + "Re", + "c...@ws.com", + "sd#er", + "sd", + "sds", + "ew")) + writer.close() + + sql("drop table if exists test") + sql( + s"""CREATE TABLE test using carbon options('long_string_columns'='subject,messagebody') + |LOCATION '$writerPath'""" + .stripMargin) + sql("select * from test").show() --- End diff -- Why is this test case not checking the correctness of the results? Such as checkAnswer ï¼ assert and so on
---