CI Summary

assert 100000 == 94972
  +100000
  -94972-self = 

    def test_bulk_round_trip_with_timeouts(self):
        """
        Test bulk import with very short read and write timeout values, this should exercise the
        retry and back-off policies. We cannot check the counts because "SELECT COUNT(*)" could timeout
        on Jenkins making the test flacky.
    
        @jira_ticket CASSANDRA-9302
        """
>       self._test_bulk_round_trip(nodes=1, partitioner="murmur3", num_operations=100000,
                                   configuration_options={'range_request_timeout_in_ms': '200',
                                                          'write_request_timeout_in_ms': '100'},
                                   copy_from_options={'MAXINSERTERRORS': -1},
                                   skip_count_checks=True)

cqlsh_tests/test_cqlsh_copy.py:2514: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
nodes = 1, partitioner = 'murmur3', num_operations = 100000, profile = None
stress_table = 'keyspace1.standard1'
configuration_options = {'range_request_timeout_in_ms': '200', 'truncate_request_timeout_in_ms': 60000, 'write_request_timeout_in_ms': '100'}
skip_count_checks = True, copy_to_options = {}
copy_from_options = {'MAXINSERTERRORS': -1}

    def _test_bulk_round_trip(self, nodes, partitioner,
                              num_operations, profile=None,
                              stress_table='keyspace1.standard1',
                              configuration_options=None,
                              skip_count_checks=False,
                              copy_to_options=None,
                              copy_from_options=None):
        """
        Test exporting a large number of rows into a csv file.
    
        If skip_count_checks is True then it means we cannot use "SELECT COUNT(*)" as it may time out but
        it also means that we can be sure that one cassandra-stress operation is one record and hence
        num_records=num_operations.
    
        Perform the following:
        - create the records with cassandra-stress
        - export the records to a csv file
        - truncate the table and import the csv file
        - export the records to another csv file
        - check that the length of the two csv files is the same
    
        Therefore, 3 COPY operations are run in total. Return a list of tuples, containing stdout and stderr
        for all 3 copy operations.
        """
        if configuration_options is None:
            configuration_options = {}
        if copy_to_options is None:
            copy_to_options = {}
    
        # The default truncate timeout of 10 seconds that is set in init_default_config() is not
        # enough for truncating larger tables, see CASSANDRA-11157
        if 'truncate_request_timeout_in_ms' not in configuration_options:
            configuration_options['truncate_request_timeout_in_ms'] = 60000
    
        self.prepare(nodes=nodes, partitioner=partitioner, configuration_options=configuration_options)
    
        ret = []
    
        def create_records():
            if not profile:
                logger.debug('Running stress without any user profile')
                self.node1.stress(['write', 'n={} cl=ALL'.format(num_operations), 'no-warmup', '-rate', 'threads=50'])
            else:
                logger.debug('Running stress with user profile {}'.format(profile))
                self.node1.stress(['user', 'profile={}'.format(profile), 'ops(insert=1)',
                                   'n={} cl=ALL'.format(num_operations), 'no-warmup', '-rate', 'threads=50'])
    
            if skip_count_checks:
                return num_operations
            else:
                count_statement = SimpleStatement("SELECT COUNT(*) FROM {}".format(stress_table), consistency_level=ConsistencyLevel.ALL,
                                                  retry_policy=FlakyRetryPolicy(max_retries=3))
                ret = rows_to_list(self.session.execute(count_statement))[0][0]
                logger.debug('Generated {} records'.format(ret))
                assert ret >= num_operations, 'cassandra-stress did not import enough records'
                return ret
    
        def run_copy_to(filename):
            logger.debug('Exporting to csv file: {}'.format(filename.name))
            start = datetime.datetime.now()
            copy_to_cmd = "CONSISTENCY ALL; COPY {} TO '{}'".format(stress_table, filename.name)
            if copy_to_options:
                copy_to_cmd += ' WITH ' + ' AND '.join('{} = {}'.format(k, v) for k, v in copy_to_options.items())
            logger.debug('Running {}'.format(copy_to_cmd))
            result = self.run_cqlsh(cmds=copy_to_cmd)
            ret.append(result)
            logger.debug("COPY TO took {} to export {} records".format(datetime.datetime.now() - start, num_records))
    
        def run_copy_from(filename):
            logger.debug('Importing from csv file: {}'.format(filename.name))
            start = datetime.datetime.now()
            copy_from_cmd = "COPY {} FROM '{}'".format(stress_table, filename.name)
            if copy_from_options:
                copy_from_cmd += ' WITH ' + ' AND '.join('{} = {}'.format(k, v) for k, v in copy_from_options.items())
            logger.debug('Running {}'.format(copy_from_cmd))
            result = self.run_cqlsh(cmds=copy_from_cmd)
            ret.append(result)
            logger.debug("COPY FROM took {} to import {} records".format(datetime.datetime.now() - start, num_records))
    
        num_records = create_records()
    
        # Copy to the first csv files
        tempfile1 = self.get_temp_file()
        run_copy_to(tempfile1)
    
        # check all records generated were exported
        with io.open(tempfile1.name, encoding="utf-8", newline='') as csvfile:
            assert num_records == sum(1 for _ in csv.reader(csvfile, quotechar='"', escapechar='\\'))
    
        # import records from the first csv file
        logger.debug('Truncating {}...'.format(stress_table))
        self.session.execute("TRUNCATE {}".format(stress_table))
        run_copy_from(tempfile1)
    
        # export again to a second csv file
        tempfile2 = self.get_temp_file()
        run_copy_to(tempfile2)
    
        # check the length of both files is the same to ensure all exported records were imported
