You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Brandon Williams (Jira)" <ji...@apache.org> on 2023/08/22 11:00:00 UTC
[jira] [Updated] (CASSANDRA-18162) Test Failure: cqlsh_tests.test_cqlsh_copy.TestCqlshCopy.test_bulk_round_trip_non_prepared_statements
[ https://issues.apache.org/jira/browse/CASSANDRA-18162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Brandon Williams updated CASSANDRA-18162:
-----------------------------------------
Bug Category: Parent values: Correctness(12982)Level 1 values: Test Failure(12990)
Complexity: Normal
Discovered By: User Report
Severity: Normal
Status: Open (was: Triage Needed)
> Test Failure: cqlsh_tests.test_cqlsh_copy.TestCqlshCopy.test_bulk_round_trip_non_prepared_statements
> ----------------------------------------------------------------------------------------------------
>
> Key: CASSANDRA-18162
> URL: https://issues.apache.org/jira/browse/CASSANDRA-18162
> Project: Cassandra
> Issue Type: Bug
> Components: Test/dtest/python
> Reporter: Michael Semb Wever
> Priority: Normal
> Fix For: 3.0.x, 3.11.x, 4.0.x, 4.1.x, 5.x
>
>
> Flaky.
> {noformat}
> itf = ('127.0.0.3', 7000)
> def assert_socket_available(itf):
> info = socket.getaddrinfo(itf[0], itf[1], socket.AF_UNSPEC, socket.SOCK_STREAM)
> if not info:
> raise UnavailableSocketError("Failed to get address info for [%s]:%s" % itf)
>
> (family, socktype, proto, canonname, sockaddr) = info[0]
> s = socket.socket(family, socktype)
> s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
>
> try:
> > s.bind(sockaddr)
> E OSError: [Errno 98] Address already in use
> ../venv/lib/python3.8/site-packages/ccmlib/common.py:631: OSError
> During handling of the above exception, another exception occurred:
> self = <cqlsh_tests.test_cqlsh_copy.TestCqlshCopy object at 0x7f36a7d70580>
> def test_bulk_round_trip_non_prepared_statements(self):
> """
> Test bulk import with default stress import (one row per operation) and without
> prepared statements.
>
> @jira_ticket CASSANDRA-11053
> """
> > self._test_bulk_round_trip(nodes=3, partitioner="murmur3", num_operations=100000,
> copy_from_options={'PREPAREDSTATEMENTS': False})
> cqlsh_tests/test_cqlsh_copy.py:2475:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> cqlsh_tests/test_cqlsh_copy.py:2391: in _test_bulk_round_trip
> self.prepare(nodes=nodes, partitioner=partitioner, configuration_options=configuration_options)
> cqlsh_tests/test_cqlsh_copy.py:116: in prepare
> self.cluster.populate(nodes, tokens=tokens).start()
> ../venv/lib/python3.8/site-packages/ccmlib/cluster.py:513: in start
> common.assert_socket_available(itf)
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> itf = ('127.0.0.3', 7000)
> def assert_socket_available(itf):
> info = socket.getaddrinfo(itf[0], itf[1], socket.AF_UNSPEC, socket.SOCK_STREAM)
> if not info:
> raise UnavailableSocketError("Failed to get address info for [%s]:%s" % itf)
>
> (family, socktype, proto, canonname, sockaddr) = info[0]
> s = socket.socket(family, socktype)
> s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
>
> try:
> s.bind(sockaddr)
> s.close()
> return True
> except socket.error as msg:
> s.close()
> addr, port = itf
> > raise UnavailableSocketError(
> "Inet address %s:%s is not available: %s; a cluster may already be running or you may need to add the loopback alias" % (
> addr, port, msg))
> E ccmlib.common.UnavailableSocketError: Inet address 127.0.0.3:7000 is not available: [Errno 98] Address already in use; a cluster may already be running or you may need to add the loopback alias
> ../venv/lib/python3.8/site-packages/ccmlib/common.py:637: UnavailableSocketError
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org