标签：omFeed getState java 请求 getInstanceId handler spark id log
打印spark处理失败的日志<br>SparkLauncher launcher = sparkJobUtil.<a href="https://www.gaodaima.com/tag/build" title="查看更多关于build的文章" target="_blank">build</a>SparkLauncher(feedConfig, <a href="https://www.gaodaima.com/tag/app" title="查看更多关于app的文章" target="_blank">app</a>Name, params);<br>SparkAppHandle handler = launcher.startApplication();<br>int exitCode = -1;<br>while (handler.getState() == null || !handler.getState().isFinal()) {<br> if (handler.getState() != null) {<br> if (handler.getState().equals(SparkAppHandle.State.FINISHED)) {<br> log.info("instance id {} App id: {} is finished ", omFeed.getInstanceId(), handler.getAppId());<br> exitCode = 0;<br> }<br> }<br>}<br>if (handler.getError().isPresent()) {<br> log.error("instance id {} app id fail fail ", omFeed.getInstanceId(), handler.getAppId());<br> handler.getError().get().printStackTrace();<br>}else{<br> log.error("instance id {} app id run success ", omFeed.getInstanceId(), handler.getAppId());<br> exitCode = 0 ;<br>}
标签：omFeed,getState,java,请求,getInstanceId,handler,spark,id,log
来源： https://www.cnblogs.com/ivyJ/p/16375855.html
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：在java里向spark请求处理
转载请注明原文链接：在java里向spark请求处理
