public static void diagnose ( String applicationId , String queueName , int numNodes , int nodeMemoryMb , int numNodesStarted ) throws Exception { H2OYarnDiagnostic client = new H2OYarnDiagnostic ( ) ; client . applicationId = applicationId ; client . queueName = queueName ; client . numNodes = numNodes ; client . nodeMemoryMb = nodeMemoryMb ; client . nodeVirtualCores = 1 ; client . numNodesStarted = numNodesStarted ; client . run ( ) ; }
The assumption is this method doesn t get called unless a problem occurred .