Teradataへの書き出し

Question

私はHDFSからSparkを介してTeradataにデータをコピーしようとしています。 Spark-shellを実行しているときにUnknownHostExceptionが発生しています。私はteradata.mainを取得していませんが、spark submitによって同じものを実行しています（私はsparkとともにteradata jarsを追加しました）。 Squooping時には、同じTeradata接続URLと認証情報が有効です。

私は、executorとドライバのクラスパスとsparkdefaults.confにteradata jarsを追加しました。

TERAJDBC4のERROR [メイン] com.teradata、以下のように火花シェルから実行している間、私が得た私のexcetionを見つけてください、以下のように

val jdbcDF = sqlContext.load("jdbc", Map("url" -> "jdbc:teradata://teradataservername, user=***###, password=***###","dbtable" -> "query","driver" -> "com.teradata.jdbc.TeraDriver")) 

を私のスパークのTeradata接続コードを見つけてください。 jdbc.jdk6.JDK6_SQL_Connection@219f9031 TMODE = TERA、ユーザ名= ###、パスワード= ###日8月6日午後10時43分40秒EDT （Teradataサーバー）への接続、ソケットORIG =（テラサーバー）、TMODE = TERA、 ユーザ名= ###、パスワード= ### CID = 742ff968のSES = 0 にjava.net.UnknownHostException：（Teradataサーバー）、TMODE = TERA、 ユーザ名= ###、パスワード= ###： java.net.InetAddress.getAddressesFromNameService（InetAddress.javaで java.net.InetAddress $ 2.lookupAllHostAddr（InetAddress.java:928）で java.net.Inet6AddressImpl.lookupAllHostAddr（ネイティブメソッド）で不明なエラー：1323） at java.net.InetAddress.getAllByName0（InetAddress.java:1276）

Answer 1

それはあなたのために働くかどうかを確認、次の解決方法を試してみてください。

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"))