ydb/tests/fq/streaming/test_streaming.py:363: in test_pragma
inp, out, endpoint = self.get_io_names(kikimr, "test_pragma", local_topics, entity_name, partitions_count=10)
ydb/tests/fq/streaming/test_streaming.py:35: in get_io_names
self.create_source(kikimr, source_name, shared=shared)
ydb/tests/fq/streaming/common.py:65: in create_source
kikimr.ydb_client.query(f"""
ydb/tests/fq/streaming/common.py:31: in query
return self.session_pool.execute_with_retries(statement)
contrib/python/ydb/py3/ydb/query/pool.py:259: in execute_with_retries
return retry_operation_sync(wrapped_callee, retry_settings)
contrib/python/ydb/py3/ydb/retries.py:163: in retry_operation_sync
for next_opt in opt_generator:
contrib/python/ydb/py3/ydb/retries.py:153: in retry_operation_impl
raise status
contrib/python/ydb/py3/ydb/retries.py:118: in retry_operation_impl
result = YdbRetryOperationFinalResult(callee(*args, **kwargs))
contrib/python/ydb/py3/ydb/query/pool.py:257: in wrapped_callee
return [result_set for result_set in it]
contrib/python/ydb/py3/ydb/_utilities.py:176: in __next__
return self._next()
contrib/python/ydb/py3/ydb/query/base.py:89: in _next
raise e
contrib/python/ydb/py3/ydb/query/base.py:85: in _next
return super()._next()
contrib/python/ydb/py3/ydb/_utilities.py:167: in _next
res = self.wrapper(next(self.it))
contrib/python/ydb/py3/ydb/query/session.py:454: in <lambda>
lambda resp: base.wrap_execute_query_response(
contrib/python/ydb/py3/ydb/query/base.py:191: in decorator
return func(rpc_state, response_pb, session, *args, **kwargs)
contrib/python/ydb/py3/ydb/query/base.py:208: in wrap_execute_query_response
issues._process_response(response_pb)
contrib/python/ydb/py3/ydb/issues.py:266: in _process_response
raise exc_class(_format_response(response_proto), response_proto.issues)
E ydb.issues.Unavailable: message: "Executing operation with object \"EXTERNAL_DATA_SOURCE\"" issue_code: 2005 severity: 1 issues { message: "Failed to execute ESchemeOpCreateExternalDataSource: <main>: Error: Schemeshard not available, code: 2005\n" issue_code: 2005 severity: 1 } (server_code: 400050)
ydb/tests/fq/streaming/test_streaming.py:424: in test_raw_format
inp, out, endpoint = self.get_io_names(kikimr, "test_raw_format", local_topics, entity_name, partitions_count=10)
ydb/tests/fq/streaming/test_streaming.py:35: in get_io_names
self.create_source(kikimr, source_name, shared=shared)
ydb/tests/fq/streaming/common.py:65: in create_source
kikimr.ydb_client.query(f"""
ydb/tests/fq/streaming/common.py:31: in query
return self.session_pool.execute_with_retries(statement)
contrib/python/ydb/py3/ydb/query/pool.py:259: in execute_with_retries
return retry_operation_sync(wrapped_callee, retry_settings)
contrib/python/ydb/py3/ydb/retries.py:163: in retry_operation_sync
for next_opt in opt_generator:
contrib/python/ydb/py3/ydb/retries.py:153: in retry_operation_impl
raise status
contrib/python/ydb/py3/ydb/retries.py:118: in retry_operation_impl
result = YdbRetryOperationFinalResult(callee(*args, **kwargs))
contrib/python/ydb/py3/ydb/query/pool.py:257: in wrapped_callee
return [result_set for result_set in it]
contrib/python/ydb/py3/ydb/_utilities.py:176: in __next__
return self._next()
contrib/python/ydb/py3/ydb/query/base.py:89: in _next
raise e
contrib/python/ydb/py3/ydb/query/base.py:85: in _next
return super()._next()
contrib/python/ydb/py3/ydb/_utilities.py:167: in _next
res = self.wrapper(next(self.it))
contrib/python/ydb/py3/ydb/query/session.py:454: in <lambda>
lambda resp: base.wrap_execute_query_response(
contrib/python/ydb/py3/ydb/query/base.py:191: in decorator
return func(rpc_state, response_pb, session, *args, **kwargs)
contrib/python/ydb/py3/ydb/query/base.py:208: in wrap_execute_query_response
issues._process_response(response_pb)
contrib/python/ydb/py3/ydb/issues.py:266: in _process_response
raise exc_class(_format_response(response_proto), response_proto.issues)
E ydb.issues.Unavailable: message: "Executing operation with object \"EXTERNAL_DATA_SOURCE\"" issue_code: 2005 severity: 1 issues { message: "Failed to execute ESchemeOpCreateExternalDataSource: <main>: Error: Schemeshard not available, code: 2005\n" issue_code: 2005 severity: 1 } (server_code: 400050)teardown failed:
ydb/tests/fq/streaming/conftest.py:47: in kikimr
kikimr.stop()
ydb/tests/fq/streaming/common.py:55: in stop
self.cluster.stop()
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/streaming/test-results/py3test/testing_out_stuff/test_streaming.py.TestStreamingInYdb.test_restart_query.False/cluster/node_6/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/streaming/test-results/py3test/testing_out_stuff/test_streaming.py.TestStreamingInYdb.test_restart_query.False/cluster/node_6/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7F0E63094AC2
E 32. ??:0: ?? @ 0x7F0E631268BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 18. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/fu...
ydb/tests/fq/streaming/test_streaming.py:424: in test_raw_format
inp, out, endpoint = self.get_io_names(kikimr, "test_raw_format", local_topics, entity_name, partitions_count=10)
ydb/tests/fq/streaming/test_streaming.py:34: in get_io_names
self.init_topics(source_name, create_output=True, partitions_count=partitions_count, endpoint=endpoint)
ydb/tests/tools/datastreams_helpers/test_yds_base.py:23: in init_topics
create_stream(self.input_topic, partitions_count=partitions_count, default_endpoint=endpoint)
ydb/tests/tools/datastreams_helpers/control_plane.py:73: in create_stream
_get_and_check_result(response, datastreams_pb2.CreateStreamResult)
ydb/tests/tools/datastreams_helpers/control_plane.py:56: in _get_and_check_result
assert response.operation.status == StatusIds.SUCCESS, response
E AssertionError: operation {
E ready: true
E status: UNAVAILABLE
E issues {
E message: "Schemeshard not available"
E severity: 1
E }
E }
contrib/python/urllib3/py3/urllib3/connection.py:174: in _new_conn
conn = connection.create_connection(
contrib/python/urllib3/py3/urllib3/util/connection.py:95: in create_connection
raise err
contrib/python/urllib3/py3/urllib3/util/connection.py:85: in create_connection
sock.connect(sa)
E ConnectionRefusedError: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/urllib3/py3/urllib3/connectionpool.py:716: in urlopen
httplib_response = self._make_request(
contrib/python/urllib3/py3/urllib3/connectionpool.py:416: in _make_request
conn.request(method, url, **httplib_request_kw)
contrib/python/urllib3/py3/urllib3/connection.py:244: in request
super(HTTPConnection, self).request(method, url, body=body, headers=headers)
contrib/tools/python3/Lib/http/client.py:1358: in request
???
contrib/tools/python3/Lib/http/client.py:1404: in _send_request
???
contrib/tools/python3/Lib/http/client.py:1353: in endheaders
???
contrib/tools/python3/Lib/http/client.py:1113: in _send_output
???
contrib/tools/python3/Lib/http/client.py:1057: in send
???
contrib/python/urllib3/py3/urllib3/connection.py:205: in connect
conn = self._new_conn()
contrib/python/urllib3/py3/urllib3/connection.py:186: in _new_conn
raise NewConnectionError(
E urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x7f3297668a60>: Failed to establish a new connection: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/requests/py3/requests/adapters.py:644: in send
resp = conn.urlopen(
contrib/python/urllib3/py3/urllib3/connectionpool.py:802: in urlopen
retries = retries.increment(
contrib/python/urllib3/py3/urllib3/util/retry.py:594: in increment
raise MaxRetryError(_pool, url, error or ResponseError(cause))
E urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='localhost', port=7085): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f3297668a60>: Failed to establish a new connection: [Errno 111] Connection refused'))
During handling of the above exception, another exception occurred:
ydb/tests/fq/streaming/test_streaming.py:143: in test_read_topic_shared_reading_insert_to_topic
self.wait_completed_checkpoints(kikimr, path1)
ydb/tests/fq/streaming/common.py:104: in wait_completed_checkpoints
current = self.get_completed_checkpoints(kikimr, path)
ydb/tests/fq/streaming/common.py:101: in get_completed_checkpoints
return self.get_checkpoint_coordinator_metric(kikimr, path, "CompletedCheckpoints")
ydb/tests/fq/streaming/common.py:87: in get_checkpoint_coordinator_metric
sensor = self.get_sensors(kikimr, node_id, "kqp").find_sensor(
ydb/tests/fq/streaming/common.py:81: in get_sensors
return load_metrics(url)
library/python/retry/__init__.py:199: in wrapped
return _retry(conf, functools.partial(f, *f_args, **f_kwargs))
library/python/retry/__init__.py:224: in _retry
return f()
ydb/tests/tools/fq_runner/kikimr_metrics.py:46: in load_metrics
response = requests.get(url)
contrib/python/requests/py3/requests/api.py:73: in get
return request("get", url, params=params, **kwargs)
contrib/python/requests/py3/requests/api.py:59: in request
return session.request(method=method, url=url, **kwargs)
contrib/python/requests/py3/requests/sessions.py:589: in request
resp = self.send(prep, **send_kwargs)
contrib/python/requests/py3/requests/sessions.py:703: in send
r = adapter.send(request, **kwargs)
contrib/python/requests/py3/requests/adapters.py:677: in send
raise ConnectionError(e, request=request)
E requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', port=7085): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f3297668a60>: Failed to establish a new connection: [Errno 111] Connection refused'))
ydb/tests/fq/streaming/test_streaming.py:108: in test_restart_query
assert self.read_stream(len(expected_data), topic_path=self.output_topic, endpoint=endpoint) == expected_data
E AssertionError: assert [] == ['lunch time']
E
E Right contains one more item: 'lunch time'
E
E Full diff:
E + []
E - [
E - 'lunch time',
E - ]
ydb/tests/fq/streaming/test_streaming.py:389: in test_types
inp, out, endpoint = self.get_io_names(kikimr, "test_types", local_topics, entity_name, partitions_count=1)
ydb/tests/fq/streaming/test_streaming.py:35: in get_io_names
self.create_source(kikimr, source_name, shared=shared)
ydb/tests/fq/streaming/common.py:65: in create_source
kikimr.ydb_client.query(f"""
ydb/tests/fq/streaming/common.py:31: in query
return self.session_pool.execute_with_retries(statement)
contrib/python/ydb/py3/ydb/query/pool.py:259: in execute_with_retries
return retry_operation_sync(wrapped_callee, retry_settings)
contrib/python/ydb/py3/ydb/retries.py:163: in retry_operation_sync
for next_opt in opt_generator:
contrib/python/ydb/py3/ydb/retries.py:153: in retry_operation_impl
raise status
contrib/python/ydb/py3/ydb/retries.py:118: in retry_operation_impl
result = YdbRetryOperationFinalResult(callee(*args, **kwargs))
contrib/python/ydb/py3/ydb/query/pool.py:257: in wrapped_callee
return [result_set for result_set in it]
contrib/python/ydb/py3/ydb/_utilities.py:176: in __next__
return self._next()
contrib/python/ydb/py3/ydb/query/base.py:89: in _next
raise e
contrib/python/ydb/py3/ydb/query/base.py:85: in _next
return super()._next()
contrib/python/ydb/py3/ydb/_utilities.py:167: in _next
res = self.wrapper(next(self.it))
contrib/python/ydb/py3/ydb/query/session.py:454: in <lambda>
lambda resp: base.wrap_execute_query_response(
contrib/python/ydb/py3/ydb/query/base.py:191: in decorator
return func(rpc_state, response_pb, session, *args, **kwargs)
contrib/python/ydb/py3/ydb/query/base.py:208: in wrap_execute_query_response
issues._process_response(response_pb)
contrib/python/ydb/py3/ydb/issues.py:266: in _process_response
raise exc_class(_format_response(response_proto), response_proto.issues)
E ydb.issues.Unavailable: message: "Executing operation with object \"EXTERNAL_DATA_SOURCE\"" issue_code: 2005 severity: 1 issues { message: "Failed to execute ESchemeOpCreateExternalDataSource: <main>: Error: Schemeshard not available, code: 2005\n" issue_code: 2005 severity: 1 } (server_code: 400050)
ydb/tests/fq/streaming/test_streaming.py:491: [E303] too many blank lines (2)
ydb/tests/fq/streaming/test_streaming.py:540: [W292] no newline at end of file
ydb/tests/fq/streaming/test_watermarks.py:98: in test_watermarks
assert sorted(actual) == expected
E assert [] == ['[["1970-01-...00:00:50Z"]]']
E
E Right contains 2 more items, first extra item: '[["1970-01-01T00:00:40Z"]]'
E
E Full diff:
E + []
E - [
E - '[["1970-01-01T00:00:40Z"]]',
E - '[["1970-01-01T00:00:50Z"]]',
E - ]
contrib/python/urllib3/py3/urllib3/connection.py:174: in _new_conn
conn = connection.create_connection(
contrib/python/urllib3/py3/urllib3/util/connection.py:95: in create_connection
raise err
contrib/python/urllib3/py3/urllib3/util/connection.py:85: in create_connection
sock.connect(sa)
E ConnectionRefusedError: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/urllib3/py3/urllib3/connectionpool.py:716: in urlopen
httplib_response = self._make_request(
contrib/python/urllib3/py3/urllib3/connectionpool.py:416: in _make_request
conn.request(method, url, **httplib_request_kw)
contrib/python/urllib3/py3/urllib3/connection.py:244: in request
super(HTTPConnection, self).request(method, url, body=body, headers=headers)
contrib/tools/python3/Lib/http/client.py:1358: in request
???
contrib/tools/python3/Lib/http/client.py:1404: in _send_request
???
contrib/tools/python3/Lib/http/client.py:1353: in endheaders
???
contrib/tools/python3/Lib/http/client.py:1113: in _send_output
???
contrib/tools/python3/Lib/http/client.py:1057: in send
???
contrib/python/urllib3/py3/urllib3/connection.py:205: in connect
conn = self._new_conn()
contrib/python/urllib3/py3/urllib3/connection.py:186: in _new_conn
raise NewConnectionError(
E urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x7f329766a060>: Failed to establish a new connection: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/requests/py3/requests/adapters.py:644: in send
resp = conn.urlopen(
contrib/python/urllib3/py3/urllib3/connectionpool.py:802: in urlopen
retries = retries.increment(
contrib/python/urllib3/py3/urllib3/util/retry.py:594: in increment
raise MaxRetryError(_pool, url, error or ResponseError(cause))
E urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329766a060>: Failed to establish a new connection: [Errno 111] Connection refused'))
During handling of the above exception, another exception occurred:
ydb/tests/fq/streaming/test_watermarks.py:81: in test_watermarks
self.wait_completed_checkpoints(kikimr, f"/Root/{query_name}")
ydb/tests/fq/streaming/common.py:104: in wait_completed_checkpoints
current = self.get_completed_checkpoints(kikimr, path)
ydb/tests/fq/streaming/common.py:101: in get_completed_checkpoints
return self.get_checkpoint_coordinator_metric(kikimr, path, "CompletedCheckpoints")
ydb/tests/fq/streaming/common.py:87: in get_checkpoint_coordinator_metric
sensor = self.get_sensors(kikimr, node_id, "kqp").find_sensor(
ydb/tests/fq/streaming/common.py:81: in get_sensors
return load_metrics(url)
library/python/retry/__init__.py:199: in wrapped
return _retry(conf, functools.partial(f, *f_args, **f_kwargs))
library/python/retry/__init__.py:224: in _retry
return f()
ydb/tests/tools/fq_runner/kikimr_metrics.py:46: in load_metrics
response = requests.get(url)
contrib/python/requests/py3/requests/api.py:73: in get
return request("get", url, params=params, **kwargs)
contrib/python/requests/py3/requests/api.py:59: in request
return session.request(method=method, url=url, **kwargs)
contrib/python/requests/py3/requests/sessions.py:589: in request
resp = self.send(prep, **send_kwargs)
contrib/python/requests/py3/requests/sessions.py:703: in send
r = adapter.send(request, **kwargs)
contrib/python/requests/py3/requests/adapters.py:677: in send
raise ConnectionError(e, request=request)
E requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329766a060>: Failed to establish a new connection: [Errno 111] Connection refused'))
contrib/python/urllib3/py3/urllib3/connection.py:174: in _new_conn
conn = connection.create_connection(
contrib/python/urllib3/py3/urllib3/util/connection.py:95: in create_connection
raise err
contrib/python/urllib3/py3/urllib3/util/connection.py:85: in create_connection
sock.connect(sa)
E ConnectionRefusedError: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/urllib3/py3/urllib3/connectionpool.py:716: in urlopen
httplib_response = self._make_request(
contrib/python/urllib3/py3/urllib3/connectionpool.py:416: in _make_request
conn.request(method, url, **httplib_request_kw)
contrib/python/urllib3/py3/urllib3/connection.py:244: in request
super(HTTPConnection, self).request(method, url, body=body, headers=headers)
contrib/tools/python3/Lib/http/client.py:1358: in request
???
contrib/tools/python3/Lib/http/client.py:1404: in _send_request
???
contrib/tools/python3/Lib/http/client.py:1353: in endheaders
???
contrib/tools/python3/Lib/http/client.py:1113: in _send_output
???
contrib/tools/python3/Lib/http/client.py:1057: in send
???
contrib/python/urllib3/py3/urllib3/connection.py:205: in connect
conn = self._new_conn()
contrib/python/urllib3/py3/urllib3/connection.py:186: in _new_conn
raise NewConnectionError(
E urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x7f329763b260>: Failed to establish a new connection: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/requests/py3/requests/adapters.py:644: in send
resp = conn.urlopen(
contrib/python/urllib3/py3/urllib3/connectionpool.py:802: in urlopen
retries = retries.increment(
contrib/python/urllib3/py3/urllib3/util/retry.py:594: in increment
raise MaxRetryError(_pool, url, error or ResponseError(cause))
E urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329763b260>: Failed to establish a new connection: [Errno 111] Connection refused'))
During handling of the above exception, another exception occurred:
ydb/tests/fq/streaming/test_watermarks.py:81: in test_watermarks
self.wait_completed_checkpoints(kikimr, f"/Root/{query_name}")
ydb/tests/fq/streaming/common.py:104: in wait_completed_checkpoints
current = self.get_completed_checkpoints(kikimr, path)
ydb/tests/fq/streaming/common.py:101: in get_completed_checkpoints
return self.get_checkpoint_coordinator_metric(kikimr, path, "CompletedCheckpoints")
ydb/tests/fq/streaming/common.py:87: in get_checkpoint_coordinator_metric
sensor = self.get_sensors(kikimr, node_id, "kqp").find_sensor(
ydb/tests/fq/streaming/common.py:81: in get_sensors
return load_metrics(url)
library/python/retry/__init__.py:199: in wrapped
return _retry(conf, functools.partial(f, *f_args, **f_kwargs))
library/python/retry/__init__.py:224: in _retry
return f()
ydb/tests/tools/fq_runner/kikimr_metrics.py:46: in load_metrics
response = requests.get(url)
contrib/python/requests/py3/requests/api.py:73: in get
return request("get", url, params=params, **kwargs)
contrib/python/requests/py3/requests/api.py:59: in request
return session.request(method=method, url=url, **kwargs)
contrib/python/requests/py3/requests/sessions.py:589: in request
resp = self.send(prep, **send_kwargs)
contrib/python/requests/py3/requests/sessions.py:703: in send
r = adapter.send(request, **kwargs)
contrib/python/requests/py3/requests/adapters.py:677: in send
raise ConnectionError(e, request=request)
E requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329763b260>: Failed to establish a new connection: [Errno 111] Connection refused'))
contrib/python/urllib3/py3/urllib3/connection.py:174: in _new_conn
conn = connection.create_connection(
contrib/python/urllib3/py3/urllib3/util/connection.py:95: in create_connection
raise err
contrib/python/urllib3/py3/urllib3/util/connection.py:85: in create_connection
sock.connect(sa)
E ConnectionRefusedError: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/urllib3/py3/urllib3/connectionpool.py:716: in urlopen
httplib_response = self._make_request(
contrib/python/urllib3/py3/urllib3/connectionpool.py:416: in _make_request
conn.request(method, url, **httplib_request_kw)
contrib/python/urllib3/py3/urllib3/connection.py:244: in request
super(HTTPConnection, self).request(method, url, body=body, headers=headers)
contrib/tools/python3/Lib/http/client.py:1358: in request
???
contrib/tools/python3/Lib/http/client.py:1404: in _send_request
???
contrib/tools/python3/Lib/http/client.py:1353: in endheaders
???
contrib/tools/python3/Lib/http/client.py:1113: in _send_output
???
contrib/tools/python3/Lib/http/client.py:1057: in send
???
contrib/python/urllib3/py3/urllib3/connection.py:205: in connect
conn = self._new_conn()
contrib/python/urllib3/py3/urllib3/connection.py:186: in _new_conn
raise NewConnectionError(
E urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x7f329803bc60>: Failed to establish a new connection: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
contrib/python/requests/py3/requests/adapters.py:644: in send
resp = conn.urlopen(
contrib/python/urllib3/py3/urllib3/connectionpool.py:802: in urlopen
retries = retries.increment(
contrib/python/urllib3/py3/urllib3/util/retry.py:594: in increment
raise MaxRetryError(_pool, url, error or ResponseError(cause))
E urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329803bc60>: Failed to establish a new connection: [Errno 111] Connection refused'))
During handling of the above exception, another exception occurred:
ydb/tests/fq/streaming/test_watermarks.py:81: in test_watermarks
self.wait_completed_checkpoints(kikimr, f"/Root/{query_name}")
ydb/tests/fq/streaming/common.py:104: in wait_completed_checkpoints
current = self.get_completed_checkpoints(kikimr, path)
ydb/tests/fq/streaming/common.py:101: in get_completed_checkpoints
return self.get_checkpoint_coordinator_metric(kikimr, path, "CompletedCheckpoints")
ydb/tests/fq/streaming/common.py:87: in get_checkpoint_coordinator_metric
sensor = self.get_sensors(kikimr, node_id, "kqp").find_sensor(
ydb/tests/fq/streaming/common.py:81: in get_sensors
return load_metrics(url)
library/python/retry/__init__.py:199: in wrapped
return _retry(conf, functools.partial(f, *f_args, **f_kwargs))
library/python/retry/__init__.py:224: in _retry
return f()
ydb/tests/tools/fq_runner/kikimr_metrics.py:46: in load_metrics
response = requests.get(url)
contrib/python/requests/py3/requests/api.py:73: in get
return request("get", url, params=params, **kwargs)
contrib/python/requests/py3/requests/api.py:59: in request
return session.request(method=method, url=url, **kwargs)
contrib/python/requests/py3/requests/sessions.py:589: in request
resp = self.send(prep, **send_kwargs)
contrib/python/requests/py3/requests/sessions.py:703: in send
r = adapter.send(request, **kwargs)
contrib/python/requests/py3/requests/adapters.py:677: in send
raise ConnectionError(e, request=request)
E requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', port=22440): Max retries exceeded with url: /counters/counters=kqp/json (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7f329803bc60>: Failed to establish a new connection: [Errno 111] Connection refused'))teardown failed:
ydb/tests/fq/streaming/conftest.py:47: in kikimr
kikimr.stop()
ydb/tests/fq/streaming/common.py:55: in stop
self.cluster.stop()
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Proc
..[snippet truncated]..
FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7F4D7CC90AC2
E 32. ??:0: ?? @ 0x7F4D7CD228BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 18. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 19. /-S/contrib/libs/...
ydb/tests/fq/yds/test_bad_syntax.py:60: in test_bad_syntax
client.wait_query(query_id, statuses=[fq.QueryMeta.COMPLETED])
ydb/tests/tools/fq_runner/fq_client.py:312: in wait_query
assert time.time() < deadline and status not in final_statuses, \
E AssertionError: Query ptqudksanl4f51hafgvi is not in expected status (['COMPLETED']) for already 1.048041820526123 seconds. Query status: FAILED. Issues: [message: "Query failed with code BAD_REQUEST at 2026-02-18T18:25:44.199988Z"
E severity: 1
E issues {
E message: "(NYdb::Dev::TContractViolation) Cannot provide SeqNo on Write() when deduplication is disabled (appeared 1 time at 2026-02-18T18:25:44.183860Z)"
E severity: 1
E }
E ]. Transient issues: []
ydb/tests/fq/yds/test_bad_syntax.py:60: in test_bad_syntax
client.wait_query(query_id, statuses=[fq.QueryMeta.COMPLETED])
ydb/tests/tools/fq_runner/fq_client.py:312: in wait_query
assert time.time() < deadline and status not in final_statuses, \
E AssertionError: Query ptqudksan0jlrlnsm7hl is not in expected status (['COMPLETED']) for already 1.5197410583496094 seconds. Query status: FAILED. Issues: [message: "Query failed with code BAD_REQUEST at 2026-02-18T18:26:02.722115Z"
E severity: 1
E issues {
E message: "(NYdb::Dev::TContractViolation) Cannot provide SeqNo on Write() when deduplication is disabled (appeared 1 time at 2026-02-18T18:26:02.714964Z)"
E severity: 1
E }
E ]. Transient issues: []
ydb/tests/fq/yds/test_big_state.py:77: in test_gt_8mb
assert actual_messages == expected_messages
E assert [] == ['{"cnt" = 1u...FFFFF"}', ...]
E
E Right contains 12 more items, first extra item: '{"cnt" = 1u; "key" = "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA...AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"}'
E
E Full diff:
E + []
E - [
E - '{"cnt" = 1u; "key" = '
E - '"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA...
ydb/tests/fq/yds/test_continue_mode.py:55: in test_continue_from_offsets
assert read_stream(output_topic_1, len(data), consumer_name=consumer_1) == data
E AssertionError: assert [] == ['1', '2']
E
E Right contains 2 more items, first extra item: '1'
E
E Full diff:
E + []
E - [
E - '1',
E - '2',
E - ]
ydb/tests/fq/yds/test_disposition.py:157: in test_disposition_from_time
query_id = run(["1", "2"], ["1", "2"], None)
ydb/tests/fq/yds/test_disposition.py:150: in run
assert self.read_stream(len(output)) == output
E AssertionError: assert [] == ['1', '2']
E
E Right contains 2 more items, first extra item: '1'
E
E Full diff:
E + []
E - [
E - '1',
E - '2',
E - ]teardown failed:
ydb/tests/fq/yds/conftest.py:36: in kikimr
with start_kikimr(request, kikimr_extensions) as kikimr:
contrib/tools/python3/Lib/contextlib.py:148: in __exit__
next(self.gen)
ydb/tests/tools/fq_runner/kikimr_utils.py:426: in start_kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_from_time.v1-mvp_external_ydb_endpoint0/default/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_from_time.v1-mvp_external_ydb_endpoint0/default/node_1/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7F2EB5923AC2
E 32. ??:0: ?? @ 0x7F2EB59B58BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/l...
ydb/tests/fq/yds/test_disposition.py:60: in test_disposition_oldest
query_id = run(["1", "2"], ["1", "2"], None)
ydb/tests/fq/yds/test_disposition.py:53: in run
assert self.read_stream(len(output)) == output
E AssertionError: assert [] == ['1', '2']
E
E Right contains 2 more items, first extra item: '1'
E
E Full diff:
E + []
E - [
E - '1',
E - '2',
E - ]teardown failed:
ydb/tests/fq/yds/conftest.py:36: in kikimr
with start_kikimr(request, kikimr_extensions) as kikimr:
contrib/tools/python3/Lib/contextlib.py:148: in __exit__
next(self.gen)
ydb/tests/tools/fq_runner/kikimr_utils.py:426: in start_kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_oldest.v1-mvp_external_ydb_endpoint0/default/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_oldest.v1-mvp_external_ydb_endpoint0/default/node_1/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7FB14EEBAAC2
E 32. ??:0: ?? @ 0x7FB14EF4C8BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/...
ydb/tests/fq/yds/test_disposition.py:208: in test_disposition_time_ago
query_id = run(["1", "2"], ["1", "2"], None)
ydb/tests/fq/yds/test_disposition.py:195: in run
client.wait_query_status(query_id, fq.QueryMeta.RUNNING)
ydb/tests/tools/fq_runner/fq_client.py:327: in wait_query_status
return self.wait_query(query_id, timeout, statuses=statuses).query.meta.status
ydb/tests/tools/fq_runner/fq_client.py:308: in wait_query
response = self.describe_query(query_id)
library/python/retry/__init__.py:214: in wrapped
return _retry(obj.retry_conf, functools.partial(f, obj, *f_args, **f_kwargs))
library/python/retry/__init__.py:224: in _retry
return f()
ydb/tests/tools/fq_runner/fq_client.py:276: in describe_query
response = self.service.DescribeQuery(
contrib/python/grpcio/py3/grpc/_channel.py:1181: in __call__
return _end_unary_response_blocking(state, call, False, None)
contrib/python/grpcio/py3/grpc/_channel.py:1006: in _end_unary_response_blocking
raise _InactiveRpcError(state) # pytype: disable=not-instantiable
E grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
E status = StatusCode.UNAVAILABLE
E details = "failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.0.1:8274: Failed to connect to remote host: Connection refused"
E debug_error_string = "UNKNOWN:failed to connect to all addresses; last error: UNKNOWN: ipv4:127.0.0.1:8274: Failed to connect to remote host: Connection refused {grpc_status:14, created_time:"2026-02-18T18:27:24.13346846+00:00", file_line:153, file:"contrib/libs/grpc/src/core/lib/transport/error_utils.cc"}"
E >teardown failed:
ydb/tests/fq/yds/conftest.py:36: in kikimr
with start_kikimr(request, kikimr_extensions) as kikimr:
contrib/tools/python3/Lib/contextlib.py:148: in __exit__
next(self.gen)
ydb/tests/tools/fq_runner/kikimr_utils.py:426: in start_kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_time_ago.v1-mvp_external_ydb_endpoint0/default/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_disposition.py.TestDisposition.test_disposition_time_ago.v1-mvp_external_ydb_endpoint0/default/node_1/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7FDCD1EAEAC2
E 32. ??:0: ?? @ 0x7FDCD1F408BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/lib...
ydb/tests/fq/yds/test_kill_pq_bill.py:49: in test_do_not_bill_pq
client.wait_query_status(query_id, fq.QueryMeta.ABORTED_BY_USER)
ydb/tests/tools/fq_runner/fq_client.py:327: in wait_query_status
return self.wait_query(query_id, timeout, statuses=statuses).query.meta.status
ydb/tests/tools/fq_runner/fq_client.py:312: in wait_query
assert time.time() < deadline and status not in final_statuses, \
E AssertionError: Query ptqudksan0fjbiunf82d is not in expected status (['ABORTED_BY_USER']) for already 0.00439763069152832 seconds. Query status: FAILED. Issues: [message: "Query failed with code BAD_REQUEST at 2026-02-18T18:26:02.843669Z"
E severity: 1
E issues {
E message: "(NYdb::Dev::TContractViolation) Cannot provide SeqNo on Write() when deduplication is disabled (appeared 1 time at 2026-02-18T18:26:02.837229Z)"
E severity: 1
E }
E ]. Transient issues: []
ydb/tests/fq/yds/test_pq_read_write.py:143: in test_pq_read_schema_metadata
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"field1":"...,"field3":1}']
E
E Right contains 2 more items, first extra item: '{"field1":"value1","field2":105,"field3":0}'
E
E Full diff:
E + []
E - [
E - '{"field1":"value1","field2":105,"field3":0}',
E - '{"field1":"value2","field2":106,"field3":1}',
E - ]
ydb/tests/fq/yds/test_pq_read_write.py:143: in test_pq_read_schema_metadata
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"field1":"...,"field3":1}']
E
E Right contains 2 more items, first extra item: '{"field1":"value1","field2":105,"field3":0}'
E
E Full diff:
E + []
E - [
E - '{"field1":"value1","field2":105,"field3":0}',
E - '{"field1":"value2","field2":106,"field3":1}',
E - ]
ydb/tests/fq/yds/test_public_metrics.py:97: in test_select_unlimited
assert self.read_stream(len(data)) == data
E AssertionError: assert [] == ['A', 'B', 'C', 'D']
E
E Right contains 4 more items, first extra item: 'A'
E
E Full diff:
E + []
E - [
E - 'A',
E - 'B',
E - 'C',
E - 'D',
E - ]
ydb/tests/fq/yds/test_read_rules_deletion.py:51: in test_delete_read_rules
assert len(read_rules) == 1, read_rules
E AssertionError: []
E assert 0 == 1
E + where 0 = len([])
ydb/tests/fq/yds/test_read_rules_deletion.py:51: in test_delete_read_rules
assert len(read_rules) == 1, read_rules
E AssertionError: []
E assert 0 == 1
E + where 0 = len([])
ydb/tests/fq/yds/test_recovery.py:187: in test_program_state_recovery
assert received == expected
E assert [] == ['{"sum" = 52...sum" = 620u}']
E
E Right contains 3 more items, first extra item: '{"sum" = 520u}'
E
E Full diff:
E + []
E - [
E - '{"sum" = 520u}',
E - '{"sum" = 570u}',
E - '{"sum" = 620u}',
E - ]
ydb/tests/fq/yds/test_recovery_match_recognize.py:219: in test_match_recognize
self.recovery_impl(
ydb/tests/fq/yds/test_recovery_match_recognize.py:115: in recovery_impl
assert read_data == expected
E assert [] == ['{"a_str":"A...49943000001}']
E
E Right contains one more item: '{"a_str":"A","b_str":"B","c_str":"C","dt_begin":1696849942000001,"dt_end":1696849943000001}'
E
E Full diff:
E + []
E - [
E - '{"a_str":"A","b_str":"B","c_str":"C","dt_begin":1696849942000001,"dt_end":1696849943000001}',
E - ]teardown failed:
ydb/tests/fq/yds/test_recovery_match_recognize.py:29: in kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_recovery_match_recognize.py.TestRecoveryMatchRecognize.test_match_recognize.v1-kikimr0/compute/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_recovery_match_recognize.py.TestRecoveryMatchRecognize.test_match_recognize.v1-kikimr0/compute/node_1/stderr
E Stderr content:
E
E E0218 18:25:39.836084943 1026368 dns_resolver_ares.cc:452] no server name supplied in dns URI
E E0218 18:25:39.836202472 1026368 channel.cc:120] channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E E0218 18:25:55.878611900 1033961 dns_resolver_ares.cc:452] no server name supplied in dns URI
E E0218 18:25:55.878701122 1033961 channel.cc:120] channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7F782B7CCAC2
E 32. ??:0: ?? @ 0x7F782B85E8BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::...
ydb/tests/fq/yds/test_recovery_match_recognize.py:159: in test_time_order_recoverer
self.recovery_impl(
ydb/tests/fq/yds/test_recovery_match_recognize.py:115: in recovery_impl
assert read_data == expected
E assert [] == ['{"dt":16968...49942800000}']
E
E Right contains 3 more items, first extra item: '{"dt":1696849942000001}'
E
E Full diff:
E + []
E - [
E - '{"dt":1696849942000001}',
E - '{"dt":1696849942400002}',
E - '{"dt":1696849942800000}',
E - ]teardown failed:
ydb/tests/fq/yds/test_recovery_match_recognize.py:29: in kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_recovery_match_recognize.py.TestRecoveryMatchRecognize.test_time_order_recoverer.v1-kikimr0/compute/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_recovery_match_recognize.py.TestRecoveryMatchRecognize.test_time_order_recoverer.v1-kikimr0/compute/node_1/stderr
E Stderr content:
E
E E0218 18:26:36.467779949 1042647 dns_resolver_ares.cc:452] no server name supplied in dns URI
E E0218 18:26:36.467866339 1042647 channel.cc:120] channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E E0218 18:26:41.022847526 1042906 dns_resolver_ares.cc:452] no server name supplied in dns URI
E E0218 18:26:41.022915647 1042906 channel.cc:120] channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E :GRPC_LIBRARY ERROR: no server name supplied in dns URI
E :GRPC_LIBRARY ERROR: channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7FCF76584AC2
E 32. ??:0: ?? @ 0x7FCF766168BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev...
ydb/tests/fq/yds/test_restart_query.py:47: in test_restart_runtime_errors
assert self.read_stream(len(data)) == data
E AssertionError: assert [] == ['data']
E
E Right contains one more item: 'data'
E
E Full diff:
E + []
E - [
E - 'data',
E - ]
ydb/tests/fq/yds/test_restart_query.py:47: in test_restart_runtime_errors
assert self.read_stream(len(data)) == data
E AssertionError: assert [] == ['data']
E
E Right contains one more item: 'data'
E
E Full diff:
E + []
E - [
E - 'data',
E - ]teardown failed:
ydb/tests/fq/yds/conftest.py:62: in kikimr_many_retries
with start_kikimr(request, kikimr_extensions) as kikimr:
contrib/tools/python3/Lib/contextlib.py:148: in __exit__
next(self.gen)
ydb/tests/tools/fq_runner/kikimr_utils.py:426: in start_kikimr
kikimr.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:749: in stop
tenant.stop()
ydb/tests/tools/fq_runner/kikimr_runner.py:62: in stop
self.kikimr_cluster.stop(kill=False)
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_restart_query.py.TestRestartQuery.test_restart_runtime_errors.v1-mvp_external_ydb_endpoint0-streaming/default/node_1/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/fq/yds/test-results/py3test/testing_out_stuff/test_restart_query.py.TestRestartQuery.test_restart_runtime_errors.v1-mvp_external_ydb_endpoint0-streaming/default/node_1/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7FCF047E1AC2
E 32. ??:0: ?? @ 0x7FCF048738BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x...
ydb/tests/fq/yds/test_row_dispatcher.py:969: in test_2_connection
assert sorted(self.read_stream(len(expected), topic_path=self.output_topic)) == expected
E AssertionError: assert [] == ['100', '100'...', '102', ...]
E
E Right contains 40 more items, first extra item: '100'
E
E Full diff:
E + []
E - [
E - '100',
E - '100',
E - '101',
E - '101',
E - '102',
E - '102',
E - '103',
E - '103',
E - '104',
E - '104',
E - '105',
E - '105',
E - '106',
E - '106',
E - '107',
E - '107',
E - '108',
E - '108',
E - '109',
E - '109',
E - '110',
E - '110',
E - '111',
E - '111',
E - '112',
E - '112',
E - '113',
E - '113',
E - '114',
E - '114',
E - '115',
E - '115',
E - '116',
E - '116',
E - '117',
E - '117',
E - '118',
E - '118',
E - '119',
E - '119',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:870: in test_3_sessions
assert self.read_stream(len(expected), topic_path=output_topic1) == expected
E assert [] == ['{"time":101...{"time":102}']
E
E Right contains 2 more items, first extra item: '{"time":101}'
E
E Full diff:
E + []
E - [
E - '{"time":101}',
E - '{"time":102}',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1279: in test_delete_topic
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['101', '102', '103']
E
E Right contains 3 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - '103',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:467: in test_filter_missing_fields
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['101', '102']
E
E Right contains 2 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:493: in test_filter_use_unsupported_predicate
assert self.read_stream(1, topic_path=self.output_topic) == ['102']
E AssertionError: assert [] == ['102']
E
E Right contains one more item: '102'
E
E Full diff:
E + []
E - [
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:540: in test_filter_with_mr
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E assert [] == ['{"event_type":2}']
E
E Right contains one more item: '{"event_type":2}'
E
E Full diff:
E + []
E - [
E - '{"event_type":2}',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:359: in test_filters_non_optional_field
self.run_and_check(kikimr, client, sql + filter, data, expected, 'predicate: (`time` > 101)')
ydb/tests/fq/yds/test_row_dispatcher.py:125: in run_and_check
assert self.read_stream(len(output), topic_path=self.output_topic) == output
E AssertionError: assert [] == ['102']
E
E Right contains one more item: '102'
E
E Full diff:
E + []
E - [
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:401: in test_filters_optional_field
self.run_and_check(kikimr, client, sql + filter, data, expected, 'predicate: (`data` = \\"hello2\\")')
ydb/tests/fq/yds/test_row_dispatcher.py:125: in run_and_check
assert self.read_stream(len(output), topic_path=self.output_topic) == output
E AssertionError: assert [] == ['102']
E
E Right contains one more item: '102'
E
E Full diff:
E + []
E - [
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1110: in test_group_by_hop_restart_node
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E assert [] == ['{"count":2,...T09:00:10Z"}']
E
E Right contains 2 more items, first extra item: '{"count":2,"project":"project1","time":"2025-04-23T09:00:10Z"}'
E
E Full diff:
E + []
E - [
E - '{"count":2,"project":"project1","time":"2025-04-23T09:00:10Z"}',
E - '{"count":1,"project":"project2","time":"2025-04-23T09:00:10Z"}',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1189: in test_huge_messages
assert received == expected
E assert [] == ['{"len":21,"...,"time":106}']
E
E Right contains 4 more items, first extra item: '{"len":21,"time":101}'
E
E Full diff:
E + []
E - [
E - '{"len":21,"time":101}',
E - '{"len":1000041,"time":102}',
E - '{"len":21,"time":105}',
E - '{"len":1000041,"time":106}',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1233: in test_json_errors
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['hello1_null...'hello3_null']
E
E Right contains 3 more items, first extra item: 'hello1_null'
E
E Full diff:
E + []
E - [
E - 'hello1_null',
E - 'hello2_null',
E - 'hello3_null',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1233: in test_json_errors
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['hello1_null...'hello3_null']
E
E Right contains 3 more items, first extra item: 'hello1_null'
E
E Full diff:
E + []
E - [
E - 'hello1_null',
E - 'hello2_null',
E - 'hello3_null',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:939: in test_many_partitions
assert sorted(self.read_stream(len(expected), topic_path=self.output_topic)) == expected
E AssertionError: assert [] == ['100', '101'...', '105', ...]
E
E Right contains 40 more items, first extra item: '100'
E
E Full diff:
E + []
E - [
E - '100',
E - '101',
E - '102',
E - '103',
E - '104',
E - '105',
E - '106',
E - '107',
E - '108',
E - '109',
E - '110',
E - '111',
E - '112',
E - '113',
E - '114',
E - '115',
E - '116',
E - '117',
E - '118',
E - '119',
E - '120',
E - '121',
E - '122',
E - '123',
E - '124',
E - '125',
E - '126',
E - '127',
E - '128',
E - '129',
E - '130',
E - '131',
E - '132',
E - '133',
E - '134',
E - '135',
E - '136',
E - '137',
E - '138',
E - '139',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:223: in test_metadatafields
assert len(self.read_stream(1, topic_path=self.output_topic)) == 1
E AssertionError: assert 0 == 1
E + where 0 = len([])
E + where [] = <bound method TestYdsBase.read_stream of <__tests__.test_row_dispatcher.TestPqRowDispatcher object at 0x7f5deaa55fe0>>(1, topic_path='test_metadatafields_output')
E + where <bound method TestYdsBase.read_stream of <__tests__.test_row_dispatcher.TestPqRowDispatcher object at 0x7f5deaa55fe0>> = <__tests__.test_row_dispatcher.TestPqRowDispatcher object at 0x7f5deaa55fe0>.read_stream
E + and 'test_metadatafields_output' = <__tests__.test_row_dispatcher.TestPqRowDispatcher object at 0x7f5deaa55fe0>.output_topic
ydb/tests/fq/yds/test_row_dispatcher.py:310: in test_nested_types
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E assert [] == ['{"key": "va...l1234567890"']
E
E Right contains 3 more items, first extra item: '{"key": "value", "second_key":"abcdefghjkl1234567890+abcdefghjkl1234567890"}'
E
E Full diff:
E + []
E - [
E - '{"key": "value", '
E - '"second_key":"abcdefghjkl1234567890+abcdefghjkl1234567890"}',
E - '["key1", "key2", "abcdefghjkl1234567890+abcdefghjkl1234567890"]',
E - '"abcdefghjkl1234567890+abcdefghjkl1234567890"',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:340: in test_nested_types_without_predicate
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E assert [] == ['{"key": "va...y1", "key2"]']
E
E Right contains 2 more items, first extra item: '{"key": "value"}'
E
E Full diff:
E + []
E - [
E - '{"key": "value"}',
E - '["key1", "key2"]',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:148: in test_read_raw_format_with_row_dispatcher
assert self.read_stream(len(data), topic_path=self.output_topic) == data
E assert [] == ['{"time" = 1...ime" = 102;}']
E
E Right contains 2 more items, first extra item: '{"time" = 101;}'
E
E Full diff:
E + []
E - [
E - '{"time" = 101;}',
E - '{"time" = 102;}',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1334: in test_redistribute_partition_after_timeout
assert self.read_stream(message_count, topic_path=self.output_topic) == [expected] * message_count
E AssertionError: assert [] == ['hello', 'he... 'hello', ...]
E
E Right contains 10 more items, first extra item: 'hello'
E
E Full diff:
E + []
E - [
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:1334: in test_redistribute_partition_after_timeout
assert self.read_stream(message_count, topic_path=self.output_topic) == [expected] * message_count
E AssertionError: assert [] == ['hello', 'he... 'hello', ...]
E
E Right contains 10 more items, first extra item: 'hello'
E
E Full diff:
E + []
E - [
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - 'hello',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:772: in test_restart_compute_node
assert sorted(self.read_stream(len(expected), topic_path=self.output_topic)) == expected
E AssertionError: assert [] == ['100', '101'...', '105', ...]
E
E Right contains 8 more items, first extra item: '100'
E
E Full diff:
E + []
E - [
E - '100',
E - '101',
E - '102',
E - '103',
E - '104',
E - '105',
E - '106',
E - '107',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:279: in test_scheme_error
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['101']
E
E Right contains one more item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:988: in test_sensors
assert self.read_stream(1, topic_path=self.output_topic) == ['101']
E AssertionError: assert [] == ['101']
E
E Right contains one more item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:184: in test_simple_not_null
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['101', '102', '103']
E
E Right contains 3 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - '103',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:242: in test_simple_optional
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['101', '102']
E
E Right contains 2 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:585: in test_start_new_query
assert self.read_stream(len(expected), topic_path=output_topic1) == expected
E AssertionError: assert [] == ['101', '102']
E
E Right contains 2 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:642: in test_stop_start
assert sorted(self.read_stream(len(expected), topic_path=self.output_topic)) == sorted(expected)
E AssertionError: assert [] == ['101', '102']
E
E Right contains 2 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:679: in test_stop_start2
assert sorted(self.read_stream(len(expected), topic_path=self.output_topic)) == sorted(expected)
E AssertionError: assert [] == ['101', '102']
E
E Right contains 2 more items, first extra item: '101'
E
E Full diff:
E + []
E - [
E - '101',
E - '102',
E - ]
ydb/tests/fq/yds/test_row_dispatcher.py:749: in test_stop_start_with_filter
assert self.read_stream(len(expected), topic_path=self.output_topic) == expected
E AssertionError: assert [] == ['203', '204']
E
E Right contains 2 more items, first extra item: '203'
E
E Full diff:
E + []
E - [
E - '203',
E - '204',
E - ]
ydb/tests/fq/yds/test_watermarks.py:180: in test_idle_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_watermarks.py:180: in test_idle_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_watermarks.py:180: in test_idle_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_watermarks.py:180: in test_idle_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_watermarks.py:109: in test_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_watermarks.py:109: in test_watermarks
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"result":[...00:00:42Z"]}']
E
E Right contains 2 more items, first extra item: '{"result":["1970-01-01T00:00:42Z"]}'
E
E Full diff:
E + []
E - [
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - '{"result":["1970-01-01T00:00:42Z"]}',
E - ]
ydb/tests/fq/yds/test_yq_streaming.py:282: in test_state_load_mode
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"Data" = "... = "hello";}']
E
E Right contains one more item: '{"Data" = "hello";}{"Data" = "hello";}'
E
E Full diff:
E + []
E - [
E - '{"Data" = "hello";}{"Data" = "hello";}',
E - ]
ydb/tests/fq/yds/test_yq_streaming.py:40: in test_yq_streaming
assert self.read_stream(len(expected)) == expected
E assert [] == ['{"Data" = "... = "hello";}']
E
E Right contains one more item: '{"Data" = "hello";}{"Data" = "hello";}'
E
E Full diff:
E + []
E - [
E - '{"Data" = "hello";}{"Data" = "hello";}',
E - ]
ydb/tests/fq/yds/test_yq_streaming.py:247: in test_yq_streaming_read_date_time_format
assert read_data == expected
E AssertionError: assert [] == ['abc2022-10-...19T16:40:48Z']
E
E Right contains 2 more items, first extra item: 'abc2022-10-19T16:40:47Z'
E
E Full diff:
E + []
E - [
E - 'abc2022-10-19T16:40:47Z',
E - 'xxx2022-10-19T16:40:48Z',
E - ]
ydb/tests/fq/yds/test_yq_streaming.py:108: in test_yq_streaming_read_from_binding
assert read_data == expected
E AssertionError: assert [] == ['abc', 'xxx']
E
E Right contains 2 more items, first extra item: 'abc'
E
E Full diff:
E + []
E - [
E - 'abc',
E - 'xxx',
E - ]
ydb/tests/fq/yds/test_yq_streaming.py:177: in test_yq_streaming_read_from_binding_date_time
assert read_data == expected
E AssertionError: assert [] == ['abc2022-10-...19T16:40:48Z']
E
E Right contains 2 more items, first extra item: 'abc2022-10-19T16:40:47Z'
E
E Full diff:
E + []
E - [
E - 'abc2022-10-19T16:40:47Z',
E - 'xxx2022-10-19T16:40:48Z',
E - ]
ydb/tests/stress/streaming/tests/test_workload.py:45: in test
yatest.common.execute(cmd, wait=True)
library/python/testing/yatest_common/yatest/common/process.py:656: in execute
res.wait(check_exit_code, timeout, on_timeout)
library/python/testing/yatest_common/yatest/common/process.py:411: in wait
self._finalise(check_exit_code)
library/python/testing/yatest_common/yatest/common/process.py:422: in _finalise
raise ExecutionError(self)
E yatest.common.process.ExecutionError: Command '/home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/stress/streaming/streaming --endpoint localhost:21540 --database /Root --duration 60 --partitions-count 10 --prefix streaming_stress' has failed with code 255.
E Errors:
E ...topic writer was stopped by call close
E 18:26:59,567 ydb._topic_writer.topic_writer_asyncio INFO Stop topic writer 8: topic writer was stopped by call close
E 18:26:59,568 ydb._topic_writer.topic_writer_asyncio INFO Stop topic writer 9: topic writer was stopped by call close
E 18:26:59,570 ydb._topic_writer.topic_writer_asyncio INFO Stop topic writer 10: topic writer was stopped by call close
E 18:26:59,572 ydb.tests.stress.streaming.workload INFO Workload::write_to_input_topic end
E 18:26:59,572 ydb.tests.stress.streaming.workload INFO Workload::read_from_output_topic
E 18:27:00,587 ydb.pool.Discovery INFO Successfully terminated discovery process
E Traceback (most recent call last):
E File "contrib/tools/python3/Lib/runpy.py", line 198, in _run_module_as_main
E return _run_code(code, main_globals, None,
E "__main__", mod_spec)
E File "contrib/tools/python3/Lib/runpy.py", line 88, in _run_code
E exec(code, run_globals)
E ~~~~^^^^^^^^^^^^^^^^^^^
E File "ydb/tests/stress/streaming/__main__.py", line 25, in <module>
E workload.loop()
E ~~~~~~~~~~~~~^^
E File "ydb/tests/stress/streaming/workload/__init__.py", line 141, in loop
E self.read_from_output_topic()
E ~~~~~~~~~~~~~~~~~~~~~~~~~~~^^
E File "ydb/tests/stress/streaming/workload/__init__.py", line 133, in read_from_output_topic
E raise Exception(f"Insufficient data in output topic: expected ~{expected} messages, got {count}")
E Exception: Insufficient data in output topic: expected ~60 messages, got 0teardown failed:
ydb/tests/stress/streaming/tests/test_workload.py:17: in setup
yield from self.setup_cluster(
ydb/tests/library/stress/fixtures.py:43: in setup_cluster
self.cluster.stop()
ydb/tests/library/harness/kikimr_runner.py:745: in stop
raise daemon.SeveralDaemonErrors(saved_exceptions)
E ydb.tests.library.harness.daemon.SeveralDaemonErrors: Daemon failed with message: Unexpectedly finished before stop.
E Process exit_code = -6.
E Stdout file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/stress/streaming/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbWorkload.test/cluster/node_5/stdout
E Stderr file name:
E /home/runner/actions_runner/_work/ydb/ydb/tmp/out/ydb/tests/stress/streaming/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbWorkload.test/cluster/node_5/stderr
E Stderr content:
E
E GRpc memory quota was set but disabled due to issues with grpc quoter, to enable it use EnableGRpcMemoryQuota option
E ======= terminate() call stack ========
E 0. /tmp//-S/ydb/core/driver_lib/run/main.cpp:182: KikimrTerminateHandler @ 0x15E10062
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:0: terminate @ 0xAC49418
E 2. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:821: report_failure @ 0xAC4999C
E 3. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:843: throw_exception @ 0xAC4999C
E 4. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 8. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 9. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 10. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 15. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 18. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 20. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 21. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 22. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x13026BE6
E 23. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x13026BE6
E 24. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x12048338
E 25. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x12048338
E 26. /-S/util/thread/pool.h:71: Process @ 0x12048338
E 27. /-S/util/thread/pool.cpp:246: DoExecute @ 0xB9FA696
E 28. /-S/util/thread/factory.h:15: Execute @ 0xB9F9C09
E 29. /-S/util/thread/factory.cpp:36: ThreadProc @ 0xB9F9C09
E 30. /-S/util/system/thread.cpp:245: ThreadProxy @ 0xACF4E0C
E 31. ??:0: ?? @ 0x7FCD57A34AC2
E 32. ??:0: ?? @ 0x7FCD57AC68BF
E ======== exception call stack =========
E 0. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:839: throw_exception @ 0xAC4985E
E 1. /tmp//-S/contrib/libs/cxxsupp/libcxxrt/exception.cc:882: __cxa_throw @ 0xAC49806
E 2. /tmp//-S/ydb/public/sdk/cpp/src/client/types/fatal_error_handlers/handlers.cpp:7: ?? @ 0xD9C6EB7
E 3. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:497: GetNextIdImpl @ 0x1301231E
E 4. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:640: WriteInternal @ 0x13013A56
E 5. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session.cpp:86: Write @ 0x13003FD9
E 6. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:423: MaybeWriteImpl @ 0x18C9FBEA
E 7. /tmp//-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:140: operator() @ 0x18CA29D5
E 8. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 9. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 10. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/federated_topic/impl/federated_write_session.cpp:131:31) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x18CA29D5
E 11. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:167: operator() @ 0x18CA29D5
E 12. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:319: operator() @ 0x18CA29D5
E 13. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:436: operator() @ 0x13026BE6
E 14. /-S/contrib/libs/cxxsupp/libcxx/include/__functional/function.h:995: operator() @ 0x13026BE6
E 15. /tmp//-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116: operator() @ 0x13026BE6
E 16. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:179: __invoke<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 17. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:251: __call<(lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 18. /-S/contrib/libs/cxxsupp/libcxx/include/__type_traits/invoke.h:273: __invoke_r<void, (lambda at /-S/ydb/public/sdk/cpp/src/client/topic/impl/write_session_impl.cpp:116:9) &, NYdb::Dev::NTopic::TWriteSessionEvent::TReadyToAcceptEvent &> @ 0x13026BE6
E 19. /-S/contrib/libs/cxxsupp/libcxx/include...