[collector]bugfix: fix warehouse data queue consume error (#153)

apache · May 27, 2022 · 7038f00 · 7038f00
1 parent e80014f
commit 7038f00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/collector/src/main/java/com/usthe/collector/dispatch/export/MetricsDataExporter.java b/collector/src/main/java/com/usthe/collector/dispatch/export/MetricsDataExporter.java
@@ -32,7 +32,7 @@ public CollectRep.MetricsData pollAlertMetricsData() throws InterruptedException
     }
 
     public CollectRep.MetricsData pollPersistentStorageMetricsData() throws InterruptedException {
-        return metricsDataToAlertQueue.poll(2, TimeUnit.SECONDS);
+        return metricsDataToPersistentStorageQueue.poll(2, TimeUnit.SECONDS);
     }
 
     public CollectRep.MetricsData pollMemoryStorageMetricsData() throws InterruptedException {