Re: Spark SQL 1.6.1 issue

2016-08-18 Thread Teik Hooi Beh
Hi, does the version have to be the same down to the minor version, e.g. 1.6.1 and 1.6.2 will give this issue On Thu, Aug 18, 2016 at 6:27 PM, Olivier Girardot < o.girar...@lateral-thoughts.com> wrote: > your executors/driver must not have the multiple versions of spark in > classpath, it may

Re: Spark SQL 1.6.1 issue

2016-08-18 Thread Olivier Girardot
your executors/driver must not have the multiple versions of spark in classpath, it may come from the cassandra connector check the pom dependencies of the version you fetched and if it's compatible with your spark version. On Thu, Aug 18, 2016 6:05 AM, thbeh th...@thbeh.com wrote: Running

Spark SQL 1.6.1 issue

2016-08-17 Thread thbeh
Running the query below I have been hitting - local class incompatible exception, anyone know the cause? val rdd = csc.cassandraSql("""select *, concat('Q', d_qoy) as qoy from store_sales join date_dim on ss_sold_date_sk = d_date_sk join item on ss_item_sk =