I'm trying to insert data into Cassandra table with Spark SQL as follows: String query = "CREATE TEMPORARY TABLE my_table USING org.apache.spark.sql.cassandra OPTIONS (table \"my_table\",keyspace \"my_keyspace\", pushdown \"true\")"; spark.sparkSession.sql(query); spark.sparkSession.sql("INSERT INTO my_keyspace.my_table (column0, column1) VALUES ('value0', 'value1');
however, it fails with the following exception: Exception in thread "main" org.apache.spark.sql.catalyst.parser.ParseException: mismatched input 'column0' expecting {'(', 'SELECT', 'FROM', 'VALUES', 'TABLE', 'INSERT', 'MAP', 'REDUCE'}(line 1, pos 33) I tried it without the column names and it worked. My point here is to insert data for some columns, not all of them. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Cassandra-Simple-Insert-Statement-using-Spark-SQL-Fails-with-org-apache-spark-sql-catalyst-parser-Pan-tp28682.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org