Fix deserialization for "lastBeofre" query

uwburn · Mar 30, 2019 · 76600a0 · 76600a0
1 parent 4af0ec0
commit 76600a0
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/worker/cassandra/CassandraMachineSink.js b/worker/cassandra/CassandraMachineSink.js
@@ -434,11 +434,12 @@ module.exports = class CassandraMachineSink extends BaseSink {
 
     let count = 0;
     for (let i = rawResults.length - 1; i >= 0; --i) {
-      if (rawResults[i].rowLength)
+      if (rawResults[i].rowLength) {
         ++count;
 
-      if (count === 1)
-        rawResults[i].rows[0].value = avroType.fromBuffer(rawResults[i].rows[0].value);
+        if (count === 1)
+          rawResults[i].rows[0].value = avroType.fromBuffer(rawResults[i].rows[0].value);
+      }
     }
 
     return count;