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

Posted to dev@carbondata.apache.org by yangwei <ya...@163.com> on 2017/06/20 01:33:22 UTC

update bug with carbondata1.1.0 and spark1.6.0

Hi,  My test case is as follows:  import  cc.implicits._var
kk:Seq[(String,String,String,Int)] = Nilfor(i<-1 to 80000){   kk = kk
++Seq((i+"", "name","city",
i))}cc.sc.makeRDD(kk).toDF("id","name","city","age").registerTempTable("t1")cc.sql("DROP
TABLE IF EXISTS testtable")cc.sql("CREATE TABLE IF NOT EXISTS testtable(id
string, name string, city string, age Int) STORED BY
'carbondata'")cc.sql("insert INTO TABLE testtable select * from
t1")cc.sql("SELECT count(distinct id) FROM testtable").show()
<http://apache-carbondata-dev-mailing-list-archive.1130556.n5.nabble.com/file/n15577/QQ%E5%9B%BE%E7%89%8720170620092732.png>
Only one record is updated, but the total number of records is missing by
two



--
View this message in context: http://apache-carbondata-dev-mailing-list-archive.1130556.n5.nabble.com/update-bug-with-carbondata1-1-0-and-spark1-6-0-tp15577.html
Sent from the Apache CarbonData Dev Mailing List archive mailing list archive at Nabble.com.