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("myhive3");

            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) {
                report.getApplicationResourceUsageReport().getMemorySeconds();
                report.getApplicationResourceUsageReport().getVcoreSeconds();


                System.out.println(report.getApplicationId());

//                yarn logs -applicationId application_1436784252938_0022
            }How can I get logs with yarn client api?

Reply via email to