spark部署在本地内部服务器。doris部署在云服务器。通过Spark Doris Connector 写入数据到doris报错
26/02/05 11:17:44 WARN TaskSetManager: Lost task 0.1 in stage 6.0 (TID 5) (bgworker03 executor 1): java.lang.Exception: org.apache.doris.shaded.org.apache.http.conn.ConnectTimeoutException: Connect to 192.168.40.119:8040 [/192.168.40.119] failed: Connection timed out
192.168.40.119这个是云服务器内网地址,本地内部服务器根本就无法识别云服务器的内网地址,这个怎么解决?
以下为代码
(df.write.format("doris")
.option("doris.fenodes", "公网ip:8030,公网ip:8030,公网ip:8030")
.option("doris.benodes", "公网ip:8040,公网ip:8040,公网ip:8040")
.option("doris.sink.auto-redirect", True)
.option("doris.table.identifier", f"{database_name}.{table_name}")
.option("doris.user","root")
.option("doris.password", "xxxxxx")
.mode("append").save())