我正在尝试将hdfs导出到crater.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没有插入到cratedb中。我试着在ip中提到“doc”,但仍然没有成功。
--connect
jdbc:crate://<SERVER-IP>:4200/doc
或者使用
--table
doc.test
我已经能够通过python库将内容插入到crater中,但不能通过sqoop。你知道我做错什么了吗?
1条答案
按热度按时间rmbxnbpk1#
您使用的是作为http端口公开的端口4200。由于板条箱0.57,您可以通过postges协议(5432)访问。在0.57之前,您需要为jdbc使用tcp 4300