YARN-5379. TestHBaseTimelineStorage. testWriteApplicationToHBase() fa…

…ils intermittently (Vrushali C via sjlee)
apache · Jul 14, 2016 · e549a9a · e549a9a
1 parent 5537c6b
commit e549a9a
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/.../java/org/apache/hadoop/yarn/server/timelineservice/storage/TestHBaseTimelineStorage.java b/.../java/org/apache/hadoop/yarn/server/timelineservice/storage/TestHBaseTimelineStorage.java
@@ -613,8 +613,8 @@ public void testWriteApplicationToHBase() throws Exception {
     TimelineMetric aggMetric = new TimelineMetric();
     aggMetric.setId("MEM_USAGE");
     Map<Long, Number> aggMetricValues = new HashMap<Long, Number>();
-    ts = System.currentTimeMillis();
-    aggMetricValues.put(ts - 120000, 102400000L);
+    long aggTs = ts;
+    aggMetricValues.put(aggTs - 120000, 102400000L);
     aggMetric.setType(Type.SINGLE_VALUE);
     aggMetric.setRealtimeAggregationOp(TimelineMetricOperation.SUM);
     aggMetric.setValues(aggMetricValues);
@@ -819,9 +819,9 @@ public void testWriteApplicationToHBase() throws Exception {
               metric.getValues().get(ts - 20000));
         }
         if (metric.getId().equals("MEM_USAGE")) {
-          assertTrue(metric.getValues().containsKey(ts - 120000));
-          assertEquals(aggMetricValues.get(ts - 120000),
-              metric.getValues().get(ts - 120000));
+          assertTrue(metric.getValues().containsKey(aggTs - 120000));
+          assertEquals(aggMetricValues.get(aggTs - 120000),
+              metric.getValues().get(aggTs - 120000));
         }
       }
     } finally {