From a6abe7fa827cb1fc1d6ce3c2009112181107f923 Mon Sep 17 00:00:00 2001
From: Chuanyi Li <chuanyili0625@gmail.com>
Date: Fri, 17 Aug 2018 19:54:57 +0800
Subject: [PATCH] Avoid 48 years delay at startup.

---
 .../prometheus/impl/PrometheusCanalEventDownStreamHandler.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusCanalEventDownStreamHandler.java b/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusCanalEventDownStreamHandler.java
index f81033a4..c3c71102 100644
--- a/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusCanalEventDownStreamHandler.java
+++ b/prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusCanalEventDownStreamHandler.java
@@ -13,7 +13,7 @@ import java.util.concurrent.atomic.AtomicLong;
  */
 public class PrometheusCanalEventDownStreamHandler extends AbstractCanalEventDownStreamHandler<List<Event>> {
 
-    private final AtomicLong latestExecuteTime  = new AtomicLong(0L);
+    private final AtomicLong latestExecuteTime  = new AtomicLong(System.currentTimeMillis());
     private final AtomicLong transactionCounter = new AtomicLong(0L);
     private final AtomicLong rowEventCounter    = new AtomicLong(0L);
     private final AtomicLong rowsCounter        = new AtomicLong(0L);