Vertica Spark Connector 0.2.0- Invalid Projection issue

I'm testing the Vertica Spark Connector 0.2.0 with Vertica 7.2.1 and HDP 2.4.0 (Spark 1.6).

I'm going through the examples from the user guide and they seem to work fine only when the tables from which I'm extracting the data are in the default schema.

However, if the table is not in the default schema and I add the parameter "dbschema"  to the options, I get the following exception:

 

java.sql.SQLSyntaxErrorException: [Vertica][VJDBC](3737) ERROR: Invalid projection name category_b0

 

The examples in the User guide somehow never provide the dbschema parameter, so I'm wondering if this behavior is intentional.

 

Here's the code I'm using:

 

val hostName = "..."
val db = "dsa"
val tableName1 = "category"
val part = "12";
val dbschema = "ga_master"
val opt = Map("host" -> hostName, "table" -> tableName1, "db" -> db, "numPartitions" -> part, "user" -> "...", "password" -> "...", "dbschema" -> dbschema)
val df = sqlContext.read.format("com.vertica.spark.datasource.DefaultSource").options(opt).load()

 

Comments

  • Hi lciszak,

     

    I tested this in my lab, and was able to reproduce the issue. It only worked with a default schema.

    I checked this internally with the relevant folks; the fix for this issue is currently in the works.

     

    Thanks,

    Harshad

  • Hey guys,

     

    Please try v0.2.1, which is now available. This release should fix this issue.

     

    Thanks,

    Edward

  • Good stuff! Thanks guys.

Leave a Comment

BoldItalicStrikethroughOrdered listUnordered list
Emoji
Image
Align leftAlign centerAlign rightToggle HTML viewToggle full pageToggle lights
Drop image/file

Can't find what you're looking for? Search the Vertica Documentation, Knowledge Base, or Blog for more information.