使用Exchange导入pg,不支持非public schema数据

PostgreSQL数据库默认是使用public的模式(schema),
如果想要访问其他模式的数据,需要使用schema_name.table_name的方式。但是配置table:“test.test_test”,会报错

java.lang.RuntimeException: Exception in thread “main” org.apache.spark.sql.AnalysisException: It is not allowed to add database prefix test for the TEMPORARY view name.;

Exchange在读取postgresql数据时,给定了数据一个tempView,采用的是table name作为view name,所以指定db.table的时候会提示不允许配置db。

你如果想配置db 可以用jdbc的方式 导入通用 JDBC 数据 - NebulaGraph Database 手册

1 个赞

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。