diff --git a/myems-aggregation/main.py b/myems-aggregation/main.py
index 850eb5af..c083d038 100644
--- a/myems-aggregation/main.py
+++ b/myems-aggregation/main.py
@@ -152,7 +152,7 @@ def main():
     Process(target=tenant_energy_input_item.main, args=(logger,)).start()
 
     # virtual meter carbon dioxide emission
-    Process(target=virtual_meter_billing.main, args=(logger,)).start()
+    Process(target=virtual_meter_carbon.main, args=(logger,)).start()
     # virtual meter billing (cost or income)
     Process(target=virtual_meter_billing.main, args=(logger,)).start()
 
diff --git a/myems-aggregation/virtual_meter_carbon.py b/myems-aggregation/virtual_meter_carbon.py
index ab6cf64c..98d82d78 100644
--- a/myems-aggregation/virtual_meter_carbon.py
+++ b/myems-aggregation/virtual_meter_carbon.py
@@ -135,7 +135,7 @@ def main(logger):
             try:
                 cursor_carbon_db.execute(" SELECT MAX(start_datetime_utc) "
                                          " FROM tbl_virtual_meter_hourly "
-                                         " WHERE meter_id = %s ",
+                                         " WHERE virtual_meter_id = %s ",
                                          (virtual_meter['id'], ))
                 row_datetime = cursor_carbon_db.fetchone()
                 start_datetime_utc = datetime.strptime(config.start_datetime_utc, '%Y-%m-%d %H:%M:%S')