Dmitry Konstantinov created CASSANDRA-21820:
-----------------------------------------------
Summary: Flaky test:
materialized_views_test.TestMaterializedViews.test_drop_mv
Key: CASSANDRA-21820
URL: https://issues.apache.org/jira/browse/CASSANDRA-21820
Project: Apache Cassandra
Issue Type: Bug
Components: Test/dtest/python
Reporter: Dmitry Konstantinov
https://ci-cassandra.apache.org/job/Cassandra-4.1/689/testReport/junit/dtest-novnode.materialized_views_test/TestMaterializedViews/test_drop_mv_3/
{code}
self = <materialized_views_test.TestMaterializedViews object at 0x78ddc74eb160>
def test_drop_mv(self):
"""Test that we can drop a view properly"""
session = self.prepare(user_table=True)
# create another materialized view
session.execute(("CREATE MATERIALIZED VIEW users_by_birth_year AS "
"SELECT * FROM users WHERE birth_year IS NOT NULL AND "
"username IS NOT NULL PRIMARY KEY (birth_year,
username)"))
result = list(session.execute(("SELECT * FROM system_schema.views "
"WHERE keyspace_name='ks' AND
base_table_name='users' ALLOW FILTERING")))
assert len(result) == 2, "Expecting {} materialized view, got
{}".format(2, len(result))
> session.execute("DROP MATERIALIZED VIEW ks.users_by_state;")
materialized_views_test.py:448:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
../venv/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="DROP MATERIALIZED VIEW
ks.users_by_state;", consistency=Not Set>' requ...ient request timeout. See
Session.execute[_async](timeout)'}, last_host=127.0.0.2:9042
coordinator_host=127.0.0.2: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.OperationTimedOut: errors={'Connection defunct by
heartbeat': 'Client request timeout. See Session.execute[_async](timeout)'},
last_host=127.0.0.2:9042
../venv/src/cassandra-driver/cassandra/cluster.py:4894: OperationTimedOut
{code}
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
