Merge pull request #853 from lcybo/master

修复启动时，没读到带execTime时，出现48年delay。
2026-11-04 00:30:15 +08:00 · 2018-08-18 13:59:54 +08:00
parent e879216fa4 59169876eb
commit a4445043c1
29 changed files with 1286 additions and 1 deletions
--- a/deployer/src/main/resources/metrics/Canal_instances_tmpl.json
+++ b/deployer/src/main/resources/metrics/Canal_instances_tmpl.json
--- a/images/DML_model_indicator.PNG
+++ b/images/DML_model_indicator.PNG
--- a/images/QPS_empty_batches.PNG
+++ b/images/QPS_empty_batches.PNG
--- a/images/RPS_client.PNG
+++ b/images/RPS_client.PNG
--- a/images/TPS.PNG
+++ b/images/TPS.PNG
--- a/images/TPS_event.PNG
+++ b/images/TPS_event.PNG
--- a/images/TPS_rows.PNG
+++ b/images/TPS_rows.PNG
--- a/images/TPS_transaction.PNG
+++ b/images/TPS_transaction.PNG
--- a/images/basic.PNG
+++ b/images/basic.PNG
--- a/images/client_band.PNG
+++ b/images/client_band.PNG
--- a/images/clients.PNG
+++ b/images/clients.PNG
--- a/images/delay.PNG
+++ b/images/delay.PNG
--- a/images/empty.PNG
+++ b/images/empty.PNG
--- a/images/idle.PNG
+++ b/images/idle.PNG
--- a/images/instance.PNG
+++ b/images/instance.PNG
--- a/images/latency.PNG
+++ b/images/latency.PNG
--- a/images/network.PNG
+++ b/images/network.PNG
--- a/images/publish_blocking.PNG
+++ b/images/publish_blocking.PNG
--- a/images/remain_events.PNG
+++ b/images/remain_events.PNG
--- a/images/remain_mem.PNG
+++ b/images/remain_mem.PNG
--- a/images/reqs.PNG
+++ b/images/reqs.PNG
--- a/images/rows.PNG
+++ b/images/rows.PNG
--- a/images/sink_blocking.PNG
+++ b/images/sink_blocking.PNG
--- a/images/store.PNG
+++ b/images/store.PNG
--- a/images/store_remain_events.PNG
+++ b/images/store_remain_events.PNG
--- a/images/store_remain_memory.PNG
+++ b/images/store_remain_memory.PNG
--- a/images/throughput.PNG
+++ b/images/throughput.PNG
--- a/images/transactions.PNG
+++ b/images/transactions.PNG
--- 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);