>       assert sum(1 for _ in open(tempfile1.name)) == sum(1 for _ in open(tempfile2.name))
E       assert 100000 == 94972
E         +100000
E         -94972

cqlsh_tests/test_cqlsh_copy.py:2456: AssertionError

Failed: Timeout >900.0s-self = 

    def test_nameless_index(self):
        """ Test CREATE INDEX without name and validate the index can be dropped """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:870: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 4032, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_limit_multiget(self):
        """ Validate LIMIT option for 'multiget' in SELECT statements """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:336: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7552, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

failed on setup with "Failed: Timeout >900.0s"->       lambda: ihook(item=item, **kwds), when=when, reraise=reraise
    )

../cassandra/build/venv/lib/python3.8/site-packages/flaky/flaky_pytest_plugin.py:146: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
conftest.py:450: in fixture_since
    ccm_repo_cache_dir, _ = ccmlib.repository.setup(upgrade_path.starting_meta.version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 6400, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_reversed_compact(self):
        """
        Test for #4716 bug and more generally for good behavior of ordering
        @jira_ticket CASSANDRA-4716
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2047: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 5760, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_edge_2i_on_complex_pk(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2822: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 2176, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_indexed_with_eq(self):
        """ Check that you can query for an indexed column even with a key EQ clause """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:458: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 3840, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_delete_row(self):
        """ Test deletion of rows """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1244: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 2816, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_function_with_null(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:3443: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 1408, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_indexed_with_eq(self):
        """ Check that you can query for an indexed column even with a key EQ clause """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:458: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 6528, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_multi_list_set(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2332: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 5952, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    @pytest.mark.no_vnodes
    def test_undefined_column_handling(self):
>       cursor = self.prepare(ordered=True)

upgrade_tests/cql_tests.py:1143: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 4992, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_more_order_by(self):
        """
        More ORDER BY checks
        @jira_ticket CASSANDRA-4160
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:661: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 2368, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_order_by_validation(self):
        """
        Check we don't allow order by on row key
        @jira_ticket CASSANDRA-4246
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:728: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 2112, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_select_count_paging(self):
        """
        Test for the #6579 'select count' paging bug
        @jira_ticket CASSANDRA-6579
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:4185: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:111: in prepare
    cluster.start()
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:550: in start
    node.watch_log_for(start_message, timeout=timeout, process=p, verbose=verbose, from_mark=mark,
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
exprs = 'Starting listening for CQL clients', from_mark = 0, timeout = 120
process = , verbose = False
filename = 'system.log', error_on_pid_terminated = True

    def watch_log_for(self, exprs, from_mark=None, timeout=600,
                      process=None, verbose=False, filename='system.log',
                      error_on_pid_terminated=False):
        """
        Watch the log until one or more (regular) expressions are found or timeouts (a
        TimeoutError is then raised). On successful completion, a list of pair (line matched,
        match object) is returned.
    
        Will raise NodeError if error_on_pit_terminated is True and C* pid is not running.
        """
        start = time.time()
        tofind = [exprs] if isinstance(exprs, string_types) else exprs
        tofind = [re.compile(e) for e in tofind]
        matchings = []
        reads = ""
        if len(tofind) == 0:
            return None
    
        log_file = os.path.join(self.log_directory(), filename)
        output_read = False
        while not os.path.exists(log_file):
            time.sleep(.5)
            TimeoutError.raise_if_passed(start=start, timeout=timeout, node=self.name,
                                         msg="Timed out waiting for {} to be created.".format(log_file))
    
            if process and not output_read:
                process.poll()
                if process.returncode is not None:
                    self.print_process_output(self.name, process, verbose)
                    output_read = True
                    if process.returncode != 0:
                        raise RuntimeError()  # Shouldn't reuse RuntimeError but I'm lazy
    
        with open(log_file) as f:
            if from_mark:
                f.seek(from_mark)
    
            while True:
                # First, if we have a process to check, then check it.
                # Skip on Windows - stdout/stderr is cassandra.bat
                if not common.is_win() and not output_read:
                    if process:
                        process.poll()
                        if process.returncode is not None:
                            self.print_process_output(self.name, process, verbose)
                            output_read = True
                            if process.returncode != 0:
                                raise RuntimeError()  # Shouldn't reuse RuntimeError but I'm lazy
    
                line = f.readline()
                if line:
                    reads = reads + line
                    for e in tofind:
                        m = e.search(line)
                        if m:
                            matchings.append((line, m))
                            tofind.remove(e)
                            if len(tofind) == 0:
                                return matchings[0] if isinstance(exprs, string_types) else matchings
                else:
                    # wait for the situation to clarify, either stop or just a pause in log production
>                   time.sleep(1)
E                   Failed: Timeout >900.0s

../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/node.py:605: Failed

Failed: Timeout >900.0s-self = 

    def test_column_name_validation(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:3541: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 128, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_no_range_ghost(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1094: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 5248, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_reversed_compact(self):
        """
        Test for #4716 bug and more generally for good behavior of ordering
        @jira_ticket CASSANDRA-4716
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2047: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 3584, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_range_query_2ndary(self):
        """
        Test range queries with 2ndary indexes
        @jira_ticket CASSANDRA-4257
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1278: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 3072, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_remove_range_slice(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1959: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 6016, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_multi_collection(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1420: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 256, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_date(self):
        """ Check dates are correctly recognized and validated """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:1730: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 704, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_multi_list_set(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2332: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 2048, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

failed on setup with "Failed: Timeout >900.0s"->       lambda: ihook(item=item, **kwds), when=when, reraise=reraise
    )

../cassandra/build/venv/lib/python3.8/site-packages/flaky/flaky_pytest_plugin.py:146: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
conftest.py:450: in fixture_since
    ccm_repo_cache_dir, _ = ccmlib.repository.setup(upgrade_path.starting_meta.version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 256, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

failed on setup with "Failed: Timeout >900.0s"->       lambda: ihook(item=item, **kwds), when=when, reraise=reraise
    )

../cassandra/build/venv/lib/python3.8/site-packages/flaky/flaky_pytest_plugin.py:146: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
conftest.py:450: in fixture_since
    ccm_repo_cache_dir, _ = ccmlib.repository.setup(upgrade_path.starting_meta.version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7872, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_returned_null(self):
        """
        Test for returned null.
        StorageProxy short read protection hadn't been updated after the changes made by CASSANDRA-3647,
        namely the fact that SliceQueryFilter groups columns by prefix before counting them.
        @jira_ticket CASSANDRA-4882
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2307: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7488, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_multi_list_set(self):
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2332: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 6144, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_query_compact_tables_during_upgrade(self):
        """
        Check that un-upgraded sstables for compact storage tables
        can be read after an upgrade. Checks for a regression where
        when the coordinator is on < 3.0, a replica at >= 3.0 returns
        0 results for any read request. When the >= 3.0 node is
        the coordinator, the problem does not manifest. Likewise, if
        the data is inserted after the replica is upgraded, or if
        upgradesstables is run after upgrade, the query succeeds, so
        the issue is with reading legacy format sstables in response to
        a legacy format read request
        @jira_ticket CASSANDRA-11087
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:2738: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7552, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_clustering_order_in(self):
        """
        @jira_ticket CASSANDRA-7105
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:5102: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 6272, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

failed on setup with "Failed: Timeout >900.0s"->       lambda: ihook(item=item, **kwds), when=when, reraise=reraise
    )

../cassandra/build/venv/lib/python3.8/site-packages/flaky/flaky_pytest_plugin.py:146: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
conftest.py:450: in fixture_since
    ccm_repo_cache_dir, _ = ccmlib.repository.setup(upgrade_path.starting_meta.version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7808, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

failed on setup with "Failed: Timeout >900.0s"->       lambda: ihook(item=item, **kwds), when=when, reraise=reraise
    )

../cassandra/build/venv/lib/python3.8/site-packages/flaky/flaky_pytest_plugin.py:146: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
conftest.py:450: in fixture_since
    ccm_repo_cache_dir, _ = ccmlib.repository.setup(upgrade_path.starting_meta.version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7488, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_deletion(self):
        """
        Test simple deletion and in particular check for #4193 bug
        @jira_ticket CASSANDRA-4193
        """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:896: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 7488, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_noncomposite_static_cf(self):
        """ Test non-composite static CF syntax """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:123: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 5760, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Failed: Timeout >900.0s-self = 

    def test_in_clause_wide_rows(self):
        """ Check IN support for 'wide rows' in SELECT statement """
>       cursor = self.prepare()

upgrade_tests/cql_tests.py:560: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
upgrade_tests/upgrade_base.py:88: in prepare
    cluster.set_install_dir(version=self.UPGRADE_PATH.starting_version)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/cluster.py:111: in set_install_dir
    dir, v = repository.setup(version, verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:99: in setup
    download_version(version, verbose=verbose, binary=binary)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:349: in download_version
    __download(archive_url, target, show_progress=verbose)
../cassandra/build/venv/lib/python3.8/site-packages/ccmlib/repository.py:546: in __download
    buffer = u.read(block_sz)
/usr/lib/python3.8/http/client.py:459: in read
    n = self.readinto(b)
/usr/lib/python3.8/http/client.py:503: in readinto
    n = self.fp.readinto(b)
/usr/lib/python3.8/socket.py:669: in readinto
    return self._sock.recv_into(b)
/usr/lib/python3.8/ssl.py:1270: in recv_into
    return self.read(nbytes, buffer)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = 
len = 3008, buffer = 

    def read(self, len=1024, buffer=None):
        """Read up to LEN bytes and return them.
        Return zero-length string on EOF."""
    
        self._checkClosed()
        if self._sslobj is None:
            raise ValueError("Read on closed or unwrapped SSL socket.")
        try:
            if buffer is not None:
>               return self._sslobj.read(len, buffer)
E               Failed: Timeout >900.0s

/usr/lib/python3.8/ssl.py:1128: Failed

Timeout occurred. Please note the time in the report does not reflect the time until the timeout.-junit.framework.AssertionFailedError: Timeout occurred. Please note the time in the report does not reflect the time until the timeout.
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.util.Vector.forEach(Vector.java:1394)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.util.Vector.forEach(Vector.java:1394)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.util.Vector.forEach(Vector.java:1394)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at org.apache.cassandra.anttasks.TestHelper.execute(TestHelper.java:53)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.util.Vector.forEach(Vector.java:1394)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at jdk.internal.reflect.GeneratedMethodAccessor4.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

expected:<0> but was:<1>-junit.framework.AssertionFailedError: expected:<0> but was:<1>
	at org.apache.cassandra.net.ConnectionTest.lambda$testMessageDeliveryOnReconnect$37(ConnectionTest.java:644)
	at org.apache.cassandra.net.ConnectionTest.doTestManual(ConnectionTest.java:253)
	at org.apache.cassandra.net.ConnectionTest.testManual(ConnectionTest.java:226)
	at org.apache.cassandra.net.ConnectionTest.testMessageDeliveryOnReconnect(ConnectionTest.java:623)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)