Re: update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread Liang Chen
Hi Correct my info, can do update as below , it is successful. +---+-++---+ | id| name|city|age| +---+-++---+ | 10|india|city| 10| +---+-++---+ Regards Liang -- View this message in context: http://apache-carbondata-dev-mailing-list-archive.1130556.n5.nabble.com/updat

Re: update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread yangwei
Thank you for your valuable advice, and I will download and test branch-1.1 -- 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-tp15578p15589.html Sent from the Apache CarbonData Dev Mailing List

Re: update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread Erlu Chen
Hi I Just test in my idea in local mode, I am not sure which mode and which branch you test. I have tested and the result seems ok. My test steps as follows: 1. just copy your code into CarbonExample class. 2. Run CarbonExample. Test result as follows: 17/06/20 10:34:12 AUDIT CarbonDataRDDFa

Re: update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread Liang Chen
Hi Just i copied your code and tested it at my local machine , the result as below. Because there are no any "india" value in name column, so don't do any update. Please check it again. BTW, suggest you do test at branch-1.1, because the community is testing branch-1.1 for preparing 1.1.1 patch

update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread yangwei
Hi, My test case is as follows: import cc.implicits._ var kk:Seq[(String,String,String,Int)] = Nil for(i<-1 to 8){ 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

update bug with carbondata1.1.0 and spark1.6.0

2017-06-19 Thread yangwei
Hi, My test case is as follows: import cc.implicits._var kk:Seq[(String,String,String,Int)] = Nilfor(i<-1 to 8){ 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 N