java.net.UnknownHostException при выполнении вставки Spark в таблицу кустов в кластере EMR - PullRequest
Новая
       42

java.net.UnknownHostException при выполнении вставки Spark в таблицу кустов в кластере EMR

0 голосов
/ 27 декабря 2018

Я пытаюсь вставить значения в уже существующую таблицу кустов. Значения вставляются в таблицу кустов, но получаются исключения при работе в кластере EMR. 

df.write.mode("append").insertInto(staging.table)

Оператор Sql 

   spark.sql("insert into table staging.table  values ('81253157746','CZK','','Dest','Neth','-1','','CZK;Dest;EST','2018-12-27 14:01:19','')")

Исключение 

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/lib/spark/python/pyspark/sql/session.py", line 708, in sql
    return DataFrame(self._jsparkSession.sql(sqlQuery), self._wrapped)
  File "/usr/lib/spark/python/lib/py4j-0.10.6-src.zip/py4j/java_gateway.py", line 1160, in __call__
  File "/usr/lib/spark/python/pyspark/sql/utils.py", line 69, in deco
    raise AnalysisException(s.split(': ', 1)[1], stackTrace)
pyspark.sql.utils.AnalysisException: u'java.lang.IllegalArgumentException: java.net.UnknownHostException: ip-10-XXX-XXX-XXX;'
...