[
https://issues.apache.org/jira/browse/CASSANDRA-19346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ekaterina Dimitrova updated CASSANDRA-19346:
--------------------------------------------
Fix Version/s: 5.x
> 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
> Components: CI
> Reporter: Ekaterina Dimitrova
> Priority: Normal
> Fix For: 5.x
>
>
> {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
