[
https://issues.apache.org/jira/browse/CASSANDRA-19145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818023#comment-17818023
]
Ekaterina Dimitrova commented on CASSANDRA-19145:
-------------------------------------------------
I rebased my latest repo and reinstalled ccm to pull the latest changes from
CASSANDRA-18753.
Current 5.0 locally with this command:
{code:java}
pytest --use-vnodes --log-cli-level="DEBUG"
write_failures_test.py::TestWriteFailures::test_paxos
--cassandra-dir=/Users/ekaterina.dimitrova/cassandra{code}
the test passes, but it shows from the logs this error:
{code:java}
==============================================================================================================
short test summary info
==============================================================================================================
ERROR write_failures_test.py::TestWriteFailures::test_paxos - Failed:
Unexpected error found in node logs (see stdout for full details). Errors:
[[node1] 'ERROR [Messaging-EventLoop-3-4] 2024-02-16 10:58:43,050
NoSpamLogger.java:110 -
/127.0.0.1:7000->/127.0.0.2:7000-URGENT_MESSAGES-[no-channel] faile...
{code}
The reported issue reproduces with 5.0 branch and changing to paxos v2 only in
the default yaml config:
{code:java}
___________________________________________________________________________________________________________
TestWriteFailures.test_paxos
____________________________________________________________________________________________________________
self = <write_failures_test.TestWriteFailures object at 0x1078e3220>
def test_paxos(self):
"""
A light transaction receives a WriteFailure
"""
> exc = self._perform_cql_statement("INSERT INTO mytable (key, value)
> VALUES ('key1', 'Value 1') IF NOT EXISTS")
write_failures_test.py:202:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
write_failures_test.py:88: in _perform_cql_statement
session.execute(statement)
cassandra/cluster.py:2618: in cassandra.cluster.Session.execute
???
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
> ???
E cassandra.WriteTimeout: Error from server: code=1100 [Coordinator node
timed out waiting for replica nodes' responses] message="CAS operation timed
out: received 1 of 2 required responses after 0 contention retries"
info={'consistency': 'SERIAL', 'required_responses': 2, 'received_responses':
1, 'write_type': 'CAS'}
cassandra/cluster.py:4894: WriteTimeout
{code}
> Python dtest TestWriteFailures.test_paxos is failing with Paxos V2
> ------------------------------------------------------------------
>
> Key: CASSANDRA-19145
> URL: https://issues.apache.org/jira/browse/CASSANDRA-19145
> Project: Cassandra
> Issue Type: Bug
> Components: Feature/Lightweight Transactions
> Reporter: Branimir Lambov
> Priority: Normal
>
> With configuration changed to engage Paxos V2 with repaired state purging,
> the dtest fails with:
> {code}
> test_paxos
> write_failures_test.TestWriteFailures
> self = <write_failures_test.TestWriteFailures object at 0x7f396bb68910>
> def test_paxos(self):
> """
> A light transaction receives a WriteFailure
> """
> > exc = self._perform_cql_statement("INSERT INTO mytable (key, value)
> > VALUES ('key1', 'Value 1') IF NOT EXISTS")
> write_failures_test.py:202:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> write_failures_test.py:88: in _perform_cql_statement
> session.execute(statement)
> ../env3.7/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='<BoundStatement query="INSERT INTO mytable
> (key, value) VALUES ('key1', 'Value 1') IF NOT EXIS...ncy': 'SERIAL',
> 'required_responses': 2, 'received_responses': 1, 'write_type': 'CAS'}
> 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="CAS operation
> timed out: received 1 of 2 required responses after 0 contention retries"
> info={'consistency': 'SERIAL', 'required_responses': 2, 'received_responses':
> 1, 'write_type': 'CAS'}
> ../env3.7/src/cassandra-driver/cassandra/cluster.py:4894: WriteTimeout
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
