livy提交任务报错com.cloudera.livy.shaded.kryo.kryo.KryoException: Unable to find class: GATest.ConJob
生活随笔
收集整理的這篇文章主要介紹了
livy提交任务报错com.cloudera.livy.shaded.kryo.kryo.KryoException: Unable to find class: GATest.ConJob
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
今天在測試的時(shí)候,出現(xiàn)這個(gè)錯(cuò)誤,找了好久網(wǎng)上找不到,最近嘗試多次終于成功了。
問題就在于:Unable to find class
你要把你已經(jīng)uploadJar的jar包中包含的類,引入工程。
我用spring-boot+livy+spark的一個(gè)例子:
public class Contains extends Kryo{@RequestMapping("/contains")@ResponseBody public String contains(@RequestParam(value="path1", defaultValue="") String path1,@RequestParam(value="path2", defaultValue="") String path2) {double sum=0;if (path1.length() == 0 || path2.length() == 0) {return "path is null";}else {try{LivyClient client = new LivyClientBuilder().setURI(new URI("http://master.esri.local:8998/")).build();System.out.println("this is the client"+ "*******************************************");client.uploadJar(new File("/usr/local/jarsubmit/EsriGA.jar")).get();System.out.println("this is the uploadJar"+ "*******************************************");//client.uploadJar(new File("C:\\testGA\\GATest2.jar")).get(); sum = client.submit(new GATest.ConJob(10)).get();//sum = client.submit(com.esrichina.gaextension.app.IntersectApp).get(); System.out.println("the client is submitted "+ "*******************************************");client.stop(true);System.out.println("the client is stopped "+ "*******************************************");}catch (Exception e){e.printStackTrace();}}return Double.toString(sum);}public static void main(String[] args) throws Exception {SpringApplication.run(Contains.class, args);} }總結(jié)
以上是生活随笔為你收集整理的livy提交任务报错com.cloudera.livy.shaded.kryo.kryo.KryoException: Unable to find class: GATest.ConJob的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Scala 中的文件操作
- 下一篇: 微服务架构模式简介