Uploaded image for project: 'Zeppelin'
  1. Zeppelin
  2. ZEPPELIN-381

sqlContext doesn't work with tables created by external jars (e.g. com.databricks.spark.csv); spark <1.5.1

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.6.0
    • 0.6.0
    • Core
    • None
    • this bug is true for Spark 1.4; I tried it with newest 1.5.1 and it worked fine

    Description

      this works fine:

      %dep
      z.load("com.databricks:spark-csv_2.10:1.2.0")
      
      val df = sqlContext.load("com.databricks.spark.csv", Map("path" -> "bank-full.csv","header"->"true","delimiter"->";"))
      df.registerTempTable("bank")
      

      however, when I try to do select in SQL interpreter I got error:

      %sql
      select age, count(1) from hmm where age < 30 group by age order by age
      
      java.lang.ClassNotFoundException: com.databricks.spark.csv.CsvRelation$$anonfun$tokenRdd$1$$anonfun$1 at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
      

      Question: if temp table is registered why Sql command still requires it?

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              xhudik Tomas Hudik
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: