[td-1322]

19b0a7cc · Haojun Liao · ec567395 · 19b0a7cc
显示空白变更内容
内联并排

Showing with 7 addition and 2 deletion

src/query/src/qPercentile.c src/query/src/qPercentile.c +7 -2

未找到文件。
--- a/src/query/src/qPercentile.c
+++ b/src/query/src/qPercentile.c
@@ -154,9 +154,14 @@ int32_t tBucketBigIntHash(tMemBucket *pBucket, const void *value) {
 // todo refactor to more generic
 int32_t tBucketIntHash(tMemBucket *pBucket, const void *value) {
-  int32_t v = *(int32_t *)value;
+  int32_t v = 0;
-  int32_t index = -1;
+  switch(pBucket->type) {
+    case TSDB_DATA_TYPE_SMALLINT: v = *(int16_t*) value; break;
+    case TSDB_DATA_TYPE_TINYINT: v = *(int8_t*) value; break;
+    default: v = *(int32_t*) value;break;
+  }
+  int32_t index = -1;
  if (pBucket->range.iMaxVal == INT32_MIN) {
    /*
     * taking negative integer into consideration,