Package org.apache.hadoop.metrics2.impl

Examples of org.apache.hadoop.metrics2.impl.MetricsSystemImpl.shutdown()

259
260
261
262
263
264
265
266
267
268
269
          QueueMetrics.forQueue(ms, leafQueueName, parentQueue1, true, conf);

      Assert.assertNotNull("QueueMetrics for alterMetrics shoudn't be null",
          alterMetrics);
    } finally {
      ms.shutdown();
    }
  }


  public static void checkApps(MetricsSource source, int submitted, int pending,
View Full Code Here
259
260
261
262
263
264
265
266
267
268
269
          QueueMetrics.forQueue(ms, leafQueueName, parentQueue1, true, conf);

      Assert.assertNotNull("QueueMetrics for alterMetrics shoudn't be null",
          alterMetrics);
    } finally {
      ms.shutdown();
    }
  }


  public static void checkApps(MetricsSource source, int submitted, int pending,
View Full Code Here
262
263
264
265
266
267
268
269
270
271
272
          QueueMetrics.forQueue(ms, leafQueueName, parentQueue1, true, conf);

      Assert.assertNotNull("QueueMetrics for alterMetrics shoudn't be null",
          alterMetrics);
    } finally {
      ms.shutdown();
    }
  }

  @Test
  public void testMetricsInitializedOnRMInit() {
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    mm1.testMetric1.incr();
    mm1.testMetric2.incr(2);

    ms.publishMetricsNow(); // publish the metrics
    ms.stop();
    ms.shutdown();
   
    InputStream is = new FileInputStream(outFile);
    ByteArrayOutputStream baos = new ByteArrayOutputStream((int)outFile.length());
    IOUtils.copyBytes(is, baos, 1024, true);
    String outFileContent = new String(baos.toByteArray(), "UTF-8");
View Full Code Here
258
259
260
261
262
263
264
265
266
267
268
          QueueMetrics.forQueue(ms, leafQueueName, parentQueue1, true, conf);

      Assert.assertNotNull("QueueMetrics for alterMetrics shoudn't be null",
          alterMetrics);
    } finally {
      ms.shutdown();
    }
  }


  public static void checkApps(MetricsSource source, int submitted, int pending,
View Full Code Here
296
297
298
299
300
301
302
303
304
305
306
          QueueMetrics.forQueue(ms, leafQueueName, parentQueue1, true, conf);

      Assert.assertNotNull("QueueMetrics for alterMetrics shoudn't be null",
          alterMetrics);
    } finally {
      ms.shutdown();
    }
  }

  @Test
  public void testMetricsInitializedOnRMInit() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.