Ekaterina Dimitrova created CASSANDRA-19346:
-----------------------------------------------
Summary: Test Failure:
counter_test.TestCounters.test_counter_node_down
Key: CASSANDRA-19346
URL: https://issues.apache.org/jira/browse/CASSANDRA-19346
Project: Cassandra
Issue Type: Bug
Reporter: Ekaterina Dimitrova
{code:java}
self = <counter_test.TestCounters object at 0x7f7f1bc565b0>
def test_counter_node_down(self):
"""
@jira_ticket CASSANDRA-17411
"""
cluster = self.cluster
cluster.populate(3).start()
node1, node2, node3 = cluster.nodelist()
session = self.patient_cql_connection(node1)
create_ks(session, 'counter_tests', 3)
session.execute("""
CREATE TABLE IF NOT EXISTS counter_cs (
key text PRIMARY KEY,
count counter
)
""")
node2.stop(gently=False, wait_other_notice=True)
for _ in range(0, 20):
> session.execute("UPDATE counter_cs SET count = count + 1 WHERE key
> = 'test'")
counter_test.py:447:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
../env3.8/src/cassandra-driver/cassandra/cluster.py:2618: in execute
return self.execute_async(query, parameters, trace, custom_payload,
timeout, execution_profile, paging_state, host, execute_as).result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <ResponseFuture: query='<SimpleStatement query="UPDATE counter_cs SET
count = count + 1 WHERE key = 'test'", consisten...cy': 'ONE',
'required_responses': 1, 'received_responses': 0, 'write_type': 'COUNTER'}
coordinator_host=127.0.0.1:9042>
def result(self):
"""
Return the final result or raise an Exception if errors were
encountered. If the final result or error has not been set
yet, this method will block until it is set, or the timeout
set for the request expires.
Timeout is specified in the Session request execution functions.
If the timeout is exceeded, an :exc:`cassandra.OperationTimedOut` will
be raised.
This is a client-side timeout. For more information
about server-side coordinator timeouts, see
:class:`.policies.RetryPolicy`.
Example usage::
>>> future = session.execute_async("SELECT * FROM mycf")
>>> # do other stuff...
>>> try:
... rows = future.result()
... for row in rows:
... ... # process results
... except Exception:
... log.exception("Operation failed:")
"""
self._event.wait()
if self._final_result is not _NOT_SET:
return ResultSet(self, self._final_result)
else:
> raise self._final_exception
E cassandra.WriteTimeout: Error from server: code=1100 [Coordinator
node timed out waiting for replica nodes' responses] message="Operation timed
out - received 0/1 responses." info={'consistency': 'ONE',
'required_responses': 1, 'received_responses': 0, 'write_type': 'COUNTER'}
../env3.8/src/cassandra-driver/cassandra/cluster.py:4894: WriteTimeout
{code}
as seen here:
https://app.circleci.com/pipelines/github/ekaterinadimitrova2/cassandra/2640/workflows/f13c3f3d-b1ad-4f8c-b110-e5b36f19a393/jobs/55253/tests#failed-test-0
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
