I am trying to connect Phoenix through pyspark. Everything fine, but the below error occures.
My Phoenix table "namespace:test" is available and access also good.
py4j.protocol.Py4JJavaError: An error occurred while calling o81.load.
: org.apache.phoenix.schema.TableNotFoundException: ERROR 1012 (42M03): Table undefined. tableName=namespace:test
I am using below code
result.write.format("org.apache.phoenix.spark").mode("overwrite").option("table", "\"namespace:test\"").option("zkUrl", "jdbc:phoenix:ip-172-31-45-15.us-west-2.compute.internal:2181:/hbase-secure:hbaseuser@ex.COM:/home/hbaseuser/hbaseuser.keytab").save()
I gave like this also. But it takes as Upper case table name as "Table undefined. tableName=NAMESPACE:TEST"
result.write.format("org.apache.phoenix.spark").mode("overwrite").option("table", "namespace:test").option("zkUrl", "jdbc:phoenix:ip-172-31-45-15.us-west-2.compute.internal:2181:/hbase-secure:hbaseuser@ex.COM:/home/hbaseuser/hbaseuser.keytab").save()
I used same jdbc url using Java. It works fine
