Merge branch 'master' into dev

walmartlabs · Oct 4, 2012 · 0ee5a9e · 0ee5a9e
2 parents 0063ce4 + 37b1ed7
commit 0ee5a9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/scala/com/walmartlabs/mupd8/Mupd8Main.scala b/src/main/scala/com/walmartlabs/mupd8/Mupd8Main.scala
@@ -453,7 +453,7 @@ class CassandraPool(
   def fetch(name : String, key : Key, next : Option[Slate] => Unit) {
     pool.submit(run{
       val start = java.lang.System.nanoTime()
-      val col = excToOption(selector.getColumnFromRow(getCF(name), Bytes.fromByteArray(key), Bytes.fromByteArray(name.getBytes), ConsistencyLevel.ONE))
+      val col = excToOption(selector.getColumnFromRow(getCF(name), Bytes.fromByteArray(key), Bytes.fromByteArray(name.getBytes), ConsistencyLevel.QUORUM))
       log("Fetch " + (java.lang.System.nanoTime() - start)/1000000 + " " + name + " " + str(key))
       next(col.map { col =>
         assert(col != null)
@@ -471,7 +471,7 @@ class CassandraPool(
       Bytes.fromByteArray(key),
       mutator.newColumn(Bytes.fromByteArray(columnName.getBytes), Bytes.fromByteArray(compressed), getTTL(columnName))
     )
-    excToOptionWithLog{mutator.execute(ConsistencyLevel.ONE)} != None
+    excToOptionWithLog{mutator.execute(ConsistencyLevel.QUORUM)} != None
   }
 
   override def pendingCount = pool.getQueue.size + pool.getActiveCount