diff --git a/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py b/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py index c964b6937e6f4b..bebafc7da0fa02 100644 --- a/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py +++ b/modules/ducktests/tests/ignitetest/services/utils/ignite_aware.py @@ -17,6 +17,8 @@ This module contains the base class to build services aware of Ignite. """ +import socket + from abc import abstractmethod, ABCMeta from ducktape.services.background_thread import BackgroundThreadService @@ -75,6 +77,8 @@ def _prepare_config(self, node): config.discovery_spi.prepare_on_start(cluster=self) + config.discovery_spi.local_address = socket.gethostbyname(node.account.hostname) + node_config = self.spec.config_template.render(config_dir=self.PERSISTENT_ROOT, work_dir=self.WORK_DIR, config=config) diff --git a/modules/ducktests/tests/ignitetest/services/utils/ignite_configuration/discovery.py b/modules/ducktests/tests/ignitetest/services/utils/ignite_configuration/discovery.py index 2f533619b1aabd..1cd310f16921a3 100644 --- a/modules/ducktests/tests/ignitetest/services/utils/ignite_configuration/discovery.py +++ b/modules/ducktests/tests/ignitetest/services/utils/ignite_configuration/discovery.py @@ -101,10 +101,11 @@ class TcpDiscoverySpi(DiscoverySpi): """ TcpDiscoverySpi. """ - def __init__(self, ip_finder=TcpDiscoveryVmIpFinder(), port=47500, port_range=100): + def __init__(self, ip_finder=TcpDiscoveryVmIpFinder(), port=47500, port_range=100, local_address=None): self.ip_finder = ip_finder self.port = port self.port_range = port_range + self.local_address = local_address @property def type(self): diff --git a/modules/ducktests/tests/ignitetest/services/utils/templates/discovery_macro.j2 b/modules/ducktests/tests/ignitetest/services/utils/templates/discovery_macro.j2 index 66bdf436030851..dc666dfda99da8 100644 --- a/modules/ducktests/tests/ignitetest/services/utils/templates/discovery_macro.j2 +++ b/modules/ducktests/tests/ignitetest/services/utils/templates/discovery_macro.j2 @@ -44,6 +44,9 @@ {% macro tcp_discovery_spi(spi) %} + {% if spi.local_address %} + + {% endif %} {{ ip_finder(spi) }}