Преглед на файлове

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

linwukang преди 6 години
родител
ревизия
70d518e13d
променени са 1 файла, в които са добавени 2 реда и са изтрити 0 реда
  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)
     aggregate_data = []
     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
     for query in queries:
       scan_length = int(query['scan_length'])