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 12:55:53 UTC
[incubator-skywalking] branch top-sql updated: Fix wrong query
result column name.
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 232b01e Fix wrong query result column name.
232b01e is described below
commit 232b01e4e5b380e91a593b51009b9514e11e404d
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Tue Feb 12 20:55:42 2019 +0800
Fix wrong query result column name.
---
.../storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java | 2 +-
.../oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java
index 42eee9e..6b3446b 100644
--- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java
+++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java
@@ -58,7 +58,7 @@ public class TopNRecordsQueryEsDAO extends EsDAO implements ITopNRecordsQueryDAO
TopNRecord record = new TopNRecord();
record.setStatement((String)searchHit.getSourceAsMap().get(TopN.STATEMENT));
record.setTraceId((String)searchHit.getSourceAsMap().get(TopN.TRACE_ID));
- record.setLatency(((Number)searchHit.getSourceAsMap().get(SegmentRecord.IS_ERROR)).longValue());
+ record.setLatency(((Number)searchHit.getSourceAsMap().get(TopN.LATENCY)).longValue());
results.add(record);
}
diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java
index 1300341..1744e3a 100644
--- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java
+++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java
@@ -65,7 +65,7 @@ public class H2TopNRecordsQueryDAO implements ITopNRecordsQueryDAO {
TopNRecord record = new TopNRecord();
record.setStatement(resultSet.getString(TopN.STATEMENT));
record.setTraceId(resultSet.getString(TopN.TRACE_ID));
- record.setLatency(resultSet.getLong(SegmentRecord.IS_ERROR));
+ record.setLatency(resultSet.getLong(TopN.LATENCY));
results.add(record);
}
} catch (SQLException e) {