回复: How can I get application with hive jdbc

[igyu]

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