[
https://issues.apache.org/jira/browse/KAFKA-16988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat resolved KAFKA-16988.
--------------------------------
Resolution: Fixed
> InsufficientResourcesError in ConnectDistributedTest system test
> ----------------------------------------------------------------
>
> Key: KAFKA-16988
> URL: https://issues.apache.org/jira/browse/KAFKA-16988
> Project: Kafka
> Issue Type: Bug
> Reporter: Luke Chen
> Assignee: Luke Chen
> Priority: Major
> Fix For: 3.8.0, 3.7.1
>
>
> Saw InsufficientResourcesError when running
> `ConnectDistributedTest#test_exactly_once_source` system test.
>
> {code:java}
> <testcase
> name="test_exactly_once_source_clean=False_connect_protocol=compatible_metadata_quorum=ZK_use_new_coordinator=False"
> classname="kafkatest.tests.connect.connect_distributed_test"
> time="403.812"><error message="InsufficientResourcesError('linux nodes
> requested: 1. linux nodes available: 0')"
> type="exception">InsufficientResourcesError('linux nodes requested: 1. linux
> nodes available: 0') Traceback (most recent call last): File
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py",
> line 186, in _do_run data = self.run_test() File
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py",
> line 246, in run_test return self.test_context.function(self.test) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 433, in
> wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
> File
> "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py",
> line 928, in test_exactly_once_source consumer_validator =
> ConsoleConsumer(self.test_context, 1, self.kafka, self.source.topic,
> consumer_timeout_ms=1000, print_key=True) File
> "/opt/kafka-dev/tests/kafkatest/services/console_consumer.py", line 97, in
> __init__ BackgroundThreadService.__init__(self, context, num_nodes) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/background_thread.py",
> line 26, in __init__ super(BackgroundThreadService, self).__init__(context,
> num_nodes, cluster_spec, *args, **kwargs) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line
> 107, in __init__ self.allocate_nodes() File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line
> 217, in allocate_nodes self.nodes = self.cluster.alloc(self.cluster_spec)
> File "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/cluster.py",
> line 54, in alloc allocated = self.do_alloc(cluster_spec) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/finite_subcluster.py",
> line 37, in do_alloc good_nodes, bad_nodes =
> self._available_nodes.remove_spec(cluster_spec) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/node_container.py",
> line 131, in remove_spec raise InsufficientResourcesError(err)
> ducktape.cluster.node_container.InsufficientResourcesError: linux nodes
> requested: 1. linux nodes available: 0 </error>
> <testcase
> name="test_exactly_once_source_clean=False_connect_protocol=sessioned_metadata_quorum=ZK_use_new_coordinator=False"
> classname="kafkatest.tests.connect.connect_distributed_test"
> time="376.160"><error message="InsufficientResourcesError('linux nodes
> requested: 1. linux nodes available: 0')"
> type="exception">InsufficientResourcesError('linux nodes requested: 1. linux
> nodes available: 0') Traceback (most recent call last): File
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py",
> line 186, in _do_run data = self.run_test() File
> "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py",
> line 246, in run_test return self.test_context.function(self.test) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 433, in
> wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
> File
> "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py",
> line 928, in test_exactly_once_source consumer_validator =
> ConsoleConsumer(self.test_context, 1, self.kafka, self.source.topic,
> consumer_timeout_ms=1000, print_key=True) File
> "/opt/kafka-dev/tests/kafkatest/services/console_consumer.py", line 97, in
> __init__ BackgroundThreadService.__init__(self, context, num_nodes) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/background_thread.py",
> line 26, in __init__ super(BackgroundThreadService, self).__init__(context,
> num_nodes, cluster_spec, *args, **kwargs) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line
> 107, in __init__ self.allocate_nodes() File
> "/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line
> 217, in allocate_nodes self.nodes = self.cluster.alloc(self.cluster_spec)
> File "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/cluster.py",
> line 54, in alloc allocated = self.do_alloc(cluster_spec) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/finite_subcluster.py",
> line 37, in do_alloc good_nodes, bad_nodes =
> self._available_nodes.remove_spec(cluster_spec) File
> "/usr/local/lib/python3.9/dist-packages/ducktape/cluster/node_container.py",
> line 131, in remove_spec raise InsufficientResourcesError(err)
> ducktape.cluster.node_container.InsufficientResourcesError: linux nodes
> requested: 1. linux nodes available: 0 </error>
> ...{code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
