You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@hive.apache.org by igyu <ig...@21cn.com> on 2021/08/10 09:46:50 UTC
How can I get application with hive jdbc
hive on spark
Properties pro = new Properties();
pro.put("hiveconf:spark.app.name", "myhive3");
pro.put("hiveconf:spark.yarn.tags","myhive3");
Connection connection = DriverManager.getConnection(HIVE_URL_LDAP, pro);
Statement st = connection.createStatement();ResultSet rs = st.executeQuery("SELECT t.username,count(1) from hivetest.tb_user t GROUP BY t.username");
getApplicationId();public static void getApplicationId() {
try {
YarnClient client = YarnClient.createYarnClient();
Configuration yarnconf = new YarnConfiguration();
yarnconf.addResource(new File("D:\\file\\yarn-site.xml").toURI().toURL());
client.init(yarnconf);
client.start();
Set<String> applicationTypes = new HashSet<>();
applicationTypes.add("SPARK");
Set<String> applicationTags = new HashSet<>();
applicationTags.add("myhive2");
Set<YarnApplicationState> applicationStates = new HashSet<>();
applicationStates.add(YarnApplicationState.ACCEPTED);
applicationStates.add(YarnApplicationState.FINISHED);
applicationStates.add(YarnApplicationState.RUNNING);
EnumSet<YarnApplicationState> enumStates = Sets.newEnumSet(applicationStates, YarnApplicationState.class);
List<ApplicationReport> reports = client.getApplications(applicationTypes, enumStates,applicationTags);
for (ApplicationReport report : reports) {
System.out.println(report.getApplicationId());
}
} catch (Exception err) {
err.printStackTrace();
}
}
How can I set tags?
igyu
回复: How can I get application with hive jdbc
Posted by igyu <ig...@21cn.com>.
applicationTags.add("myhive3");
igyu
发件人: igyu
发送时间: 2021-08-10 17:46
收件人: user
主题: How can I get application with hive jdbc
hive on spark
Properties pro = new Properties();
pro.put("hiveconf:spark.app.name", "myhive3");
pro.put("hiveconf:spark.yarn.tags","myhive3");
Connection connection = DriverManager.getConnection(HIVE_URL_LDAP, pro);
Statement st = connection.createStatement();ResultSet rs = st.executeQuery("SELECT t.username,count(1) from hivetest.tb_user t GROUP BY t.username");
getApplicationId();public static void getApplicationId() {
try {
YarnClient client = YarnClient.createYarnClient();
Configuration yarnconf = new YarnConfiguration();
yarnconf.addResource(new File("D:\\file\\yarn-site.xml").toURI().toURL());
client.init(yarnconf);
client.start();
Set<String> applicationTypes = new HashSet<>();
applicationTypes.add("SPARK");
Set<String> applicationTags = new HashSet<>();
applicationTags.add("myhive2");
Set<YarnApplicationState> applicationStates = new HashSet<>();
applicationStates.add(YarnApplicationState.ACCEPTED);
applicationStates.add(YarnApplicationState.FINISHED);
applicationStates.add(YarnApplicationState.RUNNING);
EnumSet<YarnApplicationState> enumStates = Sets.newEnumSet(applicationStates, YarnApplicationState.class);
List<ApplicationReport> reports = client.getApplications(applicationTypes, enumStates,applicationTags);
for (ApplicationReport report : reports) {
System.out.println(report.getApplicationId());
}
} catch (Exception err) {
err.printStackTrace();
}
}
How can I set tags?
igyu