[
https://issues.apache.org/jira/browse/CASSANDRA-17700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561111#comment-17561111
]
Jon Meredith commented on CASSANDRA-17700:
------------------------------------------
+1 thanks for fixing [~Jyothsnakonisa]
> Fix
> TestGossipingPropertyFileSnitch.test_prefer_local_reconnect_on_listen_address
> ---------------------------------------------------------------------------------
>
> Key: CASSANDRA-17700
> URL: https://issues.apache.org/jira/browse/CASSANDRA-17700
> Project: Cassandra
> Issue Type: Bug
> Components: CI
> Reporter: Ekaterina Dimitrova
> Assignee: Jyothsna Konisa
> Priority: Normal
> Fix For: 4.x
>
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> It is consistently failing in trunk after
> CASSANDRA-17661. Maybe a debug message has changed or something?
> CC [~Jyothsnakonisa], [~jmeredithco] , [~ycai]
> {code:java}
> Error Message
> ccmlib.node.TimeoutError: 14 Jun 2022 02:38:50 [node1] after 60.07/60 seconds
> Missing: ['tiated reconnect to an Internal IP (\\/)?127.0.0.2(:7000)? for the
> (\\/)?127.0.0.4(:7000)?'] not found in debug.log: Head: INFO [main]
> 2022-06-14 02:36:25,360 YamlConfigura Tail:
> ...7.0.0.3:7000(/127.0.0.1:43890)->/127.0.0.4:7000-LARGE_MESSAGES-8f378c72
> successfully connected, version = 12, framing = CRC, encryption = unencrypted
> Stacktrace
> self = <snitch_test.TestGossipingPropertyFileSnitch object at 0x7f2e6ec50dc0>
> def test_prefer_local_reconnect_on_listen_address(self):
> """
> @jira_ticket CASSANDRA-9748
> @jira_ticket CASSANDRA-8084
>
> Test that it's possible to connect over the broadcast_address when
> listen_on_broadcast_address=true and that
> GossipingPropertyFileSnitch
> reconnect via listen_address when prefer_local=true
> """
>
> NODE1_LISTEN_ADDRESS = '127.0.0.1'
> NODE1_BROADCAST_ADDRESS = '127.0.0.3'
>
> NODE2_LISTEN_ADDRESS = '127.0.0.2'
> NODE2_BROADCAST_ADDRESS = '127.0.0.4'
>
> STORAGE_PORT = 7000
>
> cluster = self.cluster
> cluster.populate(2)
> node1, node2 = cluster.nodelist()
>
> running40 = node1.get_base_cassandra_version() >= 4.0
>
> cluster.seeds = [NODE1_BROADCAST_ADDRESS]
> cluster.set_configuration_options(values={'endpoint_snitch':
> 'org.apache.cassandra.locator.GossipingPropertyFileSnitch',
>
> 'listen_on_broadcast_address': 'true'})
> node1.set_configuration_options(values={'broadcast_address':
> NODE1_BROADCAST_ADDRESS})
> node2.auto_bootstrap = True
> node2.set_configuration_options(values={'broadcast_address':
> NODE2_BROADCAST_ADDRESS})
>
> for node in cluster.nodelist():
> with open(os.path.join(node.get_conf_dir(),
> 'cassandra-rackdc.properties'), 'w') as snitch_file:
> snitch_file.write("dc=dc1" + os.linesep)
> snitch_file.write("rack=rack1" + os.linesep)
> snitch_file.write("prefer_local=true" + os.linesep)
>
> node1.start(wait_for_binary_proto=True)
>
> self._test_connect(NODE1_LISTEN_ADDRESS, STORAGE_PORT)
> self._test_connect(NODE1_BROADCAST_ADDRESS, STORAGE_PORT)
>
> # write some data to node1
> node1.stress(['write', 'n=10K', 'no-warmup', '-rate', 'threads=8'])
>
> session = self.patient_cql_connection(node1)
> stress_table = 'keyspace1.standard1'
> original_rows = list(session.execute("SELECT * FROM
> {}".format(stress_table)))
>
> node2.start(wait_for_binary_proto=True, wait_other_notice=False)
>
> self._test_connect(NODE2_LISTEN_ADDRESS, STORAGE_PORT)
> self._test_connect(NODE2_BROADCAST_ADDRESS, STORAGE_PORT)
>
> # substring for Intiated -> Initiated typo was fixed in 3.10
> matchn1 = 'tiated reconnect to an Internal IP (\/)?{}(:7000)? for the
> (\/)?{}(:7000)?'.format(NODE1_LISTEN_ADDRESS, NODE1_BROADCAST_ADDRESS)
> matchn2 = 'tiated reconnect to an Internal IP (\/)?{}(:7000)? for the
> (\/)?{}(:7000)?'.format(NODE2_LISTEN_ADDRESS, NODE2_BROADCAST_ADDRESS)
> > node1.watch_log_for(matchn2, filename='debug.log', timeout=60)
> snitch_test.py:85:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> ../venv/lib/python3.8/site-packages/ccmlib/node.py:589: in watch_log_for
> TimeoutError.raise_if_passed(start=start, timeout=timeout, node=self.name,
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> start = 1655174270.069921, timeout = 60
> msg = "Missing: ['tiated reconnect to an Internal IP
> (\\\\/)?127.0.0.2(:7000)? for the (\\\\/)?127.0.0.4(:7000)?'] not
> found...127.0.0.4:7000-LARGE_MESSAGES-8f378c72 successfully connected,
> version = 12, framing = CRC, encryption = unencrypted\n"
> node = 'node1'
> @staticmethod
> def raise_if_passed(start, timeout, msg, node=None):
> if start + timeout < time.time():
> > raise TimeoutError.create(start, timeout, msg, node)
> E ccmlib.node.TimeoutError: 14 Jun 2022 02:38:50 [node1] after
> 60.07/60 seconds Missing: ['tiated reconnect to an Internal IP
> (\\/)?127.0.0.2(:7000)? for the (\\/)?127.0.0.4(:7000)?'] not found in
> debug.log:
> E Head: INFO [main] 2022-06-14 02:36:25,360 YamlConfigura
> E Tail:
> ...7.0.0.3:7000(/127.0.0.1:43890)->/127.0.0.4:7000-LARGE_MESSAGES-8f378c72
> successfully connected, version = 12, framing = CRC, encryption = unencrypted
> ../venv/lib/python3.8/site-packages/ccmlib/node.py:56: TimeoutError
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
