[jira] [Created] (CASSANDRA-15845) dtest-novnode.materialized_views_test.TestMaterializedViews.test_populate_mv_after_insert_wide_rows

["Berenguer Blasi (Jira)" <ji...@apache.org>]

Berenguer Blasi created CASSANDRA-15845:
-------------------------------------------

             Summary: dtest-novnode.materialized_views_test.TestMaterializedViews.test_populate_mv_after_insert_wide_rows
                 Key: CASSANDRA-15845
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-15845
             Project: Cassandra
          Issue Type: Bug
          Components: Test/dtest
            Reporter: Berenguer Blasi


See failure [here|https://ci-cassandra.apache.org/job/Cassandra-trunk/155/testReport/dtest-novnode.materialized_views_test/TestMaterializedViews/test_populate_mv_after_insert_wide_rows_2/]

Error Message

assert 160 == 0  +  where 160 = Row(count=160).count

Stacktrace

self = <materialized_views_test.TestMaterializedViews object at 0x7fcb232b5760>

    def test_populate_mv_after_insert_wide_rows(self):
        """Test that a view is OK when created with existing data with wide rows"""
        session = self.prepare(consistency_level=ConsistencyLevel.QUORUM)
    
        session.execute("CREATE TABLE t (id int, v int, PRIMARY KEY (id, v))")
    
        for i in range(5):
            for j in range(10000):
                session.execute("INSERT INTO t (id, v) VALUES ({}, {})".format(i, j))
    
        session.execute(("CREATE MATERIALIZED VIEW t_by_v AS SELECT * FROM t WHERE v IS NOT NULL "
                         "AND id IS NOT NULL PRIMARY KEY (v, id)"))
    
        logger.debug("wait for view to build")
        self._wait_for_view("ks", "t_by_v")
    
        logger.debug("wait that all batchlogs are replayed")
>       self._replay_batchlogs()

materialized_views_test.py:350: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <materialized_views_test.TestMaterializedViews object at 0x7fcb232b5760>

    def _replay_batchlogs(self):
        for node in self.cluster.nodelist():
            if node.is_running():
                logger.debug("Replaying batchlog on node {}".format(node.name))
                node.nodetool("replaybatchlog")
                # CASSANDRA-13069 - Ensure replayed mutations are removed from the batchlog
                node_session = self.patient_exclusive_cql_connection(node)
                result = list(node_session.execute("SELECT count(*) FROM system.batches;"))
>               assert result[0].count == 0
E               assert 160 == 0
E                +  where 160 = Row(count=160).count

materialized_views_test.py:171: AssertionError



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org