我正试图通过Spark将数据从HDFS复制到Teradata。我得到的UnknownHostException时,运行胸膛火花弹.我在通过submit运行相同的teradata.main时没有找到它(我也添加了teradata.main和submit)。相同的和凭据在Sqooping时运行良好。
我已经将teradata添加到执行器和驱动程序类路径中,也在sparkdefaults.conf中添加了teradata。请找出我的火花源连接代码如下,
val jdbcDF = sqlContext.load("jdbc", Map("url" -> "jdbc:teradata://teradataservername, user=***###, password=***###","dbtable" -> "query","driver" -> "com.teradata.jdbc.TeraDriver"))请找出我从火花壳跑出来时所得到的刺激如下,
(teradata )、TMODE=TERA、username=###、password=### Sun Aug 06 22:43:40 TERAJDBC4 socket orig=(teradata )、TMODE=TERA、username=### en19# (teradata )、、en22、java.net.Inet6AddressImpl.lookupAllHostAddr(Native方法的未知错误( java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928) at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323) at java.net.InetAddress.getAllByName0(InetAddress.java:1276) )
发布于 2017-08-08 14:12:25
尝试以下解决方案,看看它是否适合您:
sc.addJar("/jar/dir/yourDriver.jar")
val jdbcDF = sqlContext.load("jdbc", Map(
"url" -> "jdbc:teradata://<server_name>, TMODE=TERA, user=my_user, password=*****",
"dbtable" -> "your query",
"driver" -> "com.teradata.jdbc.TeraDriver"))https://stackoverflow.com/questions/45570262
复制相似问题