Hi,
My test case is as follows:
import cc.implicits._
var kk:Seq[(String,String,String,Int)] = Nil
for(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("""
UPDATE testtable SET (testtable.name) = ('india') WHERE
testtable.id = '10'
""").show()
cc.sql("SELECT count(distinct id) FROM testtable").show()
|-------|
|---c0-|
|80000|
cc.sql("""
UPDATE testtable SET (testtable.name) = ('india') WHERE testtable.id
= '10'
""").show()
cc.sql("SELECT count(distinct id) FROM testtable").show()
|-------|
|---c0-|
|79998|
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-tp15578.html
Sent from the Apache CarbonData Dev Mailing List archive mailing list archive
at Nabble.com.
