Skip to content

Instantly share code, notes, and snippets.

@aphyr
Last active December 22, 2015 02:19
Show Gist options
  • Star 4 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save aphyr/6402464 to your computer and use it in GitHub Desktop.
Save aphyr/6402464 to your computer and use it in GitHub Desktop.
In http://www.datastax.com/dev/blog/row-level-isolation and
http://www.datastax.com/dev/blog/atomic-batches-in-cassandra-1-2, Datastax
asserts that batch updates to multiple cells in a single row are
guaranteed to be isolated from concurrent batches:
"Cassandra 1.1 guarantees that if you update both the login and password in the
same update (for the same row key) then no concurrent read may see only a
partial update."
"...the guarantee is that the new login cannot be persisted without the new
password being persisted too (and vice-versa)."
In this test, we have a simple table schema: each row consists of an ID, an A
column, and a B column. Five concurrent clients write sequentially to a
thousand rows. Each client generates a random identifier, and tries to write
that identifier to both the A and B fields for a given row. For reasons that
will become clear later, we write +identifier to A, and -identifier to B. If
the isolation invariant holds, A should always be equal to -B: we shouldn't see
A=1 and B=-4, for instance.
30 seconds into the run, we partition the Cassandra nodes into [n1 n2 | n3 n4
n5]. At 500 writes, we heal the network partition. The partition is not
necessary to cause this problem, but it does improve the probabilities a bit.
At the end of the run, we read back all the rows, and check to make sure that
A=B in each one. If we ever see a conflict; e.g. the row update was not
isolated, we consider that write "lost". In this case, almost every write which
occurs with an identical timestamp to another will result in corruption. In
this particular cluster and workload scheduler, the chances of 5 updates to a row
occurring at the same timestamp is roughly 7.5%, but if we force identical
timestamps or more contention, the corruption probability rises to 99% and
higher.
Why does this happen? It's because when Cassandra compares conflicting copies
of a data, either via active anti-entropy (AAE), read repair, or hinted
handoff, it resolves conflicts at the level of the *cell*, not the *row*. Let's
say the conflict resolution system sees these two copies of a row:
+----- Cell A ----------+----- Cell B -----------+
id | A value | A timestamp | B value | B timestamp
1 | 3 | 123 | -3 | 123
1 | 5 | 123 | -5 | 123
There are three possible ways to resolve this conflict in a way which preserves
row isolation: by selecting (A=3, B=-3), or (A=5, B=-5), or by throwing away
A and B altogether. Instead, Cassandra looks at each *cell* in isolation. Its
conflict resolution function chooses the copy with the higher timestamp, and
if timestamps are identical, with the higher *value*. In cell A, both timestamps
are 123, and the value 5 is greater than the value 3, so the value becomes 5.
In cell B, -3 is greater than -5, so we preserve -3. The resulting row is then:
id | A value | A timestamp | B value | B timestamp
1 | 5 | 123 | -3 | 123
which means row isolation is *not* preserved. This affects not only concurrent
reads (if they happen to interact with a read-repair or other write propagation
which causes conflict resolution), but *all* reads of the value permanently.
This failure is also, as far as I can tell, independent of the inter-node
consistency level.
Here's a log of [write number, response, latency] for all 1000 writes:
Run will take 100 seconds
0 :ok 11 ▏
1 :ok 16 ▏
2 :ok 21 ▏
3 :ok 26 ▏
4 :ok 25 ▏
5 :ok 34 ▏
6 :ok 38 ▏
7 :ok 36 ▏
8 :ok 30 ▏
9 :ok 37 ▏
10 :ok 26 ▏
11 :ok 27 ▏
12 :ok 23 ▏
13 :ok 26 ▏
14 :ok 31 ▏
15 :ok 24 ▏
16 :ok 27 ▏
17 :ok 28 ▏
18 :ok 29 ▏
19 :ok 32 ▏
20 :ok 29 ▏
21 :ok 29 ▏
22 :ok 33 ▏
23 :ok 36 ▏
24 :ok 36 ▏
25 :ok 22 ▏
26 :ok 26 ▏
27 :ok 26 ▏
28 :ok 20 ▏
29 :ok 23 ▏
30 :ok 17 ▏
31 :ok 25 ▏
32 :ok 27 ▏
33 :ok 28 ▏
34 :ok 30 ▏
35 :ok 31 ▏
36 :ok 30 ▏
37 :ok 27 ▏
38 :ok 32 ▏
39 :ok 30 ▏
40 :ok 59 ▏
41 :ok 27 ▏
42 :ok 61 ▏
43 :ok 24 ▏
44 :ok 63 ▎
45 :ok 21 ▏
46 :ok 26 ▏
47 :ok 31 ▏
48 :ok 29 ▏
49 :ok 27 ▏
50 :ok 30 ▏
51 :ok 34 ▏
52 :ok 35 ▏
53 :ok 33 ▏
54 :ok 30 ▏
55 :ok 25 ▏
56 :ok 28 ▏
57 :ok 28 ▏
58 :ok 25 ▏
59 :ok 25 ▏
60 :ok 29 ▏
61 :ok 25 ▏
62 :ok 27 ▏
63 :ok 30 ▏
64 :ok 24 ▏
65 :ok 23 ▏
66 :ok 30 ▏
67 :ok 26 ▏
68 :ok 29 ▏
69 :ok 25 ▏
70 :ok 23 ▏
71 :ok 28 ▏
72 :ok 18 ▏
73 :ok 29 ▏
74 :ok 33 ▏
75 :ok 29 ▏
76 :ok 28 ▏
77 :ok 28 ▏
78 :ok 25 ▏
79 :ok 29 ▏
80 :ok 33 ▏
81 :ok 36 ▏
82 :ok 29 ▏
83 :ok 24 ▏
84 :ok 37 ▏
85 :ok 23 ▏
86 :ok 25 ▏
87 :ok 25 ▏
88 :ok 18 ▏
89 :ok 25 ▏
90 :ok 21 ▏
91 :ok 23 ▏
92 :ok 29 ▏
93 :ok 30 ▏
94 :ok 28 ▏
95 :ok 23 ▏
96 :ok 27 ▏
97 :ok 29 ▏
98 :ok 27 ▏
99 :ok 32 ▏
Initiating partition.
100 :ok 41 ▏
101 :ok 26 ▏
102 :ok 30 ▏
103 :ok 41 ▏
104 :ok 35 ▏
105 :ok 20 ▏
106 :ok 24 ▏
107 :ok 23 ▏
108 :ok 17 ▏
109 :ok 24 ▏
Partitioned.
110 :ok 26 ▏
111 :ok 26 ▏
112 :ok 28 ▏
113 :ok 27 ▏
114 :ok 29 ▏
115 :ok 16 ▏
116 :ok 19 ▏
117 :ok 18 ▏
118 :error 10024 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
119 :ok 20 ▏
120 :ok 21 ▏
121 :error 10024 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
122 :ok 24 ▏
123 :ok 24 ▏
124 :ok 23 ▏
125 :ok 21 ▏
126 :ok 23 ▏
127 :ok 26 ▏
128 :ok 26 ▏
129 :ok 24 ▏
130 :ok 19 ▏
131 :ok 17 ▏
132 :ok 18 ▏
133 :ok 19 ▏
134 :ok 15 ▏
135 :ok 19 ▏
136 :ok 22 ▏
137 :ok 23 ▏
138 :ok 23 ▏
139 :ok 23 ▏
140 :ok 20 ▏
141 :ok 25 ▏
142 :error 10017 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
143 :ok 28 ▏
144 :ok 27 ▏
145 :error 10025 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
146 :error 10026 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
147 :error 10015 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
148 :error 10027 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
149 :ok 18 ▏
150 :ok 22 ▏
151 :error 10028 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
152 :ok 22 ▏
153 :ok 21 ▏
154 :ok 19 ▏
155 :ok 23 ▏
156 :error 10025 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
157 :error 10029 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
158 :ok 27 ▏
159 :ok 24 ▏
160 :ok 16 ▏
161 :ok 16 ▏
162 :error 10022 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
163 :ok 19 ▏
164 :ok 21 ▏
165 :ok 20 ▏
166 :ok 19 ▏
167 :error 10021 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
168 :error 10027 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
169 :ok 18 ▏
170 :ok 21 ▏
171 :ok 26 ▏
172 :ok 21 ▏
173 :ok 24 ▏
174 :ok 25 ▏
175 :ok 19 ▏
176 :ok 19 ▏
177 :error 10024 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
178 :ok 18 ▏
179 :ok 19 ▏
180 :ok 18 ▏
181 :ok 20 ▏
182 :error 10023 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
183 :ok 20 ▏
184 :ok 17 ▏
185 :ok 20 ▏
186 :error 10014 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
187 :error 10026 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
188 :ok 21 ▏
189 :error 10024 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
190 :error 10024 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
191 :ok 19 ▏
192 :ok 17 ▏
193 :ok 20 ▏
194 :ok 18 ▏
195 :ok 21 ▏
196 :ok 21 ▏
197 :ok 21 ▏
198 :ok 19 ▏
199 :ok 18 ▏
200 :ok 22 ▏
201 :ok 27 ▏
202 :ok 26 ▏
203 :ok 24 ▏
204 :ok 23 ▏
205 :ok 16 ▏
206 :ok 20 ▏
207 :ok 22 ▏
208 :ok 19 ▏
209 :ok 21 ▏
210 :ok 17 ▏
211 :ok 14 ▏
212 :ok 14 ▏
213 :ok 14 ▏
214 :ok 14 ▏
215 :ok 40 ▏
216 :ok 38 ▏
217 :ok 34 ▏
218 :ok 38 ▏
219 :ok 38 ▏
220 :error 10027 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
221 :ok 21 ▏
222 :ok 20 ▏
223 :ok 16 ▏
224 :ok 19 ▏
225 :ok 20 ▏
226 :ok 22 ▏
227 :ok 25 ▏
228 :ok 19 ▏
229 :ok 24 ▏
230 :ok 27 ▏
231 :ok 23 ▏
232 :ok 25 ▏
233 :ok 23 ▏
234 :ok 22 ▏
235 :error 10022 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
236 :ok 18 ▏
237 :ok 16 ▏
238 :ok 16 ▏
239 :ok 19 ▏
240 :ok 20 ▏
241 :ok 26 ▏
242 :ok 28 ▏
243 :ok 20 ▏
244 :ok 23 ▏
245 :error 10022 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
246 :error 10033 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
247 :ok 5083 ██████████▎
248 :ok 5211 ██████████▌
249 :ok 5210 ██████████▌
250 :error 10025 ████████████████████▏
Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.exceptions.WriteTimeoutException.copy (WriteTimeoutException.java:54)
com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException (ResultSetFuture.java:214)
com.datastax.driver.core.ResultSetFuture.getUninterruptibly (ResultSetFuture.java:169)
clojurewerkz.cassaforte.client$execute.doInvoke (client.clj:289)
clojure.lang.RestFn.invoke (RestFn.java:457)
jepsen.cassandra$isolation_app$reify__2559$fn__2560.invoke (cassandra.clj:186)
jepsen.cassandra$isolation_app$reify__2559.add (cassandra.clj:177)
jepsen.set_app$eval2420$fn__2443$G__2410__2446.invoke (set_app.clj:11)
jepsen.set_app$eval2420$fn__2443$G__2409__2450.invoke (set_app.clj:11)
clojure.lang.AFn.applyToHelper (AFn.java:163)
clojure.lang.AFn.applyTo (AFn.java:151)
clojure.core$apply.invoke (core.clj:619)
clojure.core$partial$fn__4190.doInvoke (core.clj:2396)
clojure.lang.RestFn.invoke (RestFn.java:408)
jepsen.load$wrap_catch$catcher__2389.invoke (load.clj:110)
jepsen.load$wrap_latency$measure_latency__2386.invoke (load.clj:100)
jepsen.load$wrap_record_req$record_req__2398.invoke (load.clj:129)
jepsen.console$wrap_ordered_log$logger__2346.invoke (console.clj:108)
jepsen.load$map_fixed_rate$boss__2379$fn__2381.invoke (load.clj:65)
clojure.lang.AFn.run (AFn.java:24)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
Caused by: com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during write query at consistency ANY (1 replica were required but only 0 acknowledged the write)
at com.datastax.driver.core.ResultSetFuture.convertException (ResultSetFuture.java:243)
com.datastax.driver.core.ResultSetFuture$ResponseCallback.onSet (ResultSetFuture.java:119)
com.datastax.driver.core.RequestHandler.setFinalResult (RequestHandler.java:202)
com.datastax.driver.core.RequestHandler.onSet (RequestHandler.java:331)
com.datastax.driver.core.Connection$Dispatcher.messageReceived (Connection.java:484)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream (OneToOneDecoder.java:68)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream (DefaultChannelPipeline.java:787)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:296)
org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived (FrameDecoder.java:462)
org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode (FrameDecoder.java:443)
org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived (FrameDecoder.java:303)
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream (SimpleChannelUpstreamHandler.java:70)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:560)
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream (DefaultChannelPipeline.java:555)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:268)
org.jboss.netty.channel.Channels.fireMessageReceived (Channels.java:255)
org.jboss.netty.channel.socket.nio.NioWorker.read (NioWorker.java:88)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.process (AbstractNioWorker.java:107)
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run (AbstractNioSelector.java:312)
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run (AbstractNioWorker.java:88)
org.jboss.netty.channel.socket.nio.NioWorker.run (NioWorker.java:178)
org.jboss.netty.util.ThreadRenamingRunnable.run (ThreadRenamingRunnable.java:108)
org.jboss.netty.util.internal.DeadLockProofWorker$1.run (DeadLockProofWorker.java:42)
java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:615)
java.lang.Thread.run (Thread.java:722)
251 :ok 15 ▏
252 :ok 4585 █████████▎
253 :ok 20 ▏
254 :ok 17 ▏
255 :ok 24 ▏
256 :ok 18 ▏
257 :ok 16 ▏
258 :ok 19 ▏
259 :ok 20 ▏
260 :ok 26 ▏
261 :ok 22 ▏
262 :ok 22 ▏
263 :ok 24 ▏
264 :ok 2728 █████▌
265 :ok 19 ▏
266 :ok 14 ▏
267 :ok 15 ▏
268 :ok 3212 ██████▌
269 :ok 2221 ████▌
270 :ok 23 ▏
271 :ok 21 ▏
272 :ok 2582 █████▎
273 :ok 24 ▏
274 :ok 23 ▏
275 :ok 22 ▏
276 :ok 22 ▏
277 :ok 26 ▏
278 :ok 29 ▏
279 :ok 25 ▏
280 :ok 19 ▏
281 :ok 18 ▏
282 :ok 16 ▏
283 :ok 724 █▌
284 :ok 18 ▏
285 :ok 27 ▏
286 :ok 23 ▏
287 :ok 25 ▏
288 :ok 24 ▏
289 :ok 23 ▏
290 :ok 29 ▏
291 :ok 29 ▏
292 :ok 25 ▏
293 :ok 32 ▏
294 :ok 33 ▏
295 :ok 20 ▏
296 :ok 19 ▏
297 :ok 20 ▏
298 :ok 19 ▏
299 :ok 22 ▏
300 :ok 22 ▏
301 :ok 24 ▏
302 :ok 24 ▏
303 :ok 24 ▏
304 :ok 23 ▏
305 :ok 25 ▏
306 :ok 24 ▏
307 :ok 26 ▏
308 :ok 23 ▏
309 :ok 23 ▏
310 :ok 18 ▏
311 :ok 16 ▏
312 :ok 19 ▏
313 :ok 18 ▏
314 :ok 20 ▏
315 :ok 19 ▏
316 :ok 19 ▏
317 :ok 19 ▏
318 :ok 18 ▏
319 :ok 20 ▏
320 :ok 29 ▏
321 :ok 29 ▏
322 :ok 26 ▏
323 :ok 20 ▏
324 :ok 27 ▏
325 :ok 20 ▏
326 :ok 19 ▏
327 :ok 20 ▏
328 :ok 17 ▏
329 :ok 17 ▏
330 :ok 18 ▏
331 :ok 22 ▏
332 :ok 22 ▏
333 :ok 18 ▏
334 :ok 23 ▏
335 :ok 29 ▏
336 :ok 29 ▏
337 :ok 32 ▏
338 :ok 25 ▏
339 :ok 24 ▏
340 :ok 19 ▏
341 :ok 19 ▏
342 :ok 21 ▏
343 :ok 17 ▏
344 :ok 19 ▏
345 :ok 23 ▏
346 :ok 24 ▏
347 :ok 26 ▏
348 :ok 21 ▏
349 :ok 19 ▏
350 :ok 28 ▏
351 :ok 34 ▏
352 :ok 29 ▏
353 :ok 24 ▏
354 :ok 35 ▏
355 :ok 22 ▏
356 :ok 22 ▏
357 :ok 21 ▏
358 :ok 17 ▏
359 :ok 19 ▏
360 :ok 27 ▏
361 :ok 28 ▏
362 :ok 26 ▏
363 :ok 21 ▏
364 :ok 23 ▏
365 :ok 19 ▏
366 :ok 25 ▏
367 :ok 21 ▏
368 :ok 20 ▏
369 :ok 22 ▏
370 :ok 25 ▏
371 :ok 30 ▏
372 :ok 30 ▏
373 :ok 28 ▏
374 :ok 25 ▏
375 :ok 21 ▏
376 :ok 19 ▏
377 :ok 25 ▏
378 :ok 22 ▏
379 :ok 21 ▏
380 :ok 32 ▏
381 :ok 31 ▏
382 :ok 32 ▏
383 :ok 31 ▏
384 :ok 27 ▏
385 :ok 20 ▏
386 :ok 16 ▏
387 :ok 17 ▏
388 :ok 15 ▏
389 :ok 15 ▏
390 :ok 19 ▏
391 :ok 24 ▏
392 :ok 24 ▏
393 :ok 19 ▏
394 :ok 18 ▏
395 :ok 23 ▏
396 :ok 23 ▏
397 :ok 25 ▏
398 :ok 25 ▏
399 :ok 24 ▏
400 :ok 17 ▏
401 :ok 20 ▏
402 :ok 17 ▏
403 :ok 18 ▏
404 :ok 14 ▏
405 :ok 18 ▏
406 :ok 19 ▏
407 :ok 20 ▏
408 :ok 23 ▏
409 :ok 21 ▏
410 :ok 18 ▏
411 :ok 20 ▏
412 :ok 24 ▏
413 :ok 23 ▏
414 :ok 24 ▏
415 :ok 18 ▏
416 :ok 19 ▏
417 :ok 15 ▏
418 :ok 16 ▏
419 :ok 18 ▏
420 :ok 19 ▏
421 :ok 22 ▏
422 :ok 22 ▏
423 :ok 17 ▏
424 :ok 23 ▏
425 :ok 24 ▏
426 :ok 22 ▏
427 :ok 25 ▏
428 :ok 21 ▏
429 :ok 21 ▏
430 :ok 18 ▏
431 :ok 17 ▏
432 :ok 19 ▏
433 :ok 14 ▏
434 :ok 20 ▏
435 :ok 21 ▏
436 :ok 20 ▏
437 :ok 18 ▏
438 :ok 19 ▏
439 :ok 18 ▏
440 :ok 61 ▏
441 :ok 21 ▏
442 :ok 60 ▏
443 :ok 63 ▎
444 :ok 62 ▏
445 :ok 23 ▏
446 :ok 25 ▏
447 :ok 24 ▏
448 :ok 22 ▏
449 :ok 20 ▏
450 :ok 18 ▏
451 :ok 18 ▏
452 :ok 24 ▏
453 :ok 21 ▏
454 :ok 19 ▏
455 :ok 24 ▏
456 :ok 25 ▏
457 :ok 27 ▏
458 :ok 22 ▏
459 :ok 22 ▏
460 :ok 15 ▏
461 :ok 14 ▏
462 :ok 17 ▏
463 :ok 18 ▏
464 :ok 21 ▏
465 :ok 19 ▏
466 :ok 21 ▏
467 :ok 22 ▏
468 :ok 19 ▏
469 :ok 22 ▏
470 :ok 21 ▏
471 :ok 19 ▏
472 :ok 26 ▏
473 :ok 21 ▏
474 :ok 22 ▏
475 :ok 18 ▏
476 :ok 17 ▏
477 :ok 20 ▏
478 :ok 20 ▏
479 :ok 21 ▏
480 :ok 19 ▏
481 :ok 23 ▏
482 :ok 21 ▏
483 :ok 19 ▏
484 :ok 23 ▏
485 :ok 28 ▏
486 :ok 23 ▏
487 :ok 29 ▏
488 :ok 22 ▏
489 :ok 25 ▏
490 :ok 14 ▏
491 :ok 20 ▏
492 :ok 20 ▏
493 :ok 14 ▏
494 :ok 19 ▏
495 :ok 22 ▏
496 :ok 21 ▏
497 :ok 19 ▏
498 :ok 17 ▏
499 :ok 21 ▏
500 :ok 23 ▏
501 :ok 21 ▏
502 :ok 22 ▏
503 :ok 25 ▏
504 :ok 22 ▏
505 :ok 20 ▏
506 :ok 20 ▏
507 :ok 21 ▏
508 :ok 17 ▏
509 :ok 19 ▏
510 :ok 29 ▏
511 :ok 35 ▏
512 :ok 26 ▏
513 :ok 34 ▏
514 :ok 60 ▏
Partition healed.
515 :ok 23 ▏
516 :ok 22 ▏
517 :ok 27 ▏
518 :ok 25 ▏
519 :ok 21 ▏
520 :ok 18 ▏
521 :ok 19 ▏
522 :ok 19 ▏
523 :ok 13 ▏
524 :ok 18 ▏
525 :ok 19 ▏
526 :ok 25 ▏
527 :ok 24 ▏
528 :ok 22 ▏
529 :ok 23 ▏
530 :ok 16 ▏
531 :ok 18 ▏
532 :ok 18 ▏
533 :ok 14 ▏
534 :ok 17 ▏
535 :ok 15 ▏
536 :ok 13 ▏
537 :ok 19 ▏
538 :ok 15 ▏
539 :ok 13 ▏
540 :ok 22 ▏
541 :ok 18 ▏
542 :ok 20 ▏
543 :ok 22 ▏
544 :ok 15 ▏
545 :ok 21 ▏
546 :ok 24 ▏
547 :ok 24 ▏
548 :ok 23 ▏
549 :ok 21 ▏
550 :ok 17 ▏
551 :ok 20 ▏
552 :ok 19 ▏
553 :ok 18 ▏
554 :ok 19 ▏
555 :ok 19 ▏
556 :ok 19 ▏
557 :ok 23 ▏
558 :ok 20 ▏
559 :ok 19 ▏
560 :ok 25 ▏
561 :ok 24 ▏
562 :ok 22 ▏
563 :ok 22 ▏
564 :ok 23 ▏
565 :ok 18 ▏
566 :ok 16 ▏
567 :ok 22 ▏
568 :ok 16 ▏
569 :ok 20 ▏
570 :ok 23 ▏
571 :ok 24 ▏
572 :ok 19 ▏
573 :ok 23 ▏
574 :ok 21 ▏
575 :ok 24 ▏
576 :ok 20 ▏
577 :ok 25 ▏
578 :ok 25 ▏
579 :ok 25 ▏
580 :ok 21 ▏
581 :ok 28 ▏
582 :ok 24 ▏
583 :ok 22 ▏
584 :ok 20 ▏
585 :ok 18 ▏
586 :ok 21 ▏
587 :ok 21 ▏
588 :ok 21 ▏
589 :ok 22 ▏
590 :ok 18 ▏
591 :ok 23 ▏
592 :ok 26 ▏
593 :ok 25 ▏
594 :ok 22 ▏
595 :ok 18 ▏
596 :ok 17 ▏
597 :ok 16 ▏
598 :ok 19 ▏
599 :ok 18 ▏
600 :ok 22 ▏
601 :ok 23 ▏
602 :ok 21 ▏
603 :ok 18 ▏
604 :ok 22 ▏
605 :ok 19 ▏
606 :ok 20 ▏
607 :ok 24 ▏
608 :ok 22 ▏
609 :ok 22 ▏
610 :ok 28 ▏
611 :ok 27 ▏
612 :ok 76 ▎
613 :ok 41 ▏
614 :ok 32 ▏
615 :ok 54 ▏
616 :ok 22 ▏
617 :ok 29 ▏
618 :ok 27 ▏
619 :ok 55 ▏
620 :ok 15 ▏
621 :ok 16 ▏
622 :ok 19 ▏
623 :ok 26 ▏
624 :ok 12 ▏
625 :ok 15 ▏
626 :ok 15 ▏
627 :ok 3242 ██████▌
628 :ok 13 ▏
629 :ok 271 ▋
630 :ok 24 ▏
631 :ok 23 ▏
632 :ok 24 ▏
633 :ok 2745 █████▌
634 :ok 21 ▏
635 :ok 16 ▏
636 :ok 18 ▏
637 :ok 14 ▏
638 :ok 11 ▏
639 :ok 2255 ████▋
640 :ok 25 ▏
641 :ok 51 ▏
642 :ok 53 ▏
643 :ok 1742 ███▌
644 :ok 23 ▏
645 :ok 16 ▏
646 :ok 1253 ██▋
647 :ok 24 ▏
648 :ok 23 ▏
649 :ok 26 ▏
650 :ok 24 ▏
651 :ok 22 ▏
652 :ok 23 ▏
653 :ok 24 ▏
654 :ok 24 ▏
655 :ok 17 ▏
656 :ok 13 ▏
657 :ok 17 ▏
658 :ok 16 ▏
659 :ok 15 ▏
660 :ok 17 ▏
661 :ok 22 ▏
662 :ok 22 ▏
663 :ok 20 ▏
664 :ok 19 ▏
665 :ok 44 ▏
666 :ok 41 ▏
667 :ok 41 ▏
668 :ok 15 ▏
669 :ok 44 ▏
670 :ok 18 ▏
671 :ok 20 ▏
672 :ok 16 ▏
673 :ok 14 ▏
674 :ok 15 ▏
675 :ok 23 ▏
676 :ok 19 ▏
677 :ok 20 ▏
678 :ok 21 ▏
679 :ok 24 ▏
680 :ok 21 ▏
681 :ok 24 ▏
682 :ok 25 ▏
683 :ok 24 ▏
684 :ok 23 ▏
685 :ok 22 ▏
686 :ok 21 ▏
687 :ok 18 ▏
688 :ok 15 ▏
689 :ok 18 ▏
690 :ok 20 ▏
691 :ok 19 ▏
692 :ok 23 ▏
693 :ok 22 ▏
694 :ok 22 ▏
695 :ok 24 ▏
696 :ok 24 ▏
697 :ok 26 ▏
698 :ok 27 ▏
699 :ok 26 ▏
700 :ok 20 ▏
701 :ok 20 ▏
702 :ok 21 ▏
703 :ok 17 ▏
704 :ok 19 ▏
705 :ok 21 ▏
706 :ok 26 ▏
707 :ok 23 ▏
708 :ok 23 ▏
709 :ok 17 ▏
710 :ok 21 ▏
711 :ok 22 ▏
712 :ok 26 ▏
713 :ok 26 ▏
714 :ok 28 ▏
715 :ok 16 ▏
716 :ok 20 ▏
717 :ok 22 ▏
718 :ok 18 ▏
719 :ok 20 ▏
720 :ok 23 ▏
721 :ok 26 ▏
722 :ok 24 ▏
723 :ok 28 ▏
724 :ok 27 ▏
725 :ok 25 ▏
726 :ok 23 ▏
727 :ok 24 ▏
728 :ok 19 ▏
729 :ok 28 ▏
730 :ok 18 ▏
731 :ok 16 ▏
732 :ok 21 ▏
733 :ok 16 ▏
734 :ok 15 ▏
735 :ok 22 ▏
736 :ok 23 ▏
737 :ok 23 ▏
738 :ok 19 ▏
739 :ok 20 ▏
740 :ok 19 ▏
741 :ok 24 ▏
742 :ok 22 ▏
743 :ok 21 ▏
744 :ok 24 ▏
745 :ok 19 ▏
746 :ok 18 ▏
747 :ok 16 ▏
748 :ok 19 ▏
749 :ok 15 ▏
750 :ok 21 ▏
751 :ok 19 ▏
752 :ok 21 ▏
753 :ok 17 ▏
754 :ok 21 ▏
755 :ok 21 ▏
756 :ok 25 ▏
757 :ok 23 ▏
758 :ok 23 ▏
759 :ok 19 ▏
760 :ok 20 ▏
761 :ok 20 ▏
762 :ok 15 ▏
763 :ok 21 ▏
764 :ok 21 ▏
765 :ok 24 ▏
766 :ok 27 ▏
767 :ok 26 ▏
768 :ok 21 ▏
769 :ok 28 ▏
770 :ok 23 ▏
771 :ok 24 ▏
772 :ok 26 ▏
773 :ok 24 ▏
774 :ok 23 ▏
775 :ok 28 ▏
776 :ok 29 ▏
777 :ok 30 ▏
778 :ok 24 ▏
779 :ok 24 ▏
780 :ok 22 ▏
781 :ok 22 ▏
782 :ok 24 ▏
783 :ok 22 ▏
784 :ok 18 ▏
785 :ok 23 ▏
786 :ok 24 ▏
787 :ok 23 ▏
788 :ok 23 ▏
789 :ok 26 ▏
790 :ok 17 ▏
791 :ok 21 ▏
792 :ok 60 ▏
793 :ok 14 ▏
794 :ok 21 ▏
795 :ok 19 ▏
796 :ok 17 ▏
797 :ok 19 ▏
798 :ok 21 ▏
799 :ok 20 ▏
800 :ok 25 ▏
801 :ok 26 ▏
802 :ok 27 ▏
803 :ok 23 ▏
804 :ok 23 ▏
805 :ok 20 ▏
806 :ok 19 ▏
807 :ok 17 ▏
808 :ok 18 ▏
809 :ok 17 ▏
810 :ok 20 ▏
811 :ok 24 ▏
812 :ok 18 ▏
813 :ok 19 ▏
814 :ok 23 ▏
815 :ok 23 ▏
816 :ok 24 ▏
817 :ok 27 ▏
818 :ok 20 ▏
819 :ok 22 ▏
820 :ok 18 ▏
821 :ok 21 ▏
822 :ok 21 ▏
823 :ok 21 ▏
824 :ok 15 ▏
825 :ok 20 ▏
826 :ok 21 ▏
827 :ok 21 ▏
828 :ok 22 ▏
829 :ok 24 ▏
830 :ok 25 ▏
831 :ok 25 ▏
832 :ok 26 ▏
833 :ok 19 ▏
834 :ok 21 ▏
835 :ok 20 ▏
836 :ok 21 ▏
837 :ok 21 ▏
838 :ok 25 ▏
839 :ok 24 ▏
840 :ok 63 ▎
841 :ok 64 ▎
842 :ok 65 ▎
843 :ok 18 ▏
844 :ok 21 ▏
845 :ok 24 ▏
846 :ok 25 ▏
847 :ok 24 ▏
848 :ok 26 ▏
849 :ok 27 ▏
850 :ok 16 ▏
851 :ok 19 ▏
852 :ok 17 ▏
853 :ok 20 ▏
854 :ok 19 ▏
855 :ok 24 ▏
856 :ok 24 ▏
857 :ok 24 ▏
858 :ok 23 ▏
859 :ok 21 ▏
860 :ok 25 ▏
861 :ok 23 ▏
862 :ok 27 ▏
863 :ok 26 ▏
864 :ok 25 ▏
865 :ok 18 ▏
866 :ok 20 ▏
867 :ok 20 ▏
868 :ok 16 ▏
869 :ok 16 ▏
870 :ok 19 ▏
871 :ok 23 ▏
872 :ok 24 ▏
873 :ok 22 ▏
874 :ok 20 ▏
875 :ok 21 ▏
876 :ok 27 ▏
877 :ok 25 ▏
878 :ok 21 ▏
879 :ok 24 ▏
880 :ok 22 ▏
881 :ok 20 ▏
882 :ok 17 ▏
883 :ok 18 ▏
884 :ok 18 ▏
885 :ok 22 ▏
886 :ok 22 ▏
887 :ok 21 ▏
888 :ok 21 ▏
889 :ok 21 ▏
890 :ok 25 ▏
891 :ok 26 ▏
892 :ok 25 ▏
893 :ok 24 ▏
894 :ok 24 ▏
895 :ok 21 ▏
896 :ok 26 ▏
897 :ok 20 ▏
898 :ok 23 ▏
899 :ok 18 ▏
900 :ok 22 ▏
901 :ok 19 ▏
902 :ok 19 ▏
903 :ok 15 ▏
904 :ok 18 ▏
905 :ok 22 ▏
906 :ok 24 ▏
907 :ok 25 ▏
908 :ok 27 ▏
909 :ok 24 ▏
910 :ok 16 ▏
911 :ok 19 ▏
912 :ok 17 ▏
913 :ok 19 ▏
914 :ok 20 ▏
915 :ok 20 ▏
916 :ok 22 ▏
917 :ok 22 ▏
918 :ok 16 ▏
919 :ok 19 ▏
920 :ok 27 ▏
921 :ok 26 ▏
922 :ok 26 ▏
923 :ok 26 ▏
924 :ok 22 ▏
925 :ok 17 ▏
926 :ok 18 ▏
927 :ok 18 ▏
928 :ok 18 ▏
929 :ok 17 ▏
930 :ok 21 ▏
931 :ok 19 ▏
932 :ok 23 ▏
933 :ok 19 ▏
934 :ok 22 ▏
935 :ok 24 ▏
936 :ok 21 ▏
937 :ok 25 ▏
938 :ok 19 ▏
939 :ok 20 ▏
940 :ok 19 ▏
941 :ok 15 ▏
942 :ok 19 ▏
943 :ok 19 ▏
944 :ok 19 ▏
945 :ok 20 ▏
946 :ok 24 ▏
947 :ok 24 ▏
948 :ok 21 ▏
949 :ok 22 ▏
950 :ok 20 ▏
951 :ok 23 ▏
952 :ok 26 ▏
953 :ok 26 ▏
954 :ok 18 ▏
955 :ok 18 ▏
956 :ok 16 ▏
957 :ok 21 ▏
958 :ok 16 ▏
959 :ok 13 ▏
960 :ok 21 ▏
961 :ok 19 ▏
962 :ok 22 ▏
963 :ok 19 ▏
964 :ok 23 ▏
965 :ok 24 ▏
966 :ok 28 ▏
967 :ok 24 ▏
968 :ok 24 ▏
969 :ok 25 ▏
970 :ok 15 ▏
971 :ok 10 ▏
972 :ok 12 ▏
973 :ok 18 ▏
974 :ok 13 ▏
975 :ok 20 ▏
976 :ok 21 ▏
977 :ok 20 ▏
978 :ok 20 ▏
979 :ok 20 ▏
980 :ok 18 ▏
981 :ok 18 ▏
982 :ok 20 ▏
983 :ok 15 ▏
984 :ok 19 ▏
985 :ok 19 ▏
986 :ok 19 ▏
987 :ok 21 ▏
988 :ok 20 ▏
989 :ok 19 ▏
990 :ok 21 ▏
991 :ok 25 ▏
992 :ok 23 ▏
993 :ok 19 ▏
994 :ok 23 ▏
995 :ok 22 ▏
996 :ok 23 ▏
997 :ok 24 ▏
998 :ok 27 ▏
999 :ok 26 ▏
0 unrecoverable timeouts
Collecting results.
Here's the set of writes for which a != -b; e.g. row isolation did not hold:
({:id 114, :a 1570376346, :b -812690858} {:id 55, :a 1706671853, :b -809618844} {:id 324, :a 1570376346, :b -809618844} {:id 380, :a 1706671853, :b -809618844} {:id 857, :a 1570376346, :b -436112969} {:id 914, :a 1570376346, :b -812690858} {:id 780, :a 1706671853, :b -809618844} {:id 185, :a 812690858, :b -809618844} {:id 369, :a 812690858, :b -809618844} {:id 959, :a 812690858, :b -809618844} {:id 323, :a 1570376346, :b -812690858} {:id 514, :a 812690858, :b -809618844} {:id 467, :a 1570376346, :b -436112969} {:id 398, :a 1570376346, :b -812690858} {:id 414, :a 1570376346, :b -809618844} {:id 500, :a 1706671853, :b -809618844} {:id 570, :a 1706671853, :b -809618844} {:id 883, :a 1570376346, :b -812690858} {:id 835, :a 1706671853, :b -809618844} {:id 864, :a 812690858, :b -809618844} {:id 113, :a 1570376346, :b -812690858} {:id 390, :a 1706671853, :b -812690858} {:id 280, :a 1706671853, :b -809618844} {:id 344, :a 812690858, :b -809618844} {:id 257, :a 1570376346, :b -436112969} {:id 0, :a 1706671853, :b -809618844} {:id 512, :a 1570376346, :b -436112969} {:id 440, :a 1706671853, :b -809618844} {:id 697, :a 1570376346, :b -436112969} {:id 667, :a 1570376346, :b -436112969} {:id 84, :a 812690858, :b -809618844} {:id 403, :a 1570376346, :b -812690858} {:id 74, :a 812690858, :b -809618844} {:id 345, :a 1706671853, :b -809618844} {:id 372, :a 1570376346, :b -436112969} {:id 492, :a 1570376346, :b -436112969} {:id 833, :a 1570376346, :b -812690858} {:id 555, :a 1706671853, :b -812690858} {:id 775, :a 1706671853, :b -812690858} {:id 827, :a 1570376346, :b -436112969} {:id 809, :a 1570376346, :b -809618844} {:id 575, :a 1706671853, :b -809618844} {:id 742, :a 1570376346, :b -436112969} {:id 584, :a 812690858, :b -809618844} {:id 198, :a 1570376346, :b -812690858} {:id 545, :a 1706671853, :b -809618844} {:id 996, :a 1706671853, :b -809618844} {:id 494, :a 812690858, :b -436112969} {:id 442, :a 1570376346, :b -436112969} {:id 524, :a 812690858, :b -809618844} {:id 405, :a 1706671853, :b -809618844} {:id 977, :a 1570376346, :b -436112969} {:id 258, :a 1570376346, :b -812690858} {:id 349, :a 812690858, :b -809618844} {:id 683, :a 812690858, :b -436112969} {:id 180, :a 1706671853, :b -809618844} {:id 127, :a 1570376346, :b -436112969} {:id 699, :a 812690858, :b -809618844} {:id 629, :a 812690858, :b -809618844} {:id 604, :a 812690858, :b -809618844} {:id 175, :a 1706671853, :b -812690858} {:id 589, :a 812690858, :b -809618844} {:id 995, :a 1706671853, :b -809618844} {:id 329, :a 812690858, :b -809618844} {:id 470, :a 1706671853, :b -809618844} {:id 318, :a 1570376346, :b -812690858} {:id 784, :a 812690858, :b -809618844} {:id 789, :a 1570376346, :b -809618844} {:id 805, :a 1706671853, :b -809618844} {:id 680, :a 1706671853, :b -809618844} {:id 734, :a 1570376346, :b -809618844} {:id 989, :a 1570376346, :b -812690858} {:id 422, :a 1570376346, :b -436112969} {:id 275, :a 1706671853, :b -809618844})
Writes completed in 100.04 seconds
1000 total
976 acknowledged
926 survivors
74 acknowledged writes lost! (╯°□°)╯︵ ┻━┻
0 55 74 84 113 114 ... 914 959 977 989 995 996
24 unacknowledged writes found! ヽ(´ー`)ノ
118 121 142 145 146 147 ... 190 220 235 245 246 250
0.976 ack rate
0.07581967 loss rate
0.024590164 unacknowledged but successful rate
(defn isolation-app
"This app tests whether or not it is possible to consistently update multiple
cells in a row, such that either *both* writes are visible together, or
*neither* is.
Each client picks a random int identifier to distinguish itself from the
other clients. It tries to write this identifier to cell A, and -identifier
to cell B. The write is considered successful if A=-B. It is unsuccessful if
A is *not* equal to -B; e.g. our updates were not isolated.
'concurrency defines the number of writes made to each row. At concurrency 5,
element 10 results in writes to rows 10, 9, 8, 7, and 6."
[opts]
(let [table "isolation_app"
concurrency 5
client-id (rand-int Integer/MAX_VALUE)
cluster (client/build-cluster {:contact-points [(:host opts)]
:port 9042})
session (client/connect cluster)]
(reify SetApp
(setup [app]
(teardown app)
(ensure-keyspace session)
(cql/create-table session table
(column-definitions {:id :int
:a :int
:b :int
:primary-key [:id]})))
(add [app element]
(client/with-consistency-level ConsistencyLevel/ANY
(dotimes [i concurrency]
(let [e (- element i)]
(when (<= 0 e)
(client/execute
session
(->> (insert-query table
{:id e
:a client-id
:b (- client-id)})
; If you force timestamp collisions instead of letting
; them happen naturally, you can reliably cause
; conflicts in 99% of rows! :D
; (using :timestamp 1)
queries
batch-query
client/render-query)
:prepared qbits.hayt.cql/*prepared-statement*)))))
ok)
(results [app]
(client/with-consistency-level ConsistencyLevel/ALL
(->> (cql/select session table)
(remove #(= (:a %) (- (:b %))))
prn
dorun)
(->> (cql/select session table)
(filter #(= (:a %) (- (:b %))))
(map :id))))
(teardown [app]
(drop-keyspace session)))))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment