Dmitry Kropachev
Dmitry Kropachev
It comes from https://github.com/scylladb/cassandra-stress/issues/30. Time to time it can stuck waiting for `DefaultResultSetFuture` to be released: ``` "Thread-2" prio=5 Id=59 WAITING on com.datastax.driver.core.DefaultResultSetFuture@2ad5ebfd at [email protected]/jdk.internal.misc.Unsafe.park(Native Method) - waiting on com.datastax.driver.core.DefaultResultSetFuture@2ad5ebfd...
Currently `TabletMap` contains `private final Cluster.Manager cluster` that makes it unreasonably hard to unit test it. Let's drop `private final Cluster.Manager cluster` from it and have unit tests for it.
Since netty `bootstrap.connect` uses only first address of unresolved `InetSocketAddress` 4.x does not even try to connect to other when it fails. Consider following test: ``` @Test public void cannot_connect_if_first_node_is_unavailable()...
Currently following test are failing on java-11: ``` should_not_retry_on_connection_error_if_statement_non_idempotent should_retry_on_connection_error_if_statement_idempotent should_rethrow_on_connection_error should_try_next_host_on_connection_error should_not_reprepare_on_up_when_disabled should_reprepare_on_up_by_default should_reprepare_on_up_when_enabled ``` Let's investigate why they fail and fix them
## Pre-review checklist Make schema agreement waiting code renew connection on each iteration When schema agreement is started it could happen that control connection is getting disconnected/reconnected, when it happens...
After hard-coding python-driver version to `3.29.0` for cqlsh in the [core](https://github.com/scylladb/scylladb) tests start failing with random errors, one of them: ``` self = def test_past_and_future_dates(self): (node1,) = self.cluster.nodelist() node1.run_cqlsh( cqlsh_options=self.cqlsh_options(),...
We need to have them in the cicd, but unfortunately suite get stuck at random places. Most likely there is race in reactors that not terminating connection handlers properly.
``` ____________ TestTwistedConnection.test_connection_initialization _____________ self = def test_connection_initialization(self): """ Verify that __init__() works correctly. """ self.mock_reactor_cft.assert_called_with(self.obj_ut.add_connection) > self.mock_reactor_run.assert_called_with(installSignalHandlers=False) D:\a\python-driver\python-driver\tests\unit\io\test_twistedreactor.py:115: _ _ _ _ _ _ _ _ _ _ _...