Hello,
I'm trying to integrate Atlas with Sqoop, but I get this error:
2018-11-25 20:44:23,263 INFO hive.HiveImport: Loading uploaded data into Hive
2018-11-25 20:44:23,321 ERROR tool.ImportTool: Encountered IOException running
import job: java.io.IOException: Exception thrown in Hive
at org.apache.sqoop.hive.HiveImport.executeScript(HiveImport.java:365)
at org.apache.sqoop.hive.HiveImport.importTable(HiveImport.java:245)
at org.apache.sqoop.tool.ImportTool.importTable(ImportTool.java:514)
at org.apache.sqoop.tool.ImportTool.run(ImportTool.java:605)
at org.apache.sqoop.Sqoop.run(Sqoop.java:148)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:76)
at org.apache.sqoop.Sqoop.runSqoop(Sqoop.java:184)
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:226)
at org.apache.sqoop.Sqoop.runTool(Sqoop.java:235)
at org.apache.sqoop.Sqoop.main(Sqoop.java:244)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.sqoop.hive.HiveImport.executeScript(HiveImport.java:338)
... 9 more
Caused by: java.lang.ExceptionInInitializerError
at
org.apache.hadoop.hive.common.LogUtils.initHiveLog4j(LogUtils.java:58)
at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:699)
at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:683)
... 14 more
Caused by: java.lang.IllegalArgumentException: Unrecognized Hadoop major
version number: 3.1.1
at
org.apache.hadoop.hive.shims.ShimLoader.getMajorVersion(ShimLoader.java:174)
at
org.apache.hadoop.hive.shims.ShimLoader.loadShims(ShimLoader.java:139)
at
org.apache.hadoop.hive.shims.ShimLoader.getHadoopShims(ShimLoader.java:100)
at
org.apache.hadoop.hive.conf.HiveConf$ConfVars.<clinit>(HiveConf.java:368)
... 17 more
2018-11-25 20:44:23,323 INFO kafka.KafkaNotification: ==>
KafkaNotification.createProducer()
2018-11-25 20:44:23,332 INFO hook.AtlasHook: ==> Shutdown of Atlas Hook
2018-11-25 20:44:23,352 ERROR hook.AtlasHook: Failed to send notification -
attempt #1; error=Missing required configuration "bootstrap.servers" which has
no default value.
2018-11-25 20:44:24,354 INFO kafka.KafkaNotification: ==>
KafkaNotification.createProducer()
2018-11-25 20:44:24,354 ERROR hook.AtlasHook: Failed to send notification -
attempt #2; error=Missing required configuration "bootstrap.servers" which has
no default value.
2018-11-25 20:44:25,356 INFO kafka.KafkaNotification: ==>
KafkaNotification.createProducer()
2018-11-25 20:44:25,356 ERROR hook.AtlasHook: Failed to send notification -
attempt #3; error=Missing required configuration "bootstrap.servers" which has
no default value.
2018-11-25 20:44:25,357 INFO hook.AtlasHook: <== Shutdown of Atlas Hook
Someone know how to solve it?
Thanks
Ciao
Emiliano Carlesi
Email: [email protected]<mailto:[email protected]>
Skype for Business:
[email protected]<mailto:[email protected]>
Skype: emiliano.carlesi
Mobile: +39 3487837153
Phone: +39 0650939115
[logo-firma]
Le informazioni contenute nella presente comunicazione e i relativi allegati
contenuti in questo messaggio sono strettamente riservate ed esclusivamente
indirizzate al destinatario indicato. Vogliate tener presente che qualsiasi
uso, riproduzione o divulgazione di questo messaggio è vietata. Nel caso in cui
aveste ricevuto questa mail per errore, vogliate cortesemente avvertire il
mittente e distruggere il presente messaggio. La diffusione, distribuzione e/o
copiatura del documento trasmesso da parte di qualsiasi soggetto diverso dal
destinatario è proibita, sia ai sensi dell'art. 616 c.p. , che ai sensi del
Regolamento UE 679/2016.
