diff --git a/influxdb/client.py b/influxdb/client.py
index 41908e82..ef03b012 100644
--- a/influxdb/client.py
+++ b/influxdb/client.py
@@ -282,11 +282,14 @@ def query(self, query, time_precision='s', chunked=False):
             status_code=200
             )
 
-        try:
-            res = json.loads(response.content)
-        except TypeError:
-            # must decode in python 3
-            res = json.loads(response.content.decode('utf8'))
+        if chunked:
+            res = json.loads("[" + response.content.decode('utf8').replace("}{", "},\n{") + "]")
+        else:
+            try:
+                res = json.loads(response.content)
+            except TypeError:
+                # must decode in python 3
+                res = json.loads(response.content.decode('utf8'))
 
         return res