diff --git a/frameworks/flink/src/main/java/com/criteo/hadoop/garmadon/flink/GarmadonFlinkReporter.java b/frameworks/flink/src/main/java/com/criteo/hadoop/garmadon/flink/GarmadonFlinkReporter.java
index 8a43c65e..6e7982e7 100644
--- a/frameworks/flink/src/main/java/com/criteo/hadoop/garmadon/flink/GarmadonFlinkReporter.java
+++ b/frameworks/flink/src/main/java/com/criteo/hadoop/garmadon/flink/GarmadonFlinkReporter.java
@@ -204,8 +204,8 @@ private void tryToSet(Runnable c) {
     private void reportJobManagerMetrics(long currentTimeMillis) {
         FlinkEventProtos.JobManagerEvent.Builder builder = FlinkEventProtos.JobManagerEvent.newBuilder();
 
-        tryToSet(() -> builder.setNumRunningJobs(((Gauge<Long>) gauges.get("numRegisteredTaskManagers")).getValue()));
-        tryToSet(() -> builder.setNumRegisteredTaskManagers(((Gauge<Long>) gauges.get("numRunningJobs")).getValue()));
+        tryToSet(() -> builder.setNumRunningJobs(((Gauge<Long>) gauges.get("numRunningJobs")).getValue()));
+        tryToSet(() -> builder.setNumRegisteredTaskManagers(((Gauge<Long>) gauges.get("numRegisteredTaskManagers")).getValue()));
         tryToSet(() -> builder.setTaskSlotsAvailable(((Gauge<Long>) gauges.get("taskSlotsAvailable")).getValue()));
         tryToSet(() -> builder.setTaskSlotsTotal(((Gauge<Long>) gauges.get("taskSlotsTotal")).getValue()));