Kaynağa Gözat

[hbase] Api error throw when search with rowkey startswith '0' (#895)

linwukang 6 yıl önce
ebeveyn
işleme
70d518e13d
1 değiştirilmiş dosya ile 2 ekleme ve 0 silme
  1. 2 0
      apps/hbase/src/hbase/api.py

+ 2 - 0
apps/hbase/src/hbase/api.py

@@ -218,6 +218,8 @@ class HbaseApi(object):
     client = self.connectCluster(cluster)
     client = self.connectCluster(cluster)
     aggregate_data = []
     aggregate_data = []
     limit = conf.TRUNCATE_LIMIT.get()
     limit = conf.TRUNCATE_LIMIT.get()
+    if not isinstance(queries, list):
+      queries=json.loads(queries)
     queries = sorted(queries, key=lambda query: query['scan_length']) #sort by scan length
     queries = sorted(queries, key=lambda query: query['scan_length']) #sort by scan length
     for query in queries:
     for query in queries:
       scan_length = int(query['scan_length'])
       scan_length = int(query['scan_length'])