Couchbase2Client.diff

diff --git a/couchbase2/src/main/java/com/yahoo/ycsb/db/couchbase2/Couchbase2Client.java b/couchbase2/src/main/java/com/yahoo/ycsb/db/couchbase2/Couchbase2Client.java
index 3d0bc03..56a9641 100644
--- a/couchbase2/src/main/java/com/yahoo/ycsb/db/couchbase2/Couchbase2Client.java
+++ b/couchbase2/src/main/java/com/yahoo/ycsb/db/couchbase2/Couchbase2Client.java
@@ -633,10 +633,14 @@ public class Couchbase2Client extends DB {
           @Override
           public Observable<RawJsonDocument> call(AsyncN1qlQueryRow row) {
             String id = new String(row.byteValue());
-            return bucket.async().get(
-              id.substring(id.indexOf(table + SEPARATOR), id.lastIndexOf('"')),
-              RawJsonDocument.class
-            );
+//            return bucket.async().get(
+//              id.substring(id.indexOf(table + SEPARATOR), id.lastIndexOf('"')),
+//              RawJsonDocument.class
+//            );
+            return Observable.just(RawJsonDocument.create(
+                id.substring(id.indexOf(table + SEPARATOR), id.lastIndexOf('"')),
+                "{}"
+            ));
           }
         })
         .map(new Func1<RawJsonDocument, HashMap<String, ByteIterator>>() {