You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/02/12 02:30:35 UTC

[incubator-skywalking] branch top-sql updated: Fix wrong db default threshold

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch top-sql
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git


The following commit(s) were added to refs/heads/top-sql by this push:
     new 9ef1cd9  Fix wrong db default threshold
9ef1cd9 is described below

commit 9ef1cd9561869c7070b5b467ed05dce1b01302ed
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Tue Feb 12 10:30:18 2019 +0800

    Fix wrong db default threshold
---
 .../oap/server/receiver/trace/provider/DBLatencyThresholds.java         | 2 +-
 .../apache/skywalking/oap/server/receiver/trace/mock/ServiceBMock.java  | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/DBLatencyThresholds.java b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/DBLatencyThresholds.java
index 55aab89..b66c890 100644
--- a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/DBLatencyThresholds.java
+++ b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/DBLatencyThresholds.java
@@ -35,7 +35,7 @@ public class DBLatencyThresholds {
                 thresholds.put(typeValue[0].toLowerCase(), Integer.parseInt(typeValue[1]));
             }
         }
-        if (thresholds.containsKey("default")) {
+        if (!thresholds.containsKey("default")) {
             thresholds.put("default", 10000);
         }
     }
diff --git a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/ServiceBMock.java b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/ServiceBMock.java
index f9bcfbe..9496815 100644
--- a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/ServiceBMock.java
+++ b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/test/java/org/apache/skywalking/oap/server/receiver/trace/mock/ServiceBMock.java
@@ -117,6 +117,7 @@ class ServiceBMock {
         span.setComponentId(ComponentsDefine.MONGO_DRIVER.getId());
         span.setIsError(true);
         span.addTags(KeyWithStringValue.newBuilder().setKey("db.statement").setValue("select * from database where complex = 1;").build());
+        span.addTags(KeyWithStringValue.newBuilder().setKey("db.type").setValue("mongodb").build());
 
         if (isPrepare) {
             span.setOperationName("mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]");