It seems that the second problem is dependency issue. and it works exactly like the first one.
*this is the complete code:* JavaSchemaRDD schemas=ctx.jsonRDD(arg0); schemas.insertInto("test", true); JavaSchemaRDD teeagers=ctx.hql("SELECT a,b FROM test"); List<String> teeagerNames1=teeagers.map(new Function<Row,String>() { /** * */ private static final long serialVersionUID = 1L; @Override public String call(Row arg1) throws Exception { // TODO Auto-generated method stub System.out.println(arg1.length()); System.out.println("Name:"+arg1.getString(0)); System.out.println("Name:"+arg1.getString(1)); return "Name:"+arg1.getString(0); } }).collect(); the input is : {"a":"111","b":"222"} {"a":"111","b":"222"} the output is: 2 Name:111 Name:222 while from hive: hive> select * from test; OK 111 NULL 111 NULL so,what's going wrong? thank you. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/a-hivectx-insertinto-issue-tp16365p16376.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org