Exchange 导入 PGSQL 失败 Table or view not found

[Rhett]

你好。我使用nebula-up在本地构建了 spark v3 的环境。导入pg时部分 edge 的导入报错：

这是我这部分的配置文件：

{
      name: contract

      type: {
        source: postgresql

        sink: client
      }

      host:192.168.0.54
      port:5432
      database:"njq-spark-test"
      table:"cbf"
      user:"postgres"
      password:"123456"
      sentence:"select c.objectid as src_id,d.id as dst_id,h.cbhtbm ,h.htzmjm ,h.cbqxq ,h.cbqxz from cbf c,dk d,cbht h where c.cbfbm = d.cbfbm and c.cbfbm = h.cbfbm order by cbhtbm"

      fields: [cbhtbm,htzmjm,cbqxq,cbqxz]
      nebula.fields: [contract_code,area_mu_sum,start_date,end_date]

      source: {
        field: src_id
      }

      target: {
        field: dst_id
      }

      batch: 256

      partition: 32
    }

这个sql语句在库中是可以正常执行的，这个cbht表也是存在的。

其他的 tag 和 edge 部分都可以正常导入。能否指教下是什么问题？谢谢。

[nicole]

@Rhett

sentence:"select c.objectid as src_id,d.id as dst_id,h.cbhtbm ,h.htzmjm ,h.cbqxq ,h.cbqxz from cbf c,dk d,cbht h where c.cbfbm = d.cbfbm and c.cbfbm = h.cbfbm order by cbhtbm"

因为这个语句是在spark sql中去执行的，在spark sql 的table view 中是不存在 cbf、c、dk、d、cbht这么多表的。

[Rhett]

感谢回复。
那可有其他方式能实现这种需求呢？

[nicole]

我正在给jdbc方式的导入支持这种多表查询的能力，可以稍等我的pr， ok后你可以使用最新的SNAPSHOT版本的exchange

[Rhett]

好的。顺便问一下，这个多表查询是不支持3张表或以上吗，我这里运行两张表关联查询倒是可以正常导入。

[nicole]

是的