[
https://issues.apache.org/jira/browse/CARBONDATA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xubo245 closed CARBONDATA-1550.
-------------------------------
Resolution: Duplicate
> There is an error when table has Array<STRING> column and
> ENABLE_AUTO_LOAD_MERGE is true
> ----------------------------------------------------------------------------------------
>
> Key: CARBONDATA-1550
> URL: https://issues.apache.org/jira/browse/CARBONDATA-1550
> Project: CarbonData
> Issue Type: Bug
> Reporter: xubo245
>
> There is an error when table has Array<STRING> column and
> ENABLE_AUTO_LOAD_MERGE is true
> {code:java}
> //unfinish
> sql("drop table if exists array_table")
>
> CarbonProperties.getInstance().addProperty(CarbonCommonConstants.ENABLE_AUTO_LOAD_MERGE,
> "true")
> sql(
> s"""
> | CREATE TABLE array_table(
> | complexData ARRAY<STRING>
> | )
> | STORED BY 'carbondata'
> | TBLPROPERTIES('sort_columns'='')
> """.stripMargin)
> val storeLocation =
> s"$rootPath/integration/spark-common-test/src/test/resources/bool/ArrayString.csv"
> for (i <- 0 until 4) {
> sql(
> s"""
> | LOAD DATA LOCAL INPATH '${storeLocation}'
> | INTO TABLE array_table
> | options('FILEHEADER'='complexData')
> """.stripMargin)
> }
> checkAnswer(
> sql("select count(*) from array_table"),
> Seq(Row(40))
> )
> val segments = sql("SHOW SEGMENTS FOR TABLE array_table")
> val SegmentSequenceIds = segments.collect().map { each => (each.toSeq)
> (0) }
> assert(!SegmentSequenceIds.contains("0.1"))
> assert(SegmentSequenceIds.length == 4)
>
> CarbonProperties.getInstance().addProperty(CarbonCommonConstants.ENABLE_AUTO_LOAD_MERGE,
> CarbonCommonConstants.DEFAULT_ENABLE_AUTO_LOAD_MERGE)
> sql("drop table if exists array_table")
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
