0

我正在尝试将我的 hdfs 导出到 Crate.io DB,并且我正在使用 Sqoop 来执行此操作。我已经导入了所需的 .jar 文件,我的 sqoop 文件如下所示:

export
--connect
jdbc:crate://<SERVER-IP>:4200/

--driver
io.crate.client.jdbc.CrateDriver

--table
test

--export-dir
/to/file/in/hdfs

--input-fields-terminated-by
','

--columns
name, age

我的 sqoop 操作运行没有任何错误,但是我的 hdfs 没有任何内容插入到 crate db 中。我试过在 IP 中提到“doc”,但仍然没有成功。

--connect
jdbc:crate://<SERVER-IP>:4200/doc

并交替使用

--table
doc.test

我已经能够通过 Python 库将内容插入到 crate 中,但不能通过 Sqoop。有什么想法我可能在这里做错了吗?

4

1 回答 1

1

您正在使用作为 HTTP 端口公开的端口 4200。从 Crate 0.57 开始,您可以通过 postges 协议 (5432) 访问。在 0.57 之前,您需要为 jdbc 使用 tcp 4300

于 2016-12-31T16:27:36.443 回答