diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java index 1f6114ae3d..c92b18bd04 100644 --- a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java +++ b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java @@ -194,32 +194,6 @@ private static ApplicationId getApplicationIDFromString(String appIDStr) { return ApplicationId.newInstance(timestamp, id); } - public static boolean isApplicationAccepted(HiveConf conf, String applicationId) { - if (applicationId == null) { - return false; - } - YarnClient yarnClient = null; - try { - ApplicationId appId = getApplicationIDFromString(applicationId); - yarnClient = YarnClient.createYarnClient(); - yarnClient.init(conf); - yarnClient.start(); - ApplicationReport appReport = yarnClient.getApplicationReport(appId); - return appReport != null && appReport.getYarnApplicationState() == YarnApplicationState.ACCEPTED; - } catch (Exception ex) { - LOG.error("Failed getting application status for: " + applicationId + ": " + ex, ex); - return false; - } finally { - if (yarnClient != null) { - try { - yarnClient.stop(); - } catch (Exception ex) { - LOG.error("Failed to stop yarn client: " + ex, ex); - } - } - } - } - static class YarnApplicationStateFinder { public boolean isApplicationAccepted(HiveConf conf, String applicationId) { if (applicationId == null) {