2025-11-10 09:36:45,208 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-11-10 09:36:45,209 - INFO - ya.test - pytest_runtest_setup: test_checkpoints_on_join_s3_with_yds[v1-mvp_external_ydb_endpoint0-client0]
2025-11-10 09:36:45,209 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-11-10 09:36:45,209 - INFO - ya.test - pytest_runtest_setup: Test setup
2025-11-10 09:36:46,211 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:63517/1
2025-11-10 09:36:46,216 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/9298
2025-11-10 09:36:46,217 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/14345
2025-11-10 09:36:46,217 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/10989
2025-11-10 09:36:46,218 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/63517
2025-11-10 09:36:46,218 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/29430
2025-11-10 09:36:46,218 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/15739
2025-11-10 09:36:53,220 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:27764/1
2025-11-10 09:36:53,300 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/63137
2025-11-10 09:36:53,301 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/30444
2025-11-10 09:36:53,301 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/9095
2025-11-10 09:36:53,301 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/27764
2025-11-10 09:36:53,302 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/24248
2025-11-10 09:36:54,305 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:5910/1
2025-11-10 09:36:54,306 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/14242
2025-11-10 09:36:54,306 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/10566
2025-11-10 09:36:54,306 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/25700
2025-11-10 09:36:54,306 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/5910
2025-11-10 09:36:54,306 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/63175
2025-11-10 09:36:54,307 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/18829
2025-11-10 09:36:54,309 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/17153
2025-11-10 09:36:54,321 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/26112
2025-11-10 09:36:54,408 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:54,491 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/3542
2025-11-10 09:36:54,493 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/15742
2025-11-10 09:36:54,493 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:54,496 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:36:54,496 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:54,504 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:36:54,543 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 9b09eec9-bbd2-4645-9ada-d1e33a4e83ce, localhost:12880): creating call state
2025-11-10 09:36:54,548 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 9b09eec9-bbd2-4645-9ada-d1e33a4e83ce, localhost:12880): request = { database: "local" }
2025-11-10 09:36:54,554 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 9b09eec9-bbd2-4645-9ada-d1e33a4e83ce, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:36:54,683 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:36:54,684 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:54,704 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:36:54,709 - DEBUG - ydb.table.SessionPool - subscribe: Active session queue is empty, subscribe waiter for a session
2025-11-10 09:36:54,758 - DEBUG - ydb.table.SessionPool - subscribe: Subscribe waiter <Future at 0x7f225331c880 state=pending>
2025-11-10 09:36:54,758 - DEBUG - ydb.table.SessionPool - subscribe: Session pool is not large enough (active_count < size: 0 < 1). will create a new session.
2025-11-10 09:36:54,764 - DEBUG - ydb.table.SessionPool - _create: Created session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,768 - DEBUG - ydb.table.SessionPool - _prepare: Preparing session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,769 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateSession, 551ff861-fd91-447c-b61e-c52020c6f504, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:54,770 - DEBUG - ydb.connection - _log_request: RpcState(CreateSession, 551ff861-fd91-447c-b61e-c52020c6f504, ghrun-kipqlopw2q.auto.internal:12880): request = { operation_params { operation_timeout { seconds: 3 } cancel_after { seconds: 3 } } }
2025-11-10 09:36:54,777 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 551ff861-fd91-447c-b61e-c52020c6f504, ghrun-kipqlopw2q.auto.internal:12880): on response callback started
2025-11-10 09:36:54,814 - DEBUG - ydb.connection - _log_response: RpcState(CreateSession, 551ff861-fd91-447c-b61e-c52020c6f504, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.CreateSessionResult] { session_id: "ydb://session/3?node_id=1&id=NjhmOTYzZjgtZjkyY2M5NzItMWM3YzgzN2MtYjQ5ZGQ0YWU=" } } } }
2025-11-10 09:36:54,814 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 551ff861-fd91-447c-b61e-c52020c6f504, ghrun-kipqlopw2q.auto.internal:12880): on response callback success
2025-11-10 09:36:54,814 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,815 - DEBUG - ydb.table.SessionPool - put: Replying to waiter with a session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,815 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, c61b95dd-9d77-45af-9058-2e1d1159353a, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:54,825 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, c61b95dd-9d77-45af-9058-2e1d1159353a, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=NjhmOTYzZjgtZjkyY2M5NzItMWM3YzgzN2MtYjQ5ZGQ0YWU=" path: "local/DbPoolStorage_6b599198-65f5-47b2-abc5-4af1aaf25e60/tenants" columns { name: "tenant" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "common" type { optional_type { item { type_id: BOOL } } } } columns { name: "state" type { optional_type { item { type_id: UINT32 } } } } columns { name: "state_time" type { optional_type { item { type_id: TIMESTAMP } } } } primary_key: "tenant" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:54,865 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, c61b95dd-9d77-45af-9058-2e1d1159353a, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS } }
2025-11-10 09:36:54,938 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,938 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, 4325a088-8dda-4181-9707-d1716a0c090b, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:54,939 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, 4325a088-8dda-4181-9707-d1716a0c090b, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=NjhmOTYzZjgtZjkyY2M5NzItMWM3YzgzN2MtYjQ5ZGQ0YWU=" path: "local/DbPoolStorage_6b599198-65f5-47b2-abc5-4af1aaf25e60/mappings" columns { name: "subject_type" type { optional_type { item { type_id: STRING } } } } columns { name: "subject_id" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "node" type { optional_type { item { type_id: STRING } } } } primary_key: "subject_type" primary_key: "subject_id" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:54,965 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, 4325a088-8dda-4181-9707-d1716a0c090b, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS } }
2025-11-10 09:36:54,966 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:54,967 - DEBUG - ydb.connection - _prepare_call: RpcState(ExecuteDataQuery, dfbafc67-0cda-4851-b02b-d7f638793e45, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:54,968 - DEBUG - ydb.connection - _log_request: RpcState(ExecuteDataQuery, dfbafc67-0cda-4851-b02b-d7f638793e45, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=NjhmOTYzZjgtZjkyY2M5NzItMWM3YzgzN2MtYjQ5ZGQ0YWU=" tx_control { begin_tx { serializable_read_write { } } commit_tx: true } query { yql_text: "--!syntax_v1\n            PRAGMA TablePathPrefix(\"local/DbPoolStorage_6b599198-65f5-47b2-abc5-4af1aaf25e60\");\n            UPSERT INTO tenants (tenant, vtenant, common, state, state_time) values(\"/default\", \"/default\", true, 0, CurrentUtcTimestamp());\n                " } operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:55,007 - DEBUG - ydb.connection - _log_response: RpcState(ExecuteDataQuery, dfbafc67-0cda-4851-b02b-d7f638793e45, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.ExecuteQueryResult] { tx_meta { } } } } }
2025-11-10 09:36:55,008 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f224821a9a0>
2025-11-10 09:36:55,193 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:55,207 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/12592
2025-11-10 09:36:55,208 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/15625
2025-11-10 09:36:55,208 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/29726
2025-11-10 09:36:55,212 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/kikimr_configs"
2025-11-10 09:36:55,268 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/default --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1/logfile_wfx6wlfn.log --grpc-port=15742 --mon-port=12592 --ic-port=3542
2025-11-10 09:36:55,269 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/kikimr_configs"
2025-11-10 09:36:55,269 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/default --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1/logfile_wfx6wlfn.log --grpc-port=15742 --mon-port=12592 --ic-port=3542
2025-11-10 09:36:55,271 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/kikimr_configs/config.yaml', '--node=1', '--tenant=/default', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1/logfile_wfx6wlfn.log', '--grpc-port=15742', '--mon-port=12592', '--ic-port=3542')' in '/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1' (no wait)
2025-11-10 09:36:55,322 - DEBUG - ya.test - execute: Command pid: 312564
2025-11-10 09:36:55,324 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:15742/1
2025-11-10 09:36:55,365 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.17
2025-11-10 09:36:55,366 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.17
2025-11-10 09:36:55,366 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-10 09:36:55,368 - DEBUG - ya.test - execute: Command pid: 312597
2025-11-10 09:36:56,233 - DEBUG - ya.test - _save_outputs: Command (pid 312597) rc: 0
2025-11-10 09:36:56,234 - DEBUG - ya.test - _save_outputs: Command (pid 312597) elapsed time (sec): 0.857433557510376
2025-11-10 09:36:56,234 - DEBUG - ya.test - _save_outputs: Command (pid 312597) idrss: 0
2025-11-10 09:36:56,234 - DEBUG - ya.test - _save_outputs: Command (pid 312597) inblock: 0
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) isrss: 0
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) ixrss: 0
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) majflt: 0
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) maxrss: 541024
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) minflt: 16171
2025-11-10 09:36:56,235 - DEBUG - ya.test - _save_outputs: Command (pid 312597) msgrcv: 0
2025-11-10 09:36:56,236 - DEBUG - ya.test - _save_outputs: Command (pid 312597) msgsnd: 0
2025-11-10 09:36:56,236 - DEBUG - ya.test - _save_outputs: Command (pid 312597) nivcsw: 82
2025-11-10 09:36:56,236 - DEBUG - ya.test - _save_outputs: Command (pid 312597) nsignals: 0
2025-11-10 09:36:56,236 - DEBUG - ya.test - _save_outputs: Command (pid 312597) nswap: 0
2025-11-10 09:36:56,236 - DEBUG - ya.test - _save_outputs: Command (pid 312597) nvcsw: 16
2025-11-10 09:36:56,237 - DEBUG - ya.test - _save_outputs: Command (pid 312597) oublock: 8
2025-11-10 09:36:56,238 - DEBUG - ya.test - _save_outputs: Command (pid 312597) stime: 0.24344
2025-11-10 09:36:56,238 - DEBUG - ya.test - _save_outputs: Command (pid 312597) utime: 0.149205
2025-11-10 09:36:56,238 - DEBUG - ya.test - _save_outputs: Command (pid 312597) wtime: 0.859
2025-11-10 09:36:56,238 - DEBUG - ya.test - _save_outputs: Command (pid 312597) output:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-kipqlopw2q
    Host information: 
        Linux ghrun-kipqlopw2q 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9944335923/bin/clang++
    Compiler version: 
        clang version 20.1.8
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9944335923/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-10 09:36:56,239 - DEBUG - ya.test - _save_outputs: Command (pid 312597) errors:

2025-11-10 09:36:56,239 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d
2025-11-10 09:36:56,297 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-10 09:36:56,301 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/17838
2025-11-10 09:36:56,303 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/29468
2025-11-10 09:36:56,386 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:56,404 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/61289
2025-11-10 09:36:56,465 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:56,466 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/26980
2025-11-10 09:36:56,468 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/14723
2025-11-10 09:36:56,469 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:56,473 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:36:56,474 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:56,679 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:36:56,727 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 4baaf127-a3b6-4faf-9b1c-d80a6d94e3d6, localhost:12880): creating call state
2025-11-10 09:36:56,728 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 4baaf127-a3b6-4faf-9b1c-d80a6d94e3d6, localhost:12880): request = { database: "local" }
2025-11-10 09:36:56,732 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 4baaf127-a3b6-4faf-9b1c-d80a6d94e3d6, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:36:56,733 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:36:56,733 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:36:56,751 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:36:56,752 - DEBUG - ydb.table.SessionPool - subscribe: Active session queue is empty, subscribe waiter for a session
2025-11-10 09:36:56,833 - DEBUG - ydb.table.SessionPool - subscribe: Subscribe waiter <Future at 0x7f2253a38d30 state=pending>
2025-11-10 09:36:56,833 - DEBUG - ydb.table.SessionPool - subscribe: Session pool is not large enough (active_count < size: 0 < 1). will create a new session.
2025-11-10 09:36:56,834 - DEBUG - ydb.table.SessionPool - _create: Created session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:56,834 - DEBUG - ydb.table.SessionPool - _prepare: Preparing session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:56,835 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateSession, 22c134c0-5584-4d30-a33a-6e21a8310bfa, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:56,835 - DEBUG - ydb.connection - _log_request: RpcState(CreateSession, 22c134c0-5584-4d30-a33a-6e21a8310bfa, ghrun-kipqlopw2q.auto.internal:12880): request = { operation_params { operation_timeout { seconds: 3 } cancel_after { seconds: 3 } } }
2025-11-10 09:36:56,846 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 22c134c0-5584-4d30-a33a-6e21a8310bfa, ghrun-kipqlopw2q.auto.internal:12880): on response callback started
2025-11-10 09:36:57,017 - DEBUG - ydb.connection - _log_response: RpcState(CreateSession, 22c134c0-5584-4d30-a33a-6e21a8310bfa, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.CreateSessionResult] { session_id: "ydb://session/3?node_id=1&id=MjhiZWQ5NGUtNDRhMTJhYTAtZTViOWU5Y2ItN2MyNmFhNWM=" } } } }
2025-11-10 09:36:57,018 - DEBUG - ydb.connection - _on_response_callback: RpcState(CreateSession, 22c134c0-5584-4d30-a33a-6e21a8310bfa, ghrun-kipqlopw2q.auto.internal:12880): on response callback success
2025-11-10 09:36:57,018 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:57,019 - DEBUG - ydb.table.SessionPool - put: Replying to waiter with a session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:57,019 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, 922b9a6a-8d24-4af8-8bcc-37c908f3f615, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:57,022 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, 922b9a6a-8d24-4af8-8bcc-37c908f3f615, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=MjhiZWQ5NGUtNDRhMTJhYTAtZTViOWU5Y2ItN2MyNmFhNWM=" path: "local/DbPoolStorage_3201a88d-11e0-4969-a017-221ed2528ed6/tenants" columns { name: "tenant" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "common" type { optional_type { item { type_id: BOOL } } } } columns { name: "state" type { optional_type { item { type_id: UINT32 } } } } columns { name: "state_time" type { optional_type { item { type_id: TIMESTAMP } } } } primary_key: "tenant" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:57,169 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, 922b9a6a-8d24-4af8-8bcc-37c908f3f615, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS } }
2025-11-10 09:36:57,281 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:57,282 - DEBUG - ydb.connection - _prepare_call: RpcState(CreateTable, 8e07cfc3-e3f8-48c1-993f-97bd7f3f8f3e, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:57,283 - DEBUG - ydb.connection - _log_request: RpcState(CreateTable, 8e07cfc3-e3f8-48c1-993f-97bd7f3f8f3e, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=MjhiZWQ5NGUtNDRhMTJhYTAtZTViOWU5Y2ItN2MyNmFhNWM=" path: "local/DbPoolStorage_3201a88d-11e0-4969-a017-221ed2528ed6/mappings" columns { name: "subject_type" type { optional_type { item { type_id: STRING } } } } columns { name: "subject_id" type { optional_type { item { type_id: STRING } } } } columns { name: "vtenant" type { optional_type { item { type_id: STRING } } } } columns { name: "node" type { optional_type { item { type_id: STRING } } } } primary_key: "subject_type" primary_key: "subject_id" operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:57,312 - DEBUG - ydb.connection - _log_response: RpcState(CreateTable, 8e07cfc3-e3f8-48c1-993f-97bd7f3f8f3e, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS } }
2025-11-10 09:36:57,529 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:57,530 - DEBUG - ydb.connection - _prepare_call: RpcState(ExecuteDataQuery, ef22b685-a2e3-4b9e-86fb-4edecc026b63, ghrun-kipqlopw2q.auto.internal:12880): creating call state
2025-11-10 09:36:57,531 - DEBUG - ydb.connection - _log_request: RpcState(ExecuteDataQuery, ef22b685-a2e3-4b9e-86fb-4edecc026b63, ghrun-kipqlopw2q.auto.internal:12880): request = { session_id: "ydb://session/3?node_id=1&id=MjhiZWQ5NGUtNDRhMTJhYTAtZTViOWU5Y2ItN2MyNmFhNWM=" tx_control { begin_tx { serializable_read_write { } } commit_tx: true } query { yql_text: "--!syntax_v1\n            PRAGMA TablePathPrefix(\"local/DbPoolStorage_3201a88d-11e0-4969-a017-221ed2528ed6\");\n            UPSERT INTO tenants (tenant, vtenant, common, state, state_time) values(\"/cp\", \"/cp\", true, 0, CurrentUtcTimestamp());\n                UPSERT INTO tenants (tenant, vtenant, common, state, state_time) values(\"/compute\", \"/compute\", true, 0, CurrentUtcTimestamp());\n                " } operation_params { operation_timeout { seconds: 600 } cancel_after { seconds: 600 } } }
2025-11-10 09:36:57,570 - DEBUG - ydb.connection - _log_response: RpcState(ExecuteDataQuery, ef22b685-a2e3-4b9e-86fb-4edecc026b63, ghrun-kipqlopw2q.auto.internal:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Table.ExecuteQueryResult] { tx_meta { } } } } }
2025-11-10 09:36:57,571 - DEBUG - ydb.table.SessionPool - put: Put on session <ydb.table.Session object at 0x7f2253a39f50>
2025-11-10 09:36:57,649 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/21909
2025-11-10 09:36:57,765 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:57,785 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/10138
2025-11-10 09:36:57,785 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/63840
2025-11-10 09:36:57,786 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/3038
2025-11-10 09:36:57,786 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/kikimr_configs"
2025-11-10 09:36:57,787 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/cp --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/node_1/logfile_nmfolq_a.log --grpc-port=14723 --mon-port=10138 --ic-port=61289
2025-11-10 09:36:57,787 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/kikimr_configs"
2025-11-10 09:36:57,788 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/cp --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/node_1/logfile_nmfolq_a.log --grpc-port=14723 --mon-port=10138 --ic-port=61289
2025-11-10 09:36:57,789 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/kikimr_configs/config.yaml', '--node=1', '--tenant=/cp', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/node_1/logfile_nmfolq_a.log', '--grpc-port=14723', '--mon-port=10138', '--ic-port=61289')' in '/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/cp/node_1' (no wait)
2025-11-10 09:36:57,797 - DEBUG - ya.test - execute: Command pid: 314276
2025-11-10 09:36:57,810 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:14723/1
2025-11-10 09:36:57,812 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.18
2025-11-10 09:36:57,813 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.18
2025-11-10 09:36:57,813 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-10 09:36:57,815 - DEBUG - ya.test - execute: Command pid: 314295
2025-11-10 09:36:58,567 - DEBUG - ya.test - _save_outputs: Command (pid 314295) rc: 0
2025-11-10 09:36:58,605 - DEBUG - ya.test - _save_outputs: Command (pid 314295) elapsed time (sec): 0.6942150592803955
2025-11-10 09:36:58,605 - DEBUG - ya.test - _save_outputs: Command (pid 314295) idrss: 0
2025-11-10 09:36:58,605 - DEBUG - ya.test - _save_outputs: Command (pid 314295) inblock: 0
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) isrss: 0
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) ixrss: 0
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) majflt: 0
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) maxrss: 541020
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) minflt: 16171
2025-11-10 09:36:58,606 - DEBUG - ya.test - _save_outputs: Command (pid 314295) msgrcv: 0
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) msgsnd: 0
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) nivcsw: 93
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) nsignals: 0
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) nswap: 0
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) nvcsw: 22
2025-11-10 09:36:58,607 - DEBUG - ya.test - _save_outputs: Command (pid 314295) oublock: 8
2025-11-10 09:36:58,608 - DEBUG - ya.test - _save_outputs: Command (pid 314295) stime: 0.27058899999999997
2025-11-10 09:36:58,608 - DEBUG - ya.test - _save_outputs: Command (pid 314295) utime: 0.14474299999999998
2025-11-10 09:36:58,608 - DEBUG - ya.test - _save_outputs: Command (pid 314295) wtime: 0.696
2025-11-10 09:36:58,617 - DEBUG - ya.test - _save_outputs: Command (pid 314295) output:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-kipqlopw2q
    Host information: 
        Linux ghrun-kipqlopw2q 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9944335923/bin/clang++
    Compiler version: 
        clang version 20.1.8
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9944335923/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-10 09:36:58,618 - DEBUG - ya.test - _save_outputs: Command (pid 314295) errors:

2025-11-10 09:36:58,618 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d
2025-11-10 09:36:58,619 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-10 09:36:58,826 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:36:58,845 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/11886
2025-11-10 09:36:58,902 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/18979
2025-11-10 09:36:58,903 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/10549
2025-11-10 09:36:58,904 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/kikimr_configs"
2025-11-10 09:36:58,904 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/node_1/logfile_x2whqjd8.log --grpc-port=21909 --mon-port=11886 --ic-port=26980
2025-11-10 09:36:58,904 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/kikimr_configs"
2025-11-10 09:36:58,905 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/node_1/logfile_x2whqjd8.log --grpc-port=21909 --mon-port=11886 --ic-port=26980
2025-11-10 09:36:58,906 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/kikimr_configs/config.yaml', '--node=1', '--log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/node_1/logfile_x2whqjd8.log', '--grpc-port=21909', '--mon-port=11886', '--ic-port=26980')' in '/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/compute/node_1' (no wait)
2025-11-10 09:36:58,908 - DEBUG - ya.test - execute: Command pid: 314836
2025-11-10 09:36:58,909 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:21909/1
2025-11-10 09:36:58,910 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.19
2025-11-10 09:36:58,911 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.19
2025-11-10 09:36:58,911 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-10 09:36:58,914 - DEBUG - ya.test - execute: Command pid: 314837
2025-11-10 09:36:59,610 - DEBUG - ya.test - _save_outputs: Command (pid 314837) rc: 0
2025-11-10 09:36:59,611 - DEBUG - ya.test - _save_outputs: Command (pid 314837) elapsed time (sec): 0.6539924144744873
2025-11-10 09:36:59,611 - DEBUG - ya.test - _save_outputs: Command (pid 314837) idrss: 0
2025-11-10 09:36:59,611 - DEBUG - ya.test - _save_outputs: Command (pid 314837) inblock: 0
2025-11-10 09:36:59,612 - DEBUG - ya.test - _save_outputs: Command (pid 314837) isrss: 0
2025-11-10 09:36:59,612 - DEBUG - ya.test - _save_outputs: Command (pid 314837) ixrss: 0
2025-11-10 09:36:59,612 - DEBUG - ya.test - _save_outputs: Command (pid 314837) majflt: 0
2025-11-10 09:36:59,612 - DEBUG - ya.test - _save_outputs: Command (pid 314837) maxrss: 541020
2025-11-10 09:36:59,613 - DEBUG - ya.test - _save_outputs: Command (pid 314837) minflt: 16172
2025-11-10 09:36:59,613 - DEBUG - ya.test - _save_outputs: Command (pid 314837) msgrcv: 0
2025-11-10 09:36:59,613 - DEBUG - ya.test - _save_outputs: Command (pid 314837) msgsnd: 0
2025-11-10 09:36:59,797 - DEBUG - ya.test - _save_outputs: Command (pid 314837) nivcsw: 134
2025-11-10 09:36:59,797 - DEBUG - ya.test - _save_outputs: Command (pid 314837) nsignals: 0
2025-11-10 09:36:59,797 - DEBUG - ya.test - _save_outputs: Command (pid 314837) nswap: 0
2025-11-10 09:36:59,798 - DEBUG - ya.test - _save_outputs: Command (pid 314837) nvcsw: 14
2025-11-10 09:36:59,798 - DEBUG - ya.test - _save_outputs: Command (pid 314837) oublock: 8
2025-11-10 09:36:59,798 - DEBUG - ya.test - _save_outputs: Command (pid 314837) stime: 0.291639
2025-11-10 09:36:59,798 - DEBUG - ya.test - _save_outputs: Command (pid 314837) utime: 0.150813
2025-11-10 09:36:59,798 - DEBUG - ya.test - _save_outputs: Command (pid 314837) wtime: 0.693
2025-11-10 09:36:59,799 - DEBUG - ya.test - _save_outputs: Command (pid 314837) output:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-kipqlopw2q
    Host information: 
        Linux ghrun-kipqlopw2q 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9944335923/bin/clang++
    Compiler version: 
        clang version 20.1.8
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9944335923/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-10 09:36:59,799 - DEBUG - ya.test - _save_outputs: Command (pid 314837) errors:

2025-11-10 09:36:59,800 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d
2025-11-10 09:37:02,147 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:37:02,326 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.20
2025-11-10 09:37:02,327 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.20
2025-11-10 09:37:02,327 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '--server', 'grpc://localhost:21909', 'admin', 'blobstorage', 'config', 'invoke', '--proto=Command {\n  DefineHostConfig {\n    HostConfigId: 1\n    Drive {\n      Path: "SectorMap:1:64"\n    }\n  }\n}\nCommand {\n  DefineBox {\n    BoxId: 1\n    Host {\n      Key {\n        Fqdn: "localhost"\n        IcPort: 26980\n      }\n      HostConfigId: 1\n    }\n  }\n}\n']' in 'None' (waiting)
2025-11-10 09:37:02,344 - DEBUG - ya.test - execute: Command pid: 316564
2025-11-10 09:37:02,936 - DEBUG - ya.test - _save_outputs: Command (pid 316564) rc: 0
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) elapsed time (sec): 0.5884377956390381
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) idrss: 0
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) inblock: 368
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) isrss: 0
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) ixrss: 0
2025-11-10 09:37:02,937 - DEBUG - ya.test - _save_outputs: Command (pid 316564) majflt: 2
2025-11-10 09:37:02,938 - DEBUG - ya.test - _save_outputs: Command (pid 316564) maxrss: 549260
2025-11-10 09:37:02,938 - DEBUG - ya.test - _save_outputs: Command (pid 316564) minflt: 18310
2025-11-10 09:37:02,938 - DEBUG - ya.test - _save_outputs: Command (pid 316564) msgrcv: 0
2025-11-10 09:37:02,938 - DEBUG - ya.test - _save_outputs: Command (pid 316564) msgsnd: 0
2025-11-10 09:37:02,938 - DEBUG - ya.test - _save_outputs: Command (pid 316564) nivcsw: 152
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) nsignals: 0
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) nswap: 0
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) nvcsw: 100
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) oublock: 8
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) stime: 0.339773
2025-11-10 09:37:02,939 - DEBUG - ya.test - _save_outputs: Command (pid 316564) utime: 0.13966599999999998
2025-11-10 09:37:02,940 - DEBUG - ya.test - _save_outputs: Command (pid 316564) wtime: 0.606
2025-11-10 09:37:02,940 - DEBUG - ya.test - _save_outputs: Command (pid 316564) output:
Status {
  Success: true
}
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 4

2025-11-10 09:37:02,940 - DEBUG - ya.test - _save_outputs: Command (pid 316564) errors:

2025-11-10 09:37:02,942 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:37:02,945 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.21
2025-11-10 09:37:02,946 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.21
2025-11-10 09:37:02,947 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '--server', 'grpc://localhost:21909', 'admin', 'blobstorage', 'config', 'invoke', '--proto=Command {\n  DefineStoragePool {\n    BoxId: 1\n    StoragePoolId: 1\n    Name: "dynamic_storage_pool:1"\n    ErasureSpecies: "none"\n    VDiskKind: "Default"\n    Kind: "hdd"\n    NumGroups: 2\n    PDiskFilter {\n      Property {\n        Type: ROT\n      }\n      Property {\n        Kind: 0\n      }\n    }\n  }\n}\n']' in 'None' (waiting)
2025-11-10 09:37:02,948 - DEBUG - ya.test - execute: Command pid: 316929
2025-11-10 09:37:03,597 - DEBUG - ya.test - _save_outputs: Command (pid 316929) rc: 0
2025-11-10 09:37:03,597 - DEBUG - ya.test - _save_outputs: Command (pid 316929) elapsed time (sec): 0.6474277973175049
2025-11-10 09:37:03,597 - DEBUG - ya.test - _save_outputs: Command (pid 316929) idrss: 0
2025-11-10 09:37:03,598 - DEBUG - ya.test - _save_outputs: Command (pid 316929) inblock: 0
2025-11-10 09:37:03,598 - DEBUG - ya.test - _save_outputs: Command (pid 316929) isrss: 0
2025-11-10 09:37:03,598 - DEBUG - ya.test - _save_outputs: Command (pid 316929) ixrss: 0
2025-11-10 09:37:03,598 - DEBUG - ya.test - _save_outputs: Command (pid 316929) majflt: 0
2025-11-10 09:37:03,598 - DEBUG - ya.test - _save_outputs: Command (pid 316929) maxrss: 549268
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) minflt: 18314
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) msgrcv: 0
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) msgsnd: 0
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) nivcsw: 113
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) nsignals: 0
2025-11-10 09:37:03,599 - DEBUG - ya.test - _save_outputs: Command (pid 316929) nswap: 0
2025-11-10 09:37:03,600 - DEBUG - ya.test - _save_outputs: Command (pid 316929) nvcsw: 89
2025-11-10 09:37:03,600 - DEBUG - ya.test - _save_outputs: Command (pid 316929) oublock: 8
2025-11-10 09:37:03,600 - DEBUG - ya.test - _save_outputs: Command (pid 316929) stime: 0.36335599999999996
2025-11-10 09:37:03,600 - DEBUG - ya.test - _save_outputs: Command (pid 316929) utime: 0.142249
2025-11-10 09:37:03,600 - DEBUG - ya.test - _save_outputs: Command (pid 316929) wtime: 0.649
2025-11-10 09:37:03,601 - DEBUG - ya.test - _save_outputs: Command (pid 316929) output:
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 5

2025-11-10 09:37:03,601 - DEBUG - ya.test - _save_outputs: Command (pid 316929) errors:

2025-11-10 09:37:03,602 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd
2025-11-10 09:37:03,603 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.22
2025-11-10 09:37:03,604 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.22
2025-11-10 09:37:03,604 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '--server', 'grpc://localhost:21909', 'admin', 'blobstorage', 'config', 'invoke', '--proto=Command {\n  DefineStoragePool {\n    BoxId: 1\n    StoragePoolId: 2\n    Name: "dynamic_storage_pool:2"\n    ErasureSpecies: "none"\n    VDiskKind: "Default"\n    Kind: "ssd"\n    NumGroups: 2\n    PDiskFilter {\n      Property {\n        Type: ROT\n      }\n      Property {\n        Kind: 0\n      }\n    }\n  }\n}\n']' in 'None' (waiting)
2025-11-10 09:37:03,606 - DEBUG - ya.test - execute: Command pid: 317293
2025-11-10 09:37:04,564 - DEBUG - ya.test - _save_outputs: Command (pid 317293) rc: 0
2025-11-10 09:37:04,564 - DEBUG - ya.test - _save_outputs: Command (pid 317293) elapsed time (sec): 0.6190090179443359
2025-11-10 09:37:04,565 - DEBUG - ya.test - _save_outputs: Command (pid 317293) idrss: 0
2025-11-10 09:37:04,565 - DEBUG - ya.test - _save_outputs: Command (pid 317293) inblock: 0
2025-11-10 09:37:04,565 - DEBUG - ya.test - _save_outputs: Command (pid 317293) isrss: 0
2025-11-10 09:37:04,565 - DEBUG - ya.test - _save_outputs: Command (pid 317293) ixrss: 0
2025-11-10 09:37:04,565 - DEBUG - ya.test - _save_outputs: Command (pid 317293) majflt: 0
2025-11-10 09:37:04,566 - DEBUG - ya.test - _save_outputs: Command (pid 317293) maxrss: 549244
2025-11-10 09:37:04,566 - DEBUG - ya.test - _save_outputs: Command (pid 317293) minflt: 18313
2025-11-10 09:37:04,566 - DEBUG - ya.test - _save_outputs: Command (pid 317293) msgrcv: 0
2025-11-10 09:37:04,566 - DEBUG - ya.test - _save_outputs: Command (pid 317293) msgsnd: 0
2025-11-10 09:37:04,566 - DEBUG - ya.test - _save_outputs: Command (pid 317293) nivcsw: 108
2025-11-10 09:37:04,567 - DEBUG - ya.test - _save_outputs: Command (pid 317293) nsignals: 0
2025-11-10 09:37:04,567 - DEBUG - ya.test - _save_outputs: Command (pid 317293) nswap: 0
2025-11-10 09:37:04,567 - DEBUG - ya.test - _save_outputs: Command (pid 317293) nvcsw: 116
2025-11-10 09:37:04,567 - DEBUG - ya.test - _save_outputs: Command (pid 317293) oublock: 8
2025-11-10 09:37:04,567 - DEBUG - ya.test - _save_outputs: Command (pid 317293) stime: 0.33186299999999996
2025-11-10 09:37:04,568 - DEBUG - ya.test - _save_outputs: Command (pid 317293) utime: 0.156112
2025-11-10 09:37:04,568 - DEBUG - ya.test - _save_outputs: Command (pid 317293) wtime: 0.62
2025-11-10 09:37:04,568 - DEBUG - ya.test - _save_outputs: Command (pid 317293) output:
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 6

2025-11-10 09:37:04,580 - DEBUG - ya.test - _save_outputs: Command (pid 317293) errors:

2025-11-10 09:37:04,580 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Binding storage pools to domain local: {'dynamic_storage_pool:1': 'hdd', 'dynamic_storage_pool:2': 'ssd'}
2025-11-10 09:37:04,673 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-11-10 09:37:04,772 - DEBUG - root - wait_bootstrap: Wait for node 1 to bootstrap
2025-11-10 09:37:04,834 - DEBUG - root - wait_bootstrap: Node 1 has been bootstrapped
2025-11-10 09:37:05,154 - INFO - ya.test - pytest_runtest_call: Test call (class_name: test_s3_0.py::TestS3, test_name: test_checkpoints_on_join_s3_with_yds[v1-mvp_external_ydb_endpoint0-client0])
2025-11-10 09:37:05,158 - DEBUG - botocore.hooks - _emit: Event choose-service-name: calling handler <function handle_service_name_alias at 0x7f2270349910>
2025-11-10 09:37:05,164 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_post at 0x7f227046d0d0>
2025-11-10 09:37:05,165 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function lazy_call.<locals>._handler at 0x7f226f497290>
2025-11-10 09:37:05,165 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_url at 0x7f227046cdd0>
2025-11-10 09:37:05,171 - DEBUG - botocore.endpoint - create_endpoint: Setting s3 timeout as (60, 60)
2025-11-10 09:37:05,181 - DEBUG - botocore.client - _register_legacy_retries: Registering retry handlers for service: s3
2025-11-10 09:37:05,182 - DEBUG - botocore.utils - register: Registering S3 region redirector handler
2025-11-10 09:37:05,184 - DEBUG - botocore.utils - register: Registering S3Express Identity Resolver
2025-11-10 09:37:05,188 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:s3
2025-11-10 09:37:05,191 - DEBUG - botocore.hooks - _emit: Event choose-service-name: calling handler <function handle_service_name_alias at 0x7f2270349910>
2025-11-10 09:37:05,195 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_post at 0x7f227046d0d0>
2025-11-10 09:37:05,195 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function lazy_call.<locals>._handler at 0x7f226f497290>
2025-11-10 09:37:05,195 - DEBUG - botocore.hooks - _emit: Event creating-client-class.s3: calling handler <function add_generate_presigned_url at 0x7f227046cdd0>
2025-11-10 09:37:05,200 - DEBUG - botocore.endpoint - create_endpoint: Setting s3 timeout as (60, 60)
2025-11-10 09:37:05,206 - DEBUG - botocore.client - _register_legacy_retries: Registering retry handlers for service: s3
2025-11-10 09:37:05,207 - DEBUG - botocore.utils - register: Registering S3 region redirector handler
2025-11-10 09:37:05,209 - DEBUG - botocore.utils - register: Registering S3Express Identity Resolver
2025-11-10 09:37:05,210 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:Bucket
2025-11-10 09:37:05,218 - DEBUG - boto3.resources.model - _load_name_with_category: Renaming Bucket attribute name
2025-11-10 09:37:05,221 - DEBUG - botocore.hooks - _emit: Event creating-resource-class.s3.Bucket: calling handler <function lazy_call.<locals>._handler at 0x7f226f497d10>
2025-11-10 09:37:05,222 - DEBUG - boto3.resources.action - __call__: Calling s3:create_bucket with {'Bucket': 'join_s3_with_yds', 'ACL': 'public-read'}
2025-11-10 09:37:05,224 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function validate_bucket_name at 0x7f227034b7d0>
2025-11-10 09:37:05,224 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f227037a090>
2025-11-10 09:37:05,224 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,225 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <bound method ClientCreator._inject_s3_input_parameters of <botocore.client.ClientCreator object at 0x7f22497fa090>>
2025-11-10 09:37:05,225 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.CreateBucket: calling handler <function generate_idempotent_uuid at 0x7f227034b590>
2025-11-10 09:37:05,233 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f227037a2d0>
2025-11-10 09:37:05,233 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,234 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'join_s3_with_yds', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:17161', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'DisableAccessPoints': True, 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True, 'UseS3ExpressControlEndpoint': True}
2025-11-10 09:37:05,245 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:17161/join_s3_with_yds
2025-11-10 09:37:05,246 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-11-10 09:37:05,246 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-11-10 09:37:05,259 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function add_expect_header at 0x7f227034bc50>
2025-11-10 09:37:05,259 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <bound method S3ExpressIdentityResolver.apply_signing_cache_key of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533b3fd0>>
2025-11-10 09:37:05,259 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function add_recursion_detection_header at 0x7f2270349b50>
2025-11-10 09:37:05,260 - DEBUG - botocore.hooks - _emit: Event before-call.s3.CreateBucket: calling handler <function inject_api_version_header_if_needed at 0x7f22703796d0>
2025-11-10 09:37:05,260 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=CreateBucket) with params: {'url_path': '', 'query_string': {}, 'method': 'PUT', 'headers': {'x-amz-acl': 'public-read', 'User-Agent': 'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89 Resource'}, 'body': b'', 'auth_path': '/join_s3_with_yds/', 'url': 'http://localhost:17161/join_s3_with_yds', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f225a91eea0>, 'has_streaming_input': False, 'auth_type': 'v4', 's3_redirect': {'redirected': False, 'bucket': 'join_s3_with_yds', 'params': {'Bucket': 'join_s3_with_yds', 'ACL': 'public-read'}}, 'input_params': {'Bucket': 'join_s3_with_yds'}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}, 'endpoint_properties': {'authSchemes': [{'disableDoubleEncoding': True, 'name': 'sigv4', 'signingName': 's3', 'signingRegion': 'yandex'}]}}}
2025-11-10 09:37:05,262 - DEBUG - botocore.hooks - _emit: Event request-created.s3.CreateBucket: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f225a91eef0>>
2025-11-10 09:37:05,262 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.CreateBucket: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f22497fa090>>
2025-11-10 09:37:05,269 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.CreateBucket: calling handler <function set_operation_specific_signer at 0x7f227034b410>
2025-11-10 09:37:05,270 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.CreateBucket: calling handler <function remove_arn_from_signing_path at 0x7f227037a210>
2025-11-10 09:37:05,347 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.CreateBucket: calling handler <bound method S3ExpressIdentityResolver.resolve_s3express_identity of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533b3fd0>>
2025-11-10 09:37:05,349 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-11-10 09:37:05,350 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
PUT
/join_s3_with_yds

host:localhost:17161
x-amz-acl:public-read
x-amz-content-sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
x-amz-date:20251110T093705Z

host;x-amz-acl;x-amz-content-sha256;x-amz-date
e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
2025-11-10 09:37:05,350 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251110T093705Z
20251110/yandex/s3/aws4_request
6bdfe8eb768aba75277156fd1a95d9f83290560703d7d9734c3e38a405a3fdc4
2025-11-10 09:37:05,350 - DEBUG - botocore.auth - add_auth: Signature:
13af5ca9f0b0d230be7b97d5b9286074ef7b6ffc6c07c570d94f27dfb0f5beea
2025-11-10 09:37:05,351 - DEBUG - botocore.hooks - _emit: Event request-created.s3.CreateBucket: calling handler <function add_retry_headers at 0x7f2270379fd0>
2025-11-10 09:37:05,351 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=PUT, url=http://localhost:17161/join_s3_with_yds, headers={'x-amz-acl': b'public-read', 'User-Agent': b'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89 Resource', 'X-Amz-Date': b'20251110T093705Z', 'X-Amz-Content-SHA256': b'e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251110/yandex/s3/aws4_request, SignedHeaders=host;x-amz-acl;x-amz-content-sha256;x-amz-date, Signature=13af5ca9f0b0d230be7b97d5b9286074ef7b6ffc6c07c570d94f27dfb0f5beea', 'amz-sdk-invocation-id': b'a33b73af-9866-407f-a6b4-55bb8d401ab1', 'amz-sdk-request': b'attempt=1', 'Content-Length': '0'}>
2025-11-10 09:37:05,398 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.12', 'Date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': '3YB9UoiCWSNPmrgU03lyh0f8ssjUR8qQZOiaXTtkn5YeQQi4Fqgv', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '170', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-11-10 09:37:05,398 - DEBUG - botocore.parsers - parse: Response body:
b'<CreateBucketResponse xmlns="http://s3.amazonaws.com/doc/2006-03-01"><CreateBucketResponse><Bucket>join_s3_with_yds</Bucket></CreateBucketResponse></CreateBucketResponse>'
2025-11-10 09:37:05,400 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.CreateBucket: calling handler <botocore.retryhandler.RetryHandler object at 0x7f22533b3ad0>
2025-11-10 09:37:05,409 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-11-10 09:37:05,409 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.CreateBucket: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,410 - DEBUG - boto3.resources.action - __call__: Response: {'ResponseMetadata': {'RequestId': '3YB9UoiCWSNPmrgU03lyh0f8ssjUR8qQZOiaXTtkn5YeQQi4Fqgv', 'HTTPStatusCode': 200, 'HTTPHeaders': {'server': 'Werkzeug/2.2.3 Python/3.12.12', 'date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': '3YB9UoiCWSNPmrgU03lyh0f8ssjUR8qQZOiaXTtkn5YeQQi4Fqgv', 'content-type': 'text/html; charset=utf-8', 'content-length': '170', 'access-control-allow-origin': '*', 'connection': 'close'}, 'RetryAttempts': 0}}
2025-11-10 09:37:05,411 - DEBUG - boto3.resources.collection - pages: Calling paginated s3:list_objects with {'Bucket': 'join_s3_with_yds'}
2025-11-10 09:37:05,412 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function set_list_objects_encoding_type_url at 0x7f22703790d0>
2025-11-10 09:37:05,417 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function validate_bucket_name at 0x7f227034b7d0>
2025-11-10 09:37:05,418 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f227037a090>
2025-11-10 09:37:05,418 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,418 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <bound method ClientCreator._inject_s3_input_parameters of <botocore.client.ClientCreator object at 0x7f22497fa090>>
2025-11-10 09:37:05,418 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.ListObjects: calling handler <function generate_idempotent_uuid at 0x7f227034b590>
2025-11-10 09:37:05,419 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f227037a2d0>
2025-11-10 09:37:05,419 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,420 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'join_s3_with_yds', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:17161', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-11-10 09:37:05,422 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:17161/join_s3_with_yds
2025-11-10 09:37:05,423 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-11-10 09:37:05,423 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-11-10 09:37:05,424 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function add_expect_header at 0x7f227034bc50>
2025-11-10 09:37:05,425 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <bound method S3ExpressIdentityResolver.apply_signing_cache_key of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533b3fd0>>
2025-11-10 09:37:05,425 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function add_recursion_detection_header at 0x7f2270349b50>
2025-11-10 09:37:05,425 - DEBUG - botocore.hooks - _emit: Event before-call.s3.ListObjects: calling handler <function inject_api_version_header_if_needed at 0x7f22703796d0>
2025-11-10 09:37:05,426 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=ListObjects) with params: {'url_path': '', 'query_string': {'encoding-type': 'url'}, 'method': 'GET', 'headers': {'User-Agent': 'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89 Resource'}, 'body': b'', 'auth_path': '/join_s3_with_yds/', 'url': 'http://localhost:17161/join_s3_with_yds?encoding-type=url', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f225a91eea0>, 'has_streaming_input': False, 'auth_type': 'v4', 'encoding_type_auto_set': True, 's3_redirect': {'redirected': False, 'bucket': 'join_s3_with_yds', 'params': {'Bucket': 'join_s3_with_yds', 'EncodingType': 'url'}}, 'input_params': {'Bucket': 'join_s3_with_yds'}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}, 'endpoint_properties': {'authSchemes': [{'disableDoubleEncoding': True, 'name': 'sigv4', 'signingName': 's3', 'signingRegion': 'yandex'}]}}}
2025-11-10 09:37:05,427 - DEBUG - botocore.hooks - _emit: Event request-created.s3.ListObjects: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f225a91eef0>>
2025-11-10 09:37:05,427 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.ListObjects: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f22497fa090>>
2025-11-10 09:37:05,428 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.ListObjects: calling handler <function set_operation_specific_signer at 0x7f227034b410>
2025-11-10 09:37:05,428 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.ListObjects: calling handler <function remove_arn_from_signing_path at 0x7f227037a210>
2025-11-10 09:37:05,429 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.ListObjects: calling handler <bound method S3ExpressIdentityResolver.resolve_s3express_identity of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533b3fd0>>
2025-11-10 09:37:05,429 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-11-10 09:37:05,430 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
GET
/join_s3_with_yds
encoding-type=url
host:localhost:17161
x-amz-content-sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
x-amz-date:20251110T093705Z

host;x-amz-content-sha256;x-amz-date
e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855
2025-11-10 09:37:05,430 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251110T093705Z
20251110/yandex/s3/aws4_request
d05fc41aeca0f2e52eb7f6d6f8b87d64d968282675924a35a30162d48a27f30b
2025-11-10 09:37:05,430 - DEBUG - botocore.auth - add_auth: Signature:
5c8643237a7825b42c3b4afd508dce0930c6556c51b3b9288c25045a86b2c8b6
2025-11-10 09:37:05,431 - DEBUG - botocore.hooks - _emit: Event request-created.s3.ListObjects: calling handler <function add_retry_headers at 0x7f2270379fd0>
2025-11-10 09:37:05,431 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=GET, url=http://localhost:17161/join_s3_with_yds?encoding-type=url, headers={'User-Agent': b'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89 Resource', 'X-Amz-Date': b'20251110T093705Z', 'X-Amz-Content-SHA256': b'e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251110/yandex/s3/aws4_request, SignedHeaders=host;x-amz-content-sha256;x-amz-date, Signature=5c8643237a7825b42c3b4afd508dce0930c6556c51b3b9288c25045a86b2c8b6', 'amz-sdk-invocation-id': b'5ec092bf-58f4-4830-941a-6f19ed8f5034', 'amz-sdk-request': b'attempt=1'}>
2025-11-10 09:37:05,442 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.12', 'Date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': 'xiar1hz49jsdXY5OKbvhc6RDo08oZ9qteGoLS0mDgqmDNtvrtAPj', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '239', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-11-10 09:37:05,442 - DEBUG - botocore.parsers - parse: Response body:
b'<?xml version="1.0" encoding="UTF-8"?><ListBucketResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/"><Name>join_s3_with_yds</Name><MaxKeys>1000</MaxKeys><EncodingType>url</EncodingType><IsTruncated>false</IsTruncated></ListBucketResult>'
2025-11-10 09:37:05,443 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.ListObjects: calling handler <botocore.retryhandler.RetryHandler object at 0x7f22533b3ad0>
2025-11-10 09:37:05,449 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-11-10 09:37:05,449 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.ListObjects: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533b1690>>
2025-11-10 09:37:05,449 - DEBUG - botocore.hooks - _emit: Event after-call.s3.ListObjects: calling handler <function decode_list_object at 0x7f2270379190>
2025-11-10 09:37:05,450 - DEBUG - boto3.resources.factory - load_from_definition: Loading s3:ObjectSummary
2025-11-10 09:37:05,450 - DEBUG - boto3.resources.model - _load_name_with_category: Renaming ObjectSummary attribute key
2025-11-10 09:37:05,451 - DEBUG - botocore.hooks - _emit: Event creating-resource-class.s3.ObjectSummary: calling handler <function lazy_call.<locals>._handler at 0x7f226f497e90>
2025-11-10 09:37:05,453 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_ascii_metadata at 0x7f2270378890>
2025-11-10 09:37:05,454 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function sse_md5 at 0x7f227034b890>
2025-11-10 09:37:05,454 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function convert_body_to_file_like_object at 0x7f2270379550>
2025-11-10 09:37:05,454 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_bucket_name at 0x7f227034b7d0>
2025-11-10 09:37:05,454 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f227037a090>
2025-11-10 09:37:05,455 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,455 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method ClientCreator._inject_s3_input_parameters of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,455 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function generate_idempotent_uuid at 0x7f227034b590>
2025-11-10 09:37:05,456 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f227037a2d0>
2025-11-10 09:37:05,456 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,456 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'join_s3_with_yds', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:17161', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'Key': 'a/b/c/1.json', 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-11-10 09:37:05,458 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:17161/join_s3_with_yds
2025-11-10 09:37:05,458 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-11-10 09:37:05,459 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-11-10 09:37:05,460 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function conditionally_calculate_checksum at 0x7f227057b410>
2025-11-10 09:37:05,460 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_expect_header at 0x7f227034bc50>
2025-11-10 09:37:05,461 - DEBUG - botocore.handlers - add_expect_header: Adding expect 100 continue header to request.
2025-11-10 09:37:05,461 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.apply_signing_cache_key of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,461 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_recursion_detection_header at 0x7f2270349b50>
2025-11-10 09:37:05,461 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function inject_api_version_header_if_needed at 0x7f22703796d0>
2025-11-10 09:37:05,461 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=PutObject) with params: {'url_path': '/a/b/c/1.json', 'query_string': {}, 'method': 'PUT', 'headers': {'Content-Type': 'text/json', 'User-Agent': 'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': 'MA0UhnEkNMWFRi1GVXQHdQ==', 'Expect': '100-continue'}, 'body': <_io.BytesIO object at 0x7f2253356cf0>, 'auth_path': '/join_s3_with_yds/a/b/c/1.json', 'url': 'http://localhost:17161/join_s3_with_yds/a/b/c/1.json', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f226f738c40>, 'has_streaming_input': True, 'auth_type': 'v4', 's3_redirect': {'redirected': False, 'bucket': 'join_s3_with_yds', 'params': {'Body': <_io.BytesIO object at 0x7f2253356cf0>, 'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/1.json', 'ContentType': 'text/json'}}, 'input_params': {'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/1.json'}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}, 'endpoint_properties': {'authSchemes': [{'disableDoubleEncoding': True, 'name': 'sigv4', 'signingName': 's3', 'signingRegion': 'yandex'}]}}}
2025-11-10 09:37:05,463 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f226f738970>>
2025-11-10 09:37:05,463 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,463 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <function set_operation_specific_signer at 0x7f227034b410>
2025-11-10 09:37:05,464 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <function remove_arn_from_signing_path at 0x7f227037a210>
2025-11-10 09:37:05,464 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.resolve_s3express_identity of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,465 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-11-10 09:37:05,465 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
PUT
/join_s3_with_yds/a/b/c/1.json

content-md5:MA0UhnEkNMWFRi1GVXQHdQ==
content-type:text/json
host:localhost:17161
x-amz-content-sha256:836e268bcfa32b3d7f155faee7091ed7c19fa6fdd13871dcfc46334954d65b40
x-amz-date:20251110T093705Z

content-md5;content-type;host;x-amz-content-sha256;x-amz-date
836e268bcfa32b3d7f155faee7091ed7c19fa6fdd13871dcfc46334954d65b40
2025-11-10 09:37:05,465 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251110T093705Z
20251110/yandex/s3/aws4_request
4718404660a65df35ccd897da97fd5b588bdae7200e8d081b991d1ff23edaf2c
2025-11-10 09:37:05,465 - DEBUG - botocore.auth - add_auth: Signature:
dd27966cc6317e4f024f9fe131462c1909f3b0398a7bb8a88fd91759298f81e8
2025-11-10 09:37:05,466 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <function add_retry_headers at 0x7f2270379fd0>
2025-11-10 09:37:05,466 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=PUT, url=http://localhost:17161/join_s3_with_yds/a/b/c/1.json, headers={'Content-Type': b'text/json', 'User-Agent': b'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': b'MA0UhnEkNMWFRi1GVXQHdQ==', 'Expect': b'100-continue', 'X-Amz-Date': b'20251110T093705Z', 'X-Amz-Content-SHA256': b'836e268bcfa32b3d7f155faee7091ed7c19fa6fdd13871dcfc46334954d65b40', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251110/yandex/s3/aws4_request, SignedHeaders=content-md5;content-type;host;x-amz-content-sha256;x-amz-date, Signature=dd27966cc6317e4f024f9fe131462c1909f3b0398a7bb8a88fd91759298f81e8', 'amz-sdk-invocation-id': b'e2e587da-4e63-421c-8a49-676152f9592b', 'amz-sdk-request': b'attempt=1', 'Content-Length': '26'}>
2025-11-10 09:37:05,468 - DEBUG - botocore.awsrequest - _send_output: Waiting for 100 Continue response.
2025-11-10 09:37:05,476 - DEBUG - botocore.awsrequest - _handle_expect_response: 100 Continue response seen, now sending request body.
2025-11-10 09:37:05,697 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.12', 'Date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'ETag': '"300d1486712434c585462d4655740775"', 'last-modified': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': 'GKbjU5AlylZadO6h5nnvRpN2R7DJ6l5fgYIhmOrKNAwFlGSIiI8E', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '0', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-11-10 09:37:05,697 - DEBUG - botocore.parsers - parse: Response body:
b''
2025-11-10 09:37:05,698 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <botocore.retryhandler.RetryHandler object at 0x7f22533fa4a0>
2025-11-10 09:37:05,701 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-11-10 09:37:05,701 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,702 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_ascii_metadata at 0x7f2270378890>
2025-11-10 09:37:05,702 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function sse_md5 at 0x7f227034b890>
2025-11-10 09:37:05,702 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function convert_body_to_file_like_object at 0x7f2270379550>
2025-11-10 09:37:05,702 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_bucket_name at 0x7f227034b7d0>
2025-11-10 09:37:05,702 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f227037a090>
2025-11-10 09:37:05,703 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,703 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method ClientCreator._inject_s3_input_parameters of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,703 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function generate_idempotent_uuid at 0x7f227034b590>
2025-11-10 09:37:05,703 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f227037a2d0>
2025-11-10 09:37:05,704 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,704 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'join_s3_with_yds', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:17161', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'Key': 'a/b/c/2.json', 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-11-10 09:37:05,706 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:17161/join_s3_with_yds
2025-11-10 09:37:05,706 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-11-10 09:37:05,706 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-11-10 09:37:05,707 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function conditionally_calculate_checksum at 0x7f227057b410>
2025-11-10 09:37:05,707 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_expect_header at 0x7f227034bc50>
2025-11-10 09:37:05,708 - DEBUG - botocore.handlers - add_expect_header: Adding expect 100 continue header to request.
2025-11-10 09:37:05,708 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.apply_signing_cache_key of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,708 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_recursion_detection_header at 0x7f2270349b50>
2025-11-10 09:37:05,708 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function inject_api_version_header_if_needed at 0x7f22703796d0>
2025-11-10 09:37:05,708 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=PutObject) with params: {'url_path': '/a/b/c/2.json', 'query_string': {}, 'method': 'PUT', 'headers': {'Content-Type': 'text/json', 'User-Agent': 'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': 'wygYhFm5j3ySJlRmBXeP5Q==', 'Expect': '100-continue'}, 'body': <_io.BytesIO object at 0x7f2253354830>, 'auth_path': '/join_s3_with_yds/a/b/c/2.json', 'url': 'http://localhost:17161/join_s3_with_yds/a/b/c/2.json', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f226f738c40>, 'has_streaming_input': True, 'auth_type': 'v4', 's3_redirect': {'redirected': False, 'bucket': 'join_s3_with_yds', 'params': {'Body': <_io.BytesIO object at 0x7f2253354830>, 'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/2.json', 'ContentType': 'text/json'}}, 'input_params': {'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/2.json'}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}, 'endpoint_properties': {'authSchemes': [{'disableDoubleEncoding': True, 'name': 'sigv4', 'signingName': 's3', 'signingRegion': 'yandex'}]}}}
2025-11-10 09:37:05,709 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f226f738970>>
2025-11-10 09:37:05,710 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,711 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <function set_operation_specific_signer at 0x7f227034b410>
2025-11-10 09:37:05,711 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <function remove_arn_from_signing_path at 0x7f227037a210>
2025-11-10 09:37:05,711 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.resolve_s3express_identity of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,712 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-11-10 09:37:05,712 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
PUT
/join_s3_with_yds/a/b/c/2.json

content-md5:wygYhFm5j3ySJlRmBXeP5Q==
content-type:text/json
host:localhost:17161
x-amz-content-sha256:944e3b66b93542288d85cfd7186e5c7ff3a8330a0ef1a735671f96455fc6b787
x-amz-date:20251110T093705Z

content-md5;content-type;host;x-amz-content-sha256;x-amz-date
944e3b66b93542288d85cfd7186e5c7ff3a8330a0ef1a735671f96455fc6b787
2025-11-10 09:37:05,712 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251110T093705Z
20251110/yandex/s3/aws4_request
09c02bacba45438740b42b10dce85dddd53d19d24acc05dd7862fb79d578474f
2025-11-10 09:37:05,713 - DEBUG - botocore.auth - add_auth: Signature:
71898c38f767094faa0177876c074221983dec112f20df5d7a7295393fc435c6
2025-11-10 09:37:05,713 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <function add_retry_headers at 0x7f2270379fd0>
2025-11-10 09:37:05,713 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=PUT, url=http://localhost:17161/join_s3_with_yds/a/b/c/2.json, headers={'Content-Type': b'text/json', 'User-Agent': b'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': b'wygYhFm5j3ySJlRmBXeP5Q==', 'Expect': b'100-continue', 'X-Amz-Date': b'20251110T093705Z', 'X-Amz-Content-SHA256': b'944e3b66b93542288d85cfd7186e5c7ff3a8330a0ef1a735671f96455fc6b787', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251110/yandex/s3/aws4_request, SignedHeaders=content-md5;content-type;host;x-amz-content-sha256;x-amz-date, Signature=71898c38f767094faa0177876c074221983dec112f20df5d7a7295393fc435c6', 'amz-sdk-invocation-id': b'6a67a848-e3e4-40b9-afba-f112230063ac', 'amz-sdk-request': b'attempt=1', 'Content-Length': '26'}>
2025-11-10 09:37:05,716 - DEBUG - botocore.awsrequest - _send_output: Waiting for 100 Continue response.
2025-11-10 09:37:05,719 - DEBUG - botocore.awsrequest - _handle_expect_response: 100 Continue response seen, now sending request body.
2025-11-10 09:37:05,725 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.12', 'Date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'ETag': '"c328188459b98f7c9226546605778fe5"', 'last-modified': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': 'rDijENU9JCd1VAECjxgx9kAh6T7OdF8tNJeJEDzzVL1oS5ELaE61', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '0', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-11-10 09:37:05,726 - DEBUG - botocore.parsers - parse: Response body:
b''
2025-11-10 09:37:05,726 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <botocore.retryhandler.RetryHandler object at 0x7f22533fa4a0>
2025-11-10 09:37:05,727 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-11-10 09:37:05,727 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,727 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_ascii_metadata at 0x7f2270378890>
2025-11-10 09:37:05,727 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function sse_md5 at 0x7f227034b890>
2025-11-10 09:37:05,728 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function convert_body_to_file_like_object at 0x7f2270379550>
2025-11-10 09:37:05,728 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function validate_bucket_name at 0x7f227034b7d0>
2025-11-10 09:37:05,728 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function remove_bucket_from_url_paths_from_model at 0x7f227037a090>
2025-11-10 09:37:05,728 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.annotate_request_context of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,728 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <bound method ClientCreator._inject_s3_input_parameters of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,729 - DEBUG - botocore.hooks - _emit: Event before-parameter-build.s3.PutObject: calling handler <function generate_idempotent_uuid at 0x7f227034b590>
2025-11-10 09:37:05,729 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <function customize_endpoint_resolver_builtins at 0x7f227037a2d0>
2025-11-10 09:37:05,729 - DEBUG - botocore.hooks - _emit: Event before-endpoint-resolution.s3: calling handler <bound method S3RegionRedirectorv2.redirect_from_cache of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,729 - DEBUG - botocore.regions - construct_endpoint: Calling endpoint provider with parameters: {'Bucket': 'join_s3_with_yds', 'Region': 'yandex', 'UseFIPS': False, 'UseDualStack': False, 'Endpoint': 'http://localhost:17161', 'ForcePathStyle': True, 'Accelerate': False, 'UseGlobalEndpoint': False, 'Key': 'a/b/c/3.json', 'DisableMultiRegionAccessPoints': False, 'UseArnRegion': True}
2025-11-10 09:37:05,731 - DEBUG - botocore.regions - construct_endpoint: Endpoint provider result: http://localhost:17161/join_s3_with_yds
2025-11-10 09:37:05,731 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selecting from endpoint provider's list of auth schemes: "sigv4". User selected auth scheme is: "None"
2025-11-10 09:37:05,731 - DEBUG - botocore.regions - auth_schemes_to_signing_ctx: Selected auth type "v4" as "v4" with signing context params: {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}
2025-11-10 09:37:05,732 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function conditionally_calculate_checksum at 0x7f227057b410>
2025-11-10 09:37:05,733 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_expect_header at 0x7f227034bc50>
2025-11-10 09:37:05,733 - DEBUG - botocore.handlers - add_expect_header: Adding expect 100 continue header to request.
2025-11-10 09:37:05,733 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.apply_signing_cache_key of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,733 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function add_recursion_detection_header at 0x7f2270349b50>
2025-11-10 09:37:05,734 - DEBUG - botocore.hooks - _emit: Event before-call.s3.PutObject: calling handler <function inject_api_version_header_if_needed at 0x7f22703796d0>
2025-11-10 09:37:05,734 - DEBUG - botocore.endpoint - make_request: Making request for OperationModel(name=PutObject) with params: {'url_path': '/a/b/c/3.json', 'query_string': {}, 'method': 'PUT', 'headers': {'Content-Type': 'text/json', 'User-Agent': 'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': 'psU4Ho+t3cwMn6B4twVHmg==', 'Expect': '100-continue'}, 'body': <_io.BytesIO object at 0x7f2253355e10>, 'auth_path': '/join_s3_with_yds/a/b/c/3.json', 'url': 'http://localhost:17161/join_s3_with_yds/a/b/c/3.json', 'context': {'client_region': 'yandex', 'client_config': <botocore.config.Config object at 0x7f226f738c40>, 'has_streaming_input': True, 'auth_type': 'v4', 's3_redirect': {'redirected': False, 'bucket': 'join_s3_with_yds', 'params': {'Body': <_io.BytesIO object at 0x7f2253355e10>, 'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/3.json', 'ContentType': 'text/json'}}, 'input_params': {'Bucket': 'join_s3_with_yds', 'Key': 'a/b/c/3.json'}, 'signing': {'region': 'yandex', 'signing_name': 's3', 'disableDoubleEncoding': True}, 'endpoint_properties': {'authSchemes': [{'disableDoubleEncoding': True, 'name': 'sigv4', 'signingName': 's3', 'signingRegion': 'yandex'}]}}}
2025-11-10 09:37:05,734 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <bound method RequestSigner.handler of <botocore.signers.RequestSigner object at 0x7f226f738970>>
2025-11-10 09:37:05,735 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <bound method ClientCreator._default_s3_presign_to_sigv2 of <botocore.client.ClientCreator object at 0x7f225a92ce20>>
2025-11-10 09:37:05,735 - DEBUG - botocore.hooks - _emit: Event choose-signer.s3.PutObject: calling handler <function set_operation_specific_signer at 0x7f227034b410>
2025-11-10 09:37:05,735 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <function remove_arn_from_signing_path at 0x7f227037a210>
2025-11-10 09:37:05,735 - DEBUG - botocore.hooks - _emit: Event before-sign.s3.PutObject: calling handler <bound method S3ExpressIdentityResolver.resolve_s3express_identity of <botocore.utils.S3ExpressIdentityResolver object at 0x7f22533fa5e0>>
2025-11-10 09:37:05,736 - DEBUG - botocore.auth - add_auth: Calculating signature using v4 auth.
2025-11-10 09:37:05,737 - DEBUG - botocore.auth - add_auth: CanonicalRequest:
PUT
/join_s3_with_yds/a/b/c/3.json

content-md5:psU4Ho+t3cwMn6B4twVHmg==
content-type:text/json
host:localhost:17161
x-amz-content-sha256:8e192126957ef7fbe749e605e4247ab85a5c43f8413bd103bed9fe96ef5abddf
x-amz-date:20251110T093705Z

content-md5;content-type;host;x-amz-content-sha256;x-amz-date
8e192126957ef7fbe749e605e4247ab85a5c43f8413bd103bed9fe96ef5abddf
2025-11-10 09:37:05,737 - DEBUG - botocore.auth - add_auth: StringToSign:
AWS4-HMAC-SHA256
20251110T093705Z
20251110/yandex/s3/aws4_request
e74d7148b8bd6095eee128ac4e6f78e88802a4c650abc6edd6f5f27cd9b9375b
2025-11-10 09:37:05,737 - DEBUG - botocore.auth - add_auth: Signature:
3f7910fefc048adcc49c014c3a31bb5668c1b990d60cfeff567384c9204fcbef
2025-11-10 09:37:05,738 - DEBUG - botocore.hooks - _emit: Event request-created.s3.PutObject: calling handler <function add_retry_headers at 0x7f2270379fd0>
2025-11-10 09:37:05,738 - DEBUG - botocore.endpoint - _do_get_response: Sending http request: <AWSPreparedRequest stream_output=False, method=PUT, url=http://localhost:17161/join_s3_with_yds/a/b/c/3.json, headers={'Content-Type': b'text/json', 'User-Agent': b'Boto3/1.34.89 md/Botocore#1.34.89 ua/2.0 os/linux#5.15.0-157-generic md/arch#x86_64 lang/python#3.12.12 md/pyimpl#CPython cfg/retry-mode#legacy Botocore/1.34.89', 'Content-MD5': b'psU4Ho+t3cwMn6B4twVHmg==', 'Expect': b'100-continue', 'X-Amz-Date': b'20251110T093705Z', 'X-Amz-Content-SHA256': b'8e192126957ef7fbe749e605e4247ab85a5c43f8413bd103bed9fe96ef5abddf', 'Authorization': b'AWS4-HMAC-SHA256 Credential=key/20251110/yandex/s3/aws4_request, SignedHeaders=content-md5;content-type;host;x-amz-content-sha256;x-amz-date, Signature=3f7910fefc048adcc49c014c3a31bb5668c1b990d60cfeff567384c9204fcbef', 'amz-sdk-invocation-id': b'd9ef585b-91e8-4c80-b6a8-25df866414bd', 'amz-sdk-request': b'attempt=1', 'Content-Length': '28'}>
2025-11-10 09:37:05,741 - DEBUG - botocore.awsrequest - _send_output: Waiting for 100 Continue response.
2025-11-10 09:37:05,744 - DEBUG - botocore.awsrequest - _handle_expect_response: 100 Continue response seen, now sending request body.
2025-11-10 09:37:05,749 - DEBUG - botocore.parsers - parse: Response headers: {'Server': 'Werkzeug/2.2.3 Python/3.12.12', 'Date': 'Mon, 10 Nov 2025 09:37:05 GMT', 'ETag': '"a6c5381e8fadddcc0c9fa078b705479a"', 'last-modified': 'Mon, 10 Nov 2025 09:37:05 GMT', 'x-amzn-requestid': 'oE9ytWlUQQpKKPhlcPNVjp6kVvkQNw6yap0TSjw2CEtstBhyhtSl', 'Content-Type': 'text/html; charset=utf-8', 'Content-Length': '0', 'Access-Control-Allow-Origin': '*', 'Connection': 'close'}
2025-11-10 09:37:05,750 - DEBUG - botocore.parsers - parse: Response body:
b''
2025-11-10 09:37:05,750 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <botocore.retryhandler.RetryHandler object at 0x7f22533fa4a0>
2025-11-10 09:37:05,751 - DEBUG - botocore.retryhandler - __call__: No retry needed.
2025-11-10 09:37:05,751 - DEBUG - botocore.hooks - _emit: Event needs-retry.s3.PutObject: calling handler <bound method S3RegionRedirectorv2.redirect_from_error of <botocore.utils.S3RegionRedirectorv2 object at 0x7f22533fb710>>
2025-11-10 09:37:05,751 - DEBUG - root - wait_bootstrap: Wait for node 1 to bootstrap
2025-11-10 09:37:05,798 - DEBUG - root - wait_bootstrap: Node 1 has been bootstrapped
2025-11-10 09:37:06,503 - DEBUG - root - create_stream: Requesting CreateStream.
Database: "local".
Request:
stream_name: "/local/yds_dict_input"
shard_count: 1
write_quota_kb_per_sec: 1024
retention_period_hours: 1

2025-11-10 09:37:06,597 - DEBUG - root - _get_and_check_result: Response: operation {
  ready: true
  status: SUCCESS
}

2025-11-10 09:37:06,598 - DEBUG - root - _get_and_check_result: Result: 
2025-11-10 09:37:06,600 - DEBUG - root - create_stream: Requesting CreateStream.
Database: "local".
Request:
stream_name: "/local/yds_dict_output"
shard_count: 1
write_quota_kb_per_sec: 1024
retention_period_hours: 1

2025-11-10 09:37:06,857 - DEBUG - root - _get_and_check_result: Response: operation {
  ready: true
  status: SUCCESS
}

2025-11-10 09:37:06,860 - DEBUG - root - _get_and_check_result: Result: 
2025-11-10 09:37:06,892 - DEBUG - root - _get_and_check_result: Response: operation {
  ready: true
  status: SUCCESS
}

2025-11-10 09:37:07,057 - DEBUG - root - _get_and_check_result: Result: 
2025-11-10 09:37:07,094 - DEBUG - root - create_query_impl: Request: content {
  type: STREAMING
  name: "simple"
  acl {
    visibility: PRIVATE
  }
  limits {
    execution_timeout {
    }
  }
  text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            $s3_dict_raw =\n                SELECT cast(Data AS json) AS data\n                FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict`.`*`\n                WITH (format=raw, SCHEMA (\n                    Data String NOT NULL\n                ));\n\n            $s3_dict =\n                SELECT\n                    cast(JSON_VALUE(data, \'$.key\') AS int64) AS key,\n                    cast(JSON_VALUE(data, \'$.value\') AS String) AS value\n                FROM $s3_dict_raw;\n\n            $parsed_yson_topic =\n                SELECT\n                    Yson::LookupInt64(yson_data, \"key\") AS key,\n                    Yson::LookupString(yson_data, \"val\") AS val\n                FROM (\n                    SELECT\n                        Yson::Parse(Data) AS yson_data\n                    FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_input` WITH SCHEMA (Data String NOT NULL));\n\n            $joined_seq =\n                SELECT\n                    s3_dict.value AS num,\n                    yds_seq.val AS word\n                FROM $parsed_yson_topic AS yds_seq\n                    INNER JOIN $s3_dict AS s3_dict\n                        ON yds_seq.key = s3_dict.key;\n\n            INSERT INTO `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_output`\n            SELECT\n                Yson::SerializeText(Yson::From(TableRow()))\n            FROM $joined_seq;\n            "
  syntax: YQL_V1
}
execute_mode: RUN
idempotency_key: "f5e2dd01-bc0e-45e8-a5d7-5850c763bee1"

2025-11-10 09:37:07,318 - DEBUG - root - create_query_impl: Result: query_id: "ptqudsomsqv553cv1eic"

2025-11-10 09:37:07,415 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudsomsqv553cv1eic"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762767427
        nanos: 103428000
      }
      modified_at {
        seconds: 1762767427
        nanos: 103428000
      }
      revision: 1
    }
    execute_mode: RUN
    status: STARTING
    last_job_query_revision: 1
    last_job_id: "ptjudsomsqv548p3e4dq-ptqudsomsqv553cv1eic"
    started_by: "root@builtin"
    submitted_at {
      seconds: 1762767427
      nanos: 103428000
    }
  }
  content {
    type: STREAMING
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            $s3_dict_raw =\n                SELECT cast(Data AS json) AS data\n                FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict`.`*`\n                WITH (format=raw, SCHEMA (\n                    Data String NOT NULL\n                ));\n\n            $s3_dict =\n                SELECT\n                    cast(JSON_VALUE(data, \'$.key\') AS int64) AS key,\n                    cast(JSON_VALUE(data, \'$.value\') AS String) AS value\n                FROM $s3_dict_raw;\n\n            $parsed_yson_topic =\n                SELECT\n                    Yson::LookupInt64(yson_data, \"key\") AS key,\n                    Yson::LookupString(yson_data, \"val\") AS val\n                FROM (\n                    SELECT\n                        Yson::Parse(Data) AS yson_data\n                    FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_input` WITH SCHEMA (Data String NOT NULL));\n\n            $joined_seq =\n                SELECT\n                    s3_dict.value AS num,\n                    yds_seq.val AS word\n                FROM $parsed_yson_topic AS yds_seq\n                    INNER JOIN $s3_dict AS s3_dict\n                        ON yds_seq.key = s3_dict.key;\n\n            INSERT INTO `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_output`\n            SELECT\n                Yson::SerializeText(Yson::From(TableRow()))\n            FROM $joined_seq;\n            "
    syntax: YQL_V1
  }
}

2025-11-10 09:37:07,926 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-11-10 09:37:08,439 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-11-10 09:37:09,069 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudsomsqv553cv1eic"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762767427
        nanos: 103428000
      }
      modified_at {
        seconds: 1762767427
        nanos: 103428000
      }
      revision: 1
    }
    started_at {
      seconds: 1762767428
      nanos: 201000000
    }
    execute_mode: RUN
    status: RUNNING
    last_job_query_revision: 1
    last_job_id: "ptjudsomsqv548p3e4dq-ptqudsomsqv553cv1eic"
    started_by: "root@builtin"
    submitted_at {
      seconds: 1762767427
      nanos: 103428000
    }
  }
  content {
    type: STREAMING
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            $s3_dict_raw =\n                SELECT cast(Data AS json) AS data\n                FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict`.`*`\n                WITH (format=raw, SCHEMA (\n                    Data String NOT NULL\n                ));\n\n            $s3_dict =\n                SELECT\n                    cast(JSON_VALUE(data, \'$.key\') AS int64) AS key,\n                    cast(JSON_VALUE(data, \'$.value\') AS String) AS value\n                FROM $s3_dict_raw;\n\n            $parsed_yson_topic =\n                SELECT\n                    Yson::LookupInt64(yson_data, \"key\") AS key,\n                    Yson::LookupString(yson_data, \"val\") AS val\n                FROM (\n                    SELECT\n                        Yson::Parse(Data) AS yson_data\n                    FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_input` WITH SCHEMA (Data String NOT NULL));\n\n            $joined_seq =\n                SELECT\n                    s3_dict.value AS num,\n                    yds_seq.val AS word\n                FROM $parsed_yson_topic AS yds_seq\n                    INNER JOIN $s3_dict AS s3_dict\n                        ON yds_seq.key = s3_dict.key;\n\n            INSERT INTO `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_output`\n            SELECT\n                Yson::SerializeText(Yson::From(TableRow()))\n            FROM $joined_seq;\n            "
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":17,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":15,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[17]},{\"Id\":4,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"SkipNullMembers\"},{\"Name\":\"DqPhyMapJoin\"},{\"Name\":\"ExtractMembers\"},{\"Name\":\"FlatMap\"}]},\"DependsOn\":[6,15]},{\"Id\":3,\"Name\":\"DqQuery!\",\"DependsOn\":[4]},{\"Id\":2,\"Name\":\"Commit!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":2,\"DqQuery!\":1,\"DqStage\":4}},\"Basic\":{\"nodes\":[{\"id\":6,\"level\":1,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":17,\"level\":1,\"name\":\"DqStage #17\",\"type\":\"op\"},{\"id\":15,\"level\":2,\"name\":\"DqStage #15\",\"type\":\"op\"},{\"id\":4,\"level\":3,\"name\":\"DqStage #4\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":2,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"},{\"id\":1,\"level\":6,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":17,\"target\":15},{\"source\":6,\"target\":4},{\"source\":15,\"target\":4},{\"source\":4,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $3 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $4 (DataSource \'\"pq\" $3))\n(let $5 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $6 (DataType \'String))\n(let $7 (StructType \'(\'\"Data\" $6)))\n(let $8 (PqTopic $3 \'\"local\" \'\"yds_dict_input\" $5 \'() $7))\n(let $9 \'(\'\"Endpoint\" \'\"localhost:12880\"))\n(let $10 \'(\'\"SharedReading\" \'0))\n(let $11 \'(\'\"AddBearerToToken\" \'1))\n(let $12 \'($9 $10 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudsomsr0dvvo0otgs\") $11))\n(let $13 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $14 (SecureParam $13))\n(let $15 (DqPqTopicSource $2 $8 \'(\'\"Data\") $12 $14 \'\"\" $7 \'\"\"))\n(let $16 \'(\'format \'\"raw\"))\n(let $17 (lambda \'($41) (AsStruct \'(\'\"Data\" $41))))\n(let $18 (ResourceType \'\"Yson2.Node\"))\n(let $19 \'(\'(\'\"strict\")))\n(let $20 (Bool \'\"true\"))\n(let $21 (DataType \'Yson))\n(let $22 \'($18 \'\"\" \'1))\n(let $23 (CallableType \'() \'($21) $22))\n(let $24 (OptionalType (DataType \'Int64)))\n(let $25 \'($18))\n(let $26 (OptionalType $6))\n(let $27 (DqStage \'((DqSource $4 $15)) (lambda \'($38) (block \'(\n  (let $39 \'($16 \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'settings \'($10))))\n  (let $40 (DqSourceWideWrap $38 $4 $7 $39))\n  (return (FlatMap (NarrowMap $40 $17) (lambda \'($42) (block \'(\n    (let $43 (ResourceType \'\"Yson2.Options\"))\n    (let $44 (TupleType (TupleType $6 $43) (StructType) (TupleType)))\n    (let $45 \'(\'1))\n    (let $46 \'($6 \'\"\" \'1))\n    (let $47 \'((OptionalType $43)))\n    (let $48 (CallableType $45 \'((OptionalType $18)) $46 $47))\n    (let $49 (Udf \'\"Yson2.Parse\" (Void) $44 \'\"\" $48 (VoidType) \'\"\" \'()))\n    (let $50 (OptionalType (DataType \'Bool)))\n    (let $51 (CallableType \'(\'\"2\") \'($43) \'($50 \'\"AutoConvert\") \'($50 \'\"Strict\")))\n    (let $52 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $51 (VoidType) \'\"\" $19))\n    (let $53 (Just (NamedApply $52 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'\"false\"))) \'(\'\"Strict\" (Just $20))))))\n    (let $54 (Apply $49 (Member $42 \'\"Data\") $53))\n    (let $55 (FlatMap $54 (lambda \'($61) (block \'(\n      (let $62 (Udf \'\"Yson2.Serialize\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n      (return (Just (Apply $62 $61)))\n    )))))\n    (let $56 \'($6))\n    (let $57 (TupleType (TupleType $21) (StructType) (TupleType)))\n    (let $58 \'($21 \'\"\" \'1))\n    (let $59 (CallableType $45 $25 $58 $47))\n    (let $60 (Udf \'\"Yson2.Parse\" (Void) $57 \'\"\" $59 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"key\" (FlatMap $55 (lambda \'($63) (block \'(\n      (let $64 (CallableType $45 \'($24) $22 $56 $47))\n      (let $65 (Udf \'\"Yson2.LookupInt64\" (Void) (VoidType) \'\"\" $64 (VoidType) \'\"\" \'()))\n      (return (Apply $65 (Apply $60 $63) (String \'\"key\") $53))\n    ))))) \'(\'\"val\" (FlatMap $55 (lambda \'($66) (block \'(\n      (let $67 (CallableType $45 \'($26) $22 $56 $47))\n      (let $68 (Udf \'\"Yson2.LookupString\" (Void) (VoidType) \'\"\" $67 (VoidType) \'\"\" \'()))\n      (return (Apply $68 (Apply $60 $66) (String \'\"val\") $53))\n    ))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211804))))\n(let $28 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $29 (DataSource \'\"s3\" $28))\n(let $30 \'\"Paths {\\n  Name: \\\"a\\\"\\n  Children {\\n    Name: \\\"b\\\"\\n    Children {\\n      Name: \\\"c\\\"\\n      Children {\\n        Name: \\\"1.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"2.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"3.json\\\"\\n        Size: 28\\n        Read: true\\n      }\\n      IsDirectory: true\\n    }\\n    IsDirectory: true\\n  }\\n  IsDirectory: true\\n}\\n\")\n(let $31 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $32 (S3SourceSettings $2 \'(\'((String $30) $20 (AsStruct))) (SecureParam $31) \'\"\" \'\"* \" (Void) (Void) (Void)))\n(let $33 (DqStage \'((DqSource $29 $32)) (lambda \'($69) (block \'(\n  (let $70 (DqSourceWideWrap $69 $29 $7 \'($16 \'(\'settings \'()))))\n  (return (FlatMap (NarrowMap $70 $17) (lambda \'($71) (block \'(\n    (let $72 (SafeCast (Member $71 \'\"Data\") (OptionalType (DataType \'Json))))\n    (let $73 (JsonValue $72 (Utf8 \'\"$.key\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (let $74 (JsonValue $72 (Utf8 \'\"$.value\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (return (Just (AsStruct \'(\'\"key\" (SafeCast $73 $24)) \'(\'\"value\" (SafeCast $74 $26)))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211846))))\n(let $34 (DqStage \'((DqCnUnionAll (TDqOutput $33 \'0))) (lambda \'($75) $75) \'(\'(\'\"_logical_id\" \'211902))))\n(let $35 (DataSink \'\"pq\" $3))\n(let $36 (PqTopic $3 \'\"local\" \'\"yds_dict_output\" $5 \'() $7))\n(let $37 (DqPqTopicSink $36 \'($9 $11) $14))\n(return (Commit! (Commit! (DqQuery! $2 \'((DqStage \'((DqCnMap (TDqOutput $27 \'0)) (DqCnBroadcast (TDqOutput $34 \'0))) (lambda \'($76 $77) (block \'(\n  (let $78 \'(\'\"key\"))\n  (let $79 (DqPhyMapJoin (SkipNullMembers $76 $78) (SkipNullMembers $77 $78) \'\"yds_seq\" \'\"s3_dict\" \'Inner \'(\'(\'\"yds_seq\" \'\"key\" \'\"s3_dict\" \'\"key\")) \'(\'\"yds_seq.key\") \'(\'\"s3_dict.key\")))\n  (return (FlatMap (ExtractMembers $79 \'(\'\"s3_dict.value\" \'\"yds_seq.val\")) (lambda \'($80) (block \'(\n    (let $81 (Udf \'\"Yson2.SerializeText\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n    (let $82 (StructType \'(\'\"num\" $26) \'(\'\"word\" $26)))\n    (let $83 (TupleType (TupleType $82) (StructType) (TupleType)))\n    (let $84 (CallableType \'() $25 \'($82)))\n    (let $85 (Udf \'\"Yson2.From\" (Void) $83 \'\"\" $84 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"column0\" (Apply $81 (Apply $85 (AsStruct \'(\'\"num\" (Member $80 \'\"s3_dict.value\")) \'(\'\"word\" (Member $80 \'\"yds_seq.val\")))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'212047)) \'((DqSink \'0 $35 $37))))) $35) (DataSink \'\"s3\" $28)))\n)\n"
  }
}

2025-11-10 09:37:09,087 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:37:09,125 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:37:09,165 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:37:09,209 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, ee59d13d-251f-4a2b-a9db-b50f03542270, localhost:12880): creating call state
2025-11-10 09:37:09,210 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, ee59d13d-251f-4a2b-a9db-b50f03542270, localhost:12880): request = { database: "local" }
2025-11-10 09:37:09,223 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, ee59d13d-251f-4a2b-a9db-b50f03542270, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:37:09,224 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:37:09,232 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:37:10,233 - DEBUG - root - write_stream: Write topic yds_dict_input. Response: operation {
  ready: true
  status: SUCCESS
  result {
    type_url: "type.googleapis.com/Ydb.DataStreams.V1.PutRecordsResult"
    value: "\010\001\032\021\"\0010*\014shard-000000\032\021\"\0011*\014shard-000000\032\021\"\0012*\014shard-000000\032\021\"\0013*\014shard-000000\032\021\"\0014*\014shard-000000\032\021\"\0015*\014shard-000000\032\021\"\0016*\014shard-000000\032\021\"\0017*\014shard-000000\032\021\"\0018*\014shard-000000"
  }
}

2025-11-10 09:37:10,233 - INFO - root - write_stream: Data was written to yds_dict_input: ['{"key" = 1; "val" = "January";}', '{"key" = 2; "val" = "February";}', '{"key" = 3; "val" = "March";}', '{"key" = 1; "val" = "Monday";}', '{"key" = 2; "val" = "Tuesday";}', '{"key" = 3; "val" = "Wednesday";}', '{"key" = 1; "val" = "Gold";}', '{"key" = 2; "val" = "Silver";}', '{"key" = 3; "val" = "Bronze";}']
2025-11-10 09:37:10,235 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/tools/pq_read/pq_read
2025-11-10 09:37:10,237 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to pq_read.err
2025-11-10 09:37:10,238 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/tools/pq_read/pq_read', '--endpoint', 'localhost:12880', '--database', 'local', '--topic-path', 'yds_dict_output', '--consumer-name', 'yds_dict_consumer', '--disable-cluster-discovery', '--messages-count', '9', '--timeout', '30000ms', '--commit-after-processing']' in 'None' (waiting)
2025-11-10 09:37:10,244 - DEBUG - ya.test - execute: Command pid: 321255
2025-11-10 09:37:10,654 - DEBUG - ya.test - _wait: Process resource usage is not available as process finished before wait4 was called
2025-11-10 09:37:10,699 - DEBUG - ya.test - _save_outputs: Command (pid 321255) rc: 0
2025-11-10 09:37:10,700 - DEBUG - ya.test - _save_outputs: Command (pid 321255) elapsed time (sec): 0.4536435604095459
2025-11-10 09:37:10,700 - DEBUG - ya.test - _save_outputs: Command (pid 321255) wtime: 0.461
2025-11-10 09:37:10,700 - DEBUG - ya.test - _save_outputs: Command (pid 321255) output:
None
2025-11-10 09:37:10,700 - DEBUG - ya.test - _save_outputs: Command (pid 321255) errors:
2025-11-10T09:37:10.342318Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Starting read session
2025-11-10T09:37:10.448911Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Starting session to cluster null (localhost:12880)
2025-11-10T09:37:10.449576Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] In Reconnect, ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-10T09:37:10.449596Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] New values: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-10T09:37:10.449604Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Reconnecting session to cluster null in 0.000000s
2025-11-10T09:37:10.463658Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Successfully connected. Initializing session
2025-11-10T09:37:10.540441Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Server session id: yds_dict_consumer_1_2_14203893009425294078_v1
2025-11-10T09:37:10.540570Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-10T09:37:10.546936Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Confirm partition stream create. Partition stream id: 1. Cluster: "". Topic: "yds_dict_output". Partition: 0. Read offset: (NULL)
2025-11-10T09:37:10.557178Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] After sending read request: ReadSizeBudget = 52428800, ReadSizeServerDelta = 0
2025-11-10T09:37:10.562335Z :DEBUG: [local] Decompression task done. Partition/PartitionSessionId: 0 (0-8)
2025-11-10T09:37:10.562402Z :DEBUG: [local] Take Data. Partition 0. Read: {0, 0} (0-0)
2025-11-10T09:37:10.567569Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 0} (1-1)
2025-11-10T09:37:10.567596Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 1} (2-2)
2025-11-10T09:37:10.567603Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 2} (3-3)
2025-11-10T09:37:10.567612Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 3} (4-4)
2025-11-10T09:37:10.567618Z :DEBUG: [local] Take Data. Partition 0. Read: {1, 4} (5-5)
2025-11-10T09:37:10.567624Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 0} (6-6)
2025-11-10T09:37:10.567630Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 1} (7-7)
2025-11-10T09:37:10.567648Z :DEBUG: [local] Take Data. Partition 0. Read: {2, 2} (8-8)
2025-11-10T09:37:10.567788Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Commit offsets [0, 9). Partition stream id: 1
2025-11-10T09:37:10.568012Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] The application data is transferred to the client. Number of messages 9, size 316 bytes
2025-11-10T09:37:10.583444Z :DEBUG: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] [null] Committed response: cookies { assign_id: 1 partition_cookie: 1 }
Closing session. Got 9 messages
2025-11-10T09:37:10.585799Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Closing read session. Close timeout: 5.000000s
2025-11-10T09:37:10.585863Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:yds_dict_output:0:1:8:9
2025-11-10T09:37:10.585877Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Counters: { Errors: 0 CurrentSessionLifetimeMs: 243 BytesRead: 316 MessagesRead: 9 BytesReadCompressed: 316 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
Session closed
2025-11-10T09:37:10.588264Z :NOTICE: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }
Stopping driver...
Driver stopped. Exit
Session closed event: SessionClosed { Status: SUCCESS Issues: "<main>: Error: Session was gracefully closed " }
2025-11-10T09:37:10.588503Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Closing read session. Close timeout: 0.000000s
2025-11-10T09:37:10.588538Z :INFO: [local] Read/commit by partition streams (cluster:topic:partition:stream-id:read-offset:committed-offset): null:yds_dict_output:0:1:8:9
2025-11-10T09:37:10.588552Z :INFO: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Counters: { Errors: 0 CurrentSessionLifetimeMs: 246 BytesRead: 316 MessagesRead: 9 BytesReadCompressed: 316 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-11-10T09:37:10.588568Z :NOTICE: [local] [local] [5410c21f-2d3c5983-48712ac4-c2d375df] Aborting read session. Description: SessionClosed { Status: ABORTED Issues: "<main>: Error: Aborted " }

2025-11-10 09:37:10,702 - INFO - root - read_stream: Data was read from yds_dict_output: ['{"num" = "one"; "word" = "January"}', '{"num" = "two"; "word" = "February"}', '{"num" = "three"; "word" = "March"}', '{"num" = "one"; "word" = "Monday"}', '{"num" = "two"; "word" = "Tuesday"}', '{"num" = "three"; "word" = "Wednesday"}', '{"num" = "one"; "word" = "Gold"}', '{"num" = "two"; "word" = "Silver"}', '{"num" = "three"; "word" = "Bronze"}']
2025-11-10 09:37:10,703 - DEBUG - root - test_checkpoints_on_join_s3_with_yds: Wait checkpoints
2025-11-10 09:37:11,271 - DEBUG - root - test_checkpoints_on_join_s3_with_yds: Wait checkpoints success
2025-11-10 09:37:13,881 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:37:13,965 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:37:13,978 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:37:13,979 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, b1b3e2e9-19f4-4162-bb51-5677099640db, localhost:12880): creating call state
2025-11-10 09:37:13,979 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, b1b3e2e9-19f4-4162-bb51-5677099640db, localhost:12880): request = { database: "local" }
2025-11-10 09:37:13,984 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, b1b3e2e9-19f4-4162-bb51-5677099640db, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:37:13,985 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:37:13,985 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:37:18,274 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:15742/1
2025-11-10 09:37:18,278 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/kikimr_configs"
2025-11-10 09:37:18,279 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd server --suppress-version-check --yaml-config=$CFG_DIR_PATH/config.yaml --node=1 --tenant=/default --node-kind=yq --log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1/logfile_wfx6wlfn.log --grpc-port=15742 --mon-port=12592 --ic-port=3542
2025-11-10 09:37:18,292 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/kikimr_configs/config.yaml', '--node=1', '--tenant=/default', '--node-kind=yq', '--log-file-name=/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1/logfile_wfx6wlfn.log', '--grpc-port=15742', '--mon-port=12592', '--ic-port=3542')' in '/home/runner/.ya/build/build_root/6t6o/002514/ydb/tests/fq/s3/test-results/py3test/testing_out_stuff/test_s3_0/testing_out_stuff/test_s3_0.py.TestS3.test_checkpoints_on_join_s3_with_yds.v1-mvp_external_ydb_endpoint0-client0/default/node_1' (no wait)
2025-11-10 09:37:18,297 - DEBUG - ya.test - execute: Command pid: 326084
2025-11-10 09:37:18,305 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:15742/1
2025-11-10 09:37:18,307 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.23
2025-11-10 09:37:18,308 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.23
2025-11-10 09:37:18,308 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/6t6o/002514/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-11-10 09:37:18,310 - DEBUG - ya.test - execute: Command pid: 326090
2025-11-10 09:37:18,815 - DEBUG - ya.test - _save_outputs: Command (pid 326090) rc: 0
2025-11-10 09:37:18,816 - DEBUG - ya.test - _save_outputs: Command (pid 326090) elapsed time (sec): 0.4930288791656494
2025-11-10 09:37:18,816 - DEBUG - ya.test - _save_outputs: Command (pid 326090) idrss: 0
2025-11-10 09:37:18,816 - DEBUG - ya.test - _save_outputs: Command (pid 326090) inblock: 0
2025-11-10 09:37:18,816 - DEBUG - ya.test - _save_outputs: Command (pid 326090) isrss: 0
2025-11-10 09:37:18,817 - DEBUG - ya.test - _save_outputs: Command (pid 326090) ixrss: 0
2025-11-10 09:37:18,817 - DEBUG - ya.test - _save_outputs: Command (pid 326090) majflt: 2
2025-11-10 09:37:18,817 - DEBUG - ya.test - _save_outputs: Command (pid 326090) maxrss: 540932
2025-11-10 09:37:18,817 - DEBUG - ya.test - _save_outputs: Command (pid 326090) minflt: 18690
2025-11-10 09:37:18,818 - DEBUG - ya.test - _save_outputs: Command (pid 326090) msgrcv: 0
2025-11-10 09:37:18,818 - DEBUG - ya.test - _save_outputs: Command (pid 326090) msgsnd: 0
2025-11-10 09:37:18,818 - DEBUG - ya.test - _save_outputs: Command (pid 326090) nivcsw: 17
2025-11-10 09:37:18,818 - DEBUG - ya.test - _save_outputs: Command (pid 326090) nsignals: 0
2025-11-10 09:37:18,818 - DEBUG - ya.test - _save_outputs: Command (pid 326090) nswap: 0
2025-11-10 09:37:18,819 - DEBUG - ya.test - _save_outputs: Command (pid 326090) nvcsw: 18
2025-11-10 09:37:18,819 - DEBUG - ya.test - _save_outputs: Command (pid 326090) oublock: 8
2025-11-10 09:37:18,819 - DEBUG - ya.test - _save_outputs: Command (pid 326090) stime: 0.289618
2025-11-10 09:37:18,820 - DEBUG - ya.test - _save_outputs: Command (pid 326090) utime: 0.148831
2025-11-10 09:37:18,820 - DEBUG - ya.test - _save_outputs: Command (pid 326090) wtime: 0.495
2025-11-10 09:37:18,820 - DEBUG - ya.test - _save_outputs: Command (pid 326090) output:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-kipqlopw2q
    Host information: 
        Linux ghrun-kipqlopw2q 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64

    
Build info:
    Compiler: /home/runner/.ya/tools/v4/9944335923/bin/clang++
    Compiler version: 
        clang version 20.1.8
        Target: x86_64-unknown-linux-gnu
        Thread model: posix
        InstalledDir: /home/runner/.ya/tools/v4/9944335923/bin
    Compile flags: -Xclang -fdebug-compilation-dir -Xclang /tmp -pipe -m64 -O3 -gline-tables-only -fno-common -ffunction-sections -fdata-sections -fsized-deallocation -fexceptions -fuse-init-array -fcolor-diagnostics -faligned-allocation -Werror -Wall -Wextra -Wno-parentheses -Wno-implicit-const-int-float-conversion -Wno-unknown-warning-option -D_THREAD_SAFE -D_PTHREADS -D_REENTRANT -D_LARGEFILE_SOURCE -D__STDC_CONSTANT_MACROS -D__STDC_FORMAT_MACROS -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -D_YNDX_LIBUNWIND_ENABLE_EXCEPTION_BACKTRACE -D__LONG_LONG_SUPPORTED -fno-omit-frame-pointer -Wno-unknown-argument -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -DCATBOOST_OPENSOURCE=yes -msse2 -msse3 -mssse3 -msse4.1 -msse4.2 -mpopcnt -mcx16 -UNDEBUG -Wno-array-parameter -Wno-deprecate-lax-vec-conv-all -Wno-unqualified-std-cast-call -Wno-unused-but-set-parameter -Wno-implicit-function-declaration -Wno-int-conversion -Wno-incompatible-function-pointer-types -Wno-address-of-packed-member -Wno-deprecated-this-capture -Wno-missing-designated-field-initializers -Wno-format -Wno-vla-cxx-extension -Wno-invalid-offsetof -Wno-alias-template-in-declaration-name -Wno-cast-function-type-mismatch -Wno-explicit-specialization-storage-class -Wno-extraneous-template-head -Wno-missing-template-arg-list-after-template-kw -Wno-nontrivial-memcall -Wno-strict-primary-template-shadow -std=c++20 -Wimport-preprocessor-directive-pedantic -Woverloaded-virtual -Wno-ambiguous-reversed-operator -Wno-defaulted-function-deleted -Wno-deprecated-anon-enum-enum-conversion -Wno-deprecated-enum-enum-conversion -Wno-deprecated-enum-float-conversion -Wno-deprecated-volatile -Wno-pessimizing-move -Wno-undefined-var-template -nostdinc++ -DCATBOOST_OPENSOURCE=yes -nostdinc++

2025-11-10 09:37:18,821 - DEBUG - ya.test - _save_outputs: Command (pid 326090) errors:

2025-11-10 09:37:18,821 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: 2d3bc32bffc01725fa6c3dd0bb0f7616ee098760
    Branch: 
    Author: Daniil Timižev <ditimizhev@ydb.tech>
    Summary: Merge 4ff3894868fb9bba81a268efd022ca68496f230a into 27b8fe5960eec979164acf2636986bcea3ca729d
2025-11-10 09:37:18,822 - DEBUG - root - wait_bootstrap: Wait for node 1 to bootstrap
2025-11-10 09:37:20,329 - DEBUG - root - wait_bootstrap: Node 1 has been bootstrapped
2025-11-10 09:37:20,350 - DEBUG - root - test_checkpoints_on_join_s3_with_yds: Wait checkpoints after restore
2025-11-10 09:37:23,021 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:37:23,093 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:37:23,110 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:37:23,169 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 9958ee59-db0b-48eb-9bbd-14da6f55a04d, localhost:12880): creating call state
2025-11-10 09:37:23,177 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 9958ee59-db0b-48eb-9bbd-14da6f55a04d, localhost:12880): request = { database: "local" }
2025-11-10 09:37:23,181 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 9958ee59-db0b-48eb-9bbd-14da6f55a04d, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:37:23,182 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:37:23,182 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:37:24,188 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:37:24,218 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:37:24,225 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:37:24,244 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 3dd45cbf-241c-46b0-b903-0a08349e8196, localhost:12880): creating call state
2025-11-10 09:37:24,245 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 3dd45cbf-241c-46b0-b903-0a08349e8196, localhost:12880): request = { database: "local" }
2025-11-10 09:37:24,253 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 3dd45cbf-241c-46b0-b903-0a08349e8196, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:37:24,313 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:37:24,314 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:37:33,349 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-11-10 09:37:33,349 - DEBUG - ydb.connection - channel_factory: Channel options: [('grpc.max_receive_message_length', 64000000), ('grpc.max_send_message_length', 64000000), ('grpc.primary_user_agent', 'python-library'), ('grpc.lb_policy_name', 'round_robin'), ('grpc.keepalive_time_ms', 1250), ('grpc.keepalive_timeout_ms', 10000), ('grpc.http2.max_pings_without_data', 0), ('grpc.keepalive_permit_without_calls', 0)]
2025-11-10 09:37:33,366 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database local
2025-11-10 09:37:33,367 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, b5abf71d-4a8a-4154-a196-3d35257c2b74, localhost:12880): creating call state
2025-11-10 09:37:33,367 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, b5abf71d-4a8a-4154-a196-3d35257c2b74, localhost:12880): request = { database: "local" }
2025-11-10 09:37:33,375 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, b5abf71d-4a8a-4154-a196-3d35257c2b74, localhost:12880): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-kipqlopw2q.auto.internal" port: 12880 service: "legacy" service: "tablet_service" service: "yql" service: "discovery" service: "cms" service: "locking" service: "kesus" service: "pq" service: "pqcd" service: "pqv1" service: "topic" service: "datastreams" service: "scripting" service: "clickhouse_internal" service: "rate_limiter" service: "analytics" service: "export" service: "import" service: "yq" service: "keyvalue" service: "monitoring" service: "auth" service: "query_service" service: "view" location: "1" node_id: 1 } self_location: "1" } } } }
2025-11-10 09:37:33,376 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database local: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-kipqlopw2q.auto.internal:12880, location 1, ssl: False>]>
2025-11-10 09:37:33,376 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:12880
2025-11-10 09:37:35,610 - DEBUG - root - test_checkpoints_on_join_s3_with_yds: Wait checkpoints after restore success
2025-11-10 09:37:36,187 - DEBUG - root - control_query: Result: 
2025-11-10 09:37:36,204 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudsomsqv553cv1eic"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762767427
        nanos: 103428000
      }
      modified_at {
        seconds: 1762767456
        nanos: 21718000
      }
      revision: 2
    }
    started_at {
      seconds: 1762767428
      nanos: 201000000
    }
    execute_mode: RUN
    status: ABORTING_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudsomsqv548p3e4dq-ptqudsomsqv553cv1eic"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762767427
      nanos: 103428000
    }
  }
  content {
    type: STREAMING
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            $s3_dict_raw =\n                SELECT cast(Data AS json) AS data\n                FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict`.`*`\n                WITH (format=raw, SCHEMA (\n                    Data String NOT NULL\n                ));\n\n            $s3_dict =\n                SELECT\n                    cast(JSON_VALUE(data, \'$.key\') AS int64) AS key,\n                    cast(JSON_VALUE(data, \'$.value\') AS String) AS value\n                FROM $s3_dict_raw;\n\n            $parsed_yson_topic =\n                SELECT\n                    Yson::LookupInt64(yson_data, \"key\") AS key,\n                    Yson::LookupString(yson_data, \"val\") AS val\n                FROM (\n                    SELECT\n                        Yson::Parse(Data) AS yson_data\n                    FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_input` WITH SCHEMA (Data String NOT NULL));\n\n            $joined_seq =\n                SELECT\n                    s3_dict.value AS num,\n                    yds_seq.val AS word\n                FROM $parsed_yson_topic AS yds_seq\n                    INNER JOIN $s3_dict AS s3_dict\n                        ON yds_seq.key = s3_dict.key;\n\n            INSERT INTO `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_output`\n            SELECT\n                Yson::SerializeText(Yson::From(TableRow()))\n            FROM $joined_seq;\n            "
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":17,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":15,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[17]},{\"Id\":4,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"SkipNullMembers\"},{\"Name\":\"DqPhyMapJoin\"},{\"Name\":\"ExtractMembers\"},{\"Name\":\"FlatMap\"}]},\"DependsOn\":[6,15]},{\"Id\":3,\"Name\":\"DqQuery!\",\"DependsOn\":[4]},{\"Id\":2,\"Name\":\"Commit!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":2,\"DqQuery!\":1,\"DqStage\":4}},\"Basic\":{\"nodes\":[{\"id\":6,\"level\":1,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":17,\"level\":1,\"name\":\"DqStage #17\",\"type\":\"op\"},{\"id\":15,\"level\":2,\"name\":\"DqStage #15\",\"type\":\"op\"},{\"id\":4,\"level\":3,\"name\":\"DqStage #4\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":2,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"},{\"id\":1,\"level\":6,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":17,\"target\":15},{\"source\":6,\"target\":4},{\"source\":15,\"target\":4},{\"source\":4,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":5,\"count\":4,\"avg\":1,\"max\":2,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.44s\",\"count\":5,\"avg\":\"88ms\",\"max\":\"0.22s\",\"min\":\"0.00s\"},\"IngressBytes\":{\"sum\":80,\"count\":2,\"avg\":40,\"max\":54,\"min\":26},\"IngressRows\":{\"sum\":3,\"count\":2,\"avg\":1,\"max\":2,\"min\":1},\"InputBytes\":{\"sum\":26,\"count\":1,\"avg\":26,\"max\":26,\"min\":26},\"InputRows\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"OutputBytes\":{\"sum\":49,\"count\":3,\"avg\":16,\"max\":23,\"min\":8},\"OutputRows\":{\"sum\":6,\"count\":3,\"avg\":2,\"max\":3,\"min\":1},\"MaxMemoryUsage\":{\"sum\":6094848,\"count\":3,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"IngressQueuedBytes\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $3 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $4 (DataSource \'\"pq\" $3))\n(let $5 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $6 (DataType \'String))\n(let $7 (StructType \'(\'\"Data\" $6)))\n(let $8 (PqTopic $3 \'\"local\" \'\"yds_dict_input\" $5 \'() $7))\n(let $9 \'(\'\"Endpoint\" \'\"localhost:12880\"))\n(let $10 \'(\'\"SharedReading\" \'0))\n(let $11 \'(\'\"AddBearerToToken\" \'1))\n(let $12 \'($9 $10 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudsomsr0dvvo0otgs\") $11))\n(let $13 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $14 (SecureParam $13))\n(let $15 (DqPqTopicSource $2 $8 \'(\'\"Data\") $12 $14 \'\"\" $7 \'\"\"))\n(let $16 \'(\'format \'\"raw\"))\n(let $17 (lambda \'($41) (AsStruct \'(\'\"Data\" $41))))\n(let $18 (ResourceType \'\"Yson2.Node\"))\n(let $19 \'(\'(\'\"strict\")))\n(let $20 (Bool \'\"true\"))\n(let $21 (DataType \'Yson))\n(let $22 \'($18 \'\"\" \'1))\n(let $23 (CallableType \'() \'($21) $22))\n(let $24 (OptionalType (DataType \'Int64)))\n(let $25 \'($18))\n(let $26 (OptionalType $6))\n(let $27 (DqStage \'((DqSource $4 $15)) (lambda \'($38) (block \'(\n  (let $39 \'($16 \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'settings \'($10))))\n  (let $40 (DqSourceWideWrap $38 $4 $7 $39))\n  (return (FlatMap (NarrowMap $40 $17) (lambda \'($42) (block \'(\n    (let $43 (ResourceType \'\"Yson2.Options\"))\n    (let $44 (TupleType (TupleType $6 $43) (StructType) (TupleType)))\n    (let $45 \'(\'1))\n    (let $46 \'($6 \'\"\" \'1))\n    (let $47 \'((OptionalType $43)))\n    (let $48 (CallableType $45 \'((OptionalType $18)) $46 $47))\n    (let $49 (Udf \'\"Yson2.Parse\" (Void) $44 \'\"\" $48 (VoidType) \'\"\" \'()))\n    (let $50 (OptionalType (DataType \'Bool)))\n    (let $51 (CallableType \'(\'\"2\") \'($43) \'($50 \'\"AutoConvert\") \'($50 \'\"Strict\")))\n    (let $52 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $51 (VoidType) \'\"\" $19))\n    (let $53 (Just (NamedApply $52 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'\"false\"))) \'(\'\"Strict\" (Just $20))))))\n    (let $54 (Apply $49 (Member $42 \'\"Data\") $53))\n    (let $55 (FlatMap $54 (lambda \'($61) (block \'(\n      (let $62 (Udf \'\"Yson2.Serialize\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n      (return (Just (Apply $62 $61)))\n    )))))\n    (let $56 \'($6))\n    (let $57 (TupleType (TupleType $21) (StructType) (TupleType)))\n    (let $58 \'($21 \'\"\" \'1))\n    (let $59 (CallableType $45 $25 $58 $47))\n    (let $60 (Udf \'\"Yson2.Parse\" (Void) $57 \'\"\" $59 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"key\" (FlatMap $55 (lambda \'($63) (block \'(\n      (let $64 (CallableType $45 \'($24) $22 $56 $47))\n      (let $65 (Udf \'\"Yson2.LookupInt64\" (Void) (VoidType) \'\"\" $64 (VoidType) \'\"\" \'()))\n      (return (Apply $65 (Apply $60 $63) (String \'\"key\") $53))\n    ))))) \'(\'\"val\" (FlatMap $55 (lambda \'($66) (block \'(\n      (let $67 (CallableType $45 \'($26) $22 $56 $47))\n      (let $68 (Udf \'\"Yson2.LookupString\" (Void) (VoidType) \'\"\" $67 (VoidType) \'\"\" \'()))\n      (return (Apply $68 (Apply $60 $66) (String \'\"val\") $53))\n    ))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211804))))\n(let $28 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $29 (DataSource \'\"s3\" $28))\n(let $30 \'\"Paths {\\n  Name: \\\"a\\\"\\n  Children {\\n    Name: \\\"b\\\"\\n    Children {\\n      Name: \\\"c\\\"\\n      Children {\\n        Name: \\\"1.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"2.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"3.json\\\"\\n        Size: 28\\n        Read: true\\n      }\\n      IsDirectory: true\\n    }\\n    IsDirectory: true\\n  }\\n  IsDirectory: true\\n}\\n\")\n(let $31 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $32 (S3SourceSettings $2 \'(\'((String $30) $20 (AsStruct))) (SecureParam $31) \'\"\" \'\"* \" (Void) (Void) (Void)))\n(let $33 (DqStage \'((DqSource $29 $32)) (lambda \'($69) (block \'(\n  (let $70 (DqSourceWideWrap $69 $29 $7 \'($16 \'(\'settings \'()))))\n  (return (FlatMap (NarrowMap $70 $17) (lambda \'($71) (block \'(\n    (let $72 (SafeCast (Member $71 \'\"Data\") (OptionalType (DataType \'Json))))\n    (let $73 (JsonValue $72 (Utf8 \'\"$.key\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (let $74 (JsonValue $72 (Utf8 \'\"$.value\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (return (Just (AsStruct \'(\'\"key\" (SafeCast $73 $24)) \'(\'\"value\" (SafeCast $74 $26)))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211846))))\n(let $34 (DqStage \'((DqCnUnionAll (TDqOutput $33 \'0))) (lambda \'($75) $75) \'(\'(\'\"_logical_id\" \'211902))))\n(let $35 (DataSink \'\"pq\" $3))\n(let $36 (PqTopic $3 \'\"local\" \'\"yds_dict_output\" $5 \'() $7))\n(let $37 (DqPqTopicSink $36 \'($9 $11) $14))\n(return (Commit! (Commit! (DqQuery! $2 \'((DqStage \'((DqCnMap (TDqOutput $27 \'0)) (DqCnBroadcast (TDqOutput $34 \'0))) (lambda \'($76 $77) (block \'(\n  (let $78 \'(\'\"key\"))\n  (let $79 (DqPhyMapJoin (SkipNullMembers $76 $78) (SkipNullMembers $77 $78) \'\"yds_seq\" \'\"s3_dict\" \'Inner \'(\'(\'\"yds_seq\" \'\"key\" \'\"s3_dict\" \'\"key\")) \'(\'\"yds_seq.key\") \'(\'\"s3_dict.key\")))\n  (return (FlatMap (ExtractMembers $79 \'(\'\"s3_dict.value\" \'\"yds_seq.val\")) (lambda \'($80) (block \'(\n    (let $81 (Udf \'\"Yson2.SerializeText\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n    (let $82 (StructType \'(\'\"num\" $26) \'(\'\"word\" $26)))\n    (let $83 (TupleType (TupleType $82) (StructType) (TupleType)))\n    (let $84 (CallableType \'() $25 \'($82)))\n    (let $85 (Udf \'\"Yson2.From\" (Void) $83 \'\"\" $84 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"column0\" (Apply $81 (Apply $85 (AsStruct \'(\'\"num\" (Member $80 \'\"s3_dict.value\")) \'(\'\"word\" (Member $80 \'\"yds_seq.val\")))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'212047)) \'((DqSink \'0 $35 $37))))) $35) (DataSink \'\"s3\" $28)))\n)\n"
  }
}

2025-11-10 09:37:36,735 - DEBUG - root - describe_query: Result: ... (repeated, see above) ...
2025-11-10 09:37:37,259 - DEBUG - root - describe_query: Result: query {
  meta {
    common {
      id: "ptqudsomsqv553cv1eic"
      created_by: "root@builtin"
      modified_by: "root@builtin"
      created_at {
        seconds: 1762767427
        nanos: 103428000
      }
      modified_at {
        seconds: 1762767456
        nanos: 21718000
      }
      revision: 2
    }
    started_at {
      seconds: 1762767428
      nanos: 201000000
    }
    finished_at {
      seconds: 1762767456
      nanos: 540000000
    }
    execute_mode: RUN
    status: ABORTED_BY_USER
    last_job_query_revision: 1
    last_job_id: "ptjudsomsqv548p3e4dq-ptqudsomsqv553cv1eic"
    started_by: "root@builtin"
    aborted_by: "root@builtin"
    has_saved_checkpoints: true
    submitted_at {
      seconds: 1762767427
      nanos: 103428000
    }
  }
  content {
    type: STREAMING
    name: "simple"
    acl {
      visibility: PRIVATE
    }
    limits {
      execution_timeout {
      }
    }
    text: "\n            PRAGMA dq.MaxTasksPerStage=\"2\";\n\n            $s3_dict_raw =\n                SELECT cast(Data AS json) AS data\n                FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict`.`*`\n                WITH (format=raw, SCHEMA (\n                    Data String NOT NULL\n                ));\n\n            $s3_dict =\n                SELECT\n                    cast(JSON_VALUE(data, \'$.key\') AS int64) AS key,\n                    cast(JSON_VALUE(data, \'$.value\') AS String) AS value\n                FROM $s3_dict_raw;\n\n            $parsed_yson_topic =\n                SELECT\n                    Yson::LookupInt64(yson_data, \"key\") AS key,\n                    Yson::LookupString(yson_data, \"val\") AS val\n                FROM (\n                    SELECT\n                        Yson::Parse(Data) AS yson_data\n                    FROM `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_input` WITH SCHEMA (Data String NOT NULL));\n\n            $joined_seq =\n                SELECT\n                    s3_dict.value AS num,\n                    yds_seq.val AS word\n                FROM $parsed_yson_topic AS yds_seq\n                    INNER JOIN $s3_dict AS s3_dict\n                        ON yds_seq.key = s3_dict.key;\n\n            INSERT INTO `h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds`.`yds_dict_output`\n            SELECT\n                Yson::SerializeText(Yson::From(TableRow()))\n            FROM $joined_seq;\n            "
    syntax: YQL_V1
  }
  plan {
    json: "{\"Detailed\":{\"Operations\":[{\"Id\":6,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":17,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"DqSourceWideWrap\"},{\"Name\":\"NarrowMap\"},{\"Name\":\"FlatMap\"}]}},{\"Id\":15,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[]},\"DependsOn\":[17]},{\"Id\":4,\"Name\":\"DqStage\",\"Streams\":{\"Program\":[{\"Name\":\"SkipNullMembers\"},{\"Name\":\"DqPhyMapJoin\"},{\"Name\":\"ExtractMembers\"},{\"Name\":\"FlatMap\"}]},\"DependsOn\":[6,15]},{\"Id\":3,\"Name\":\"DqQuery!\",\"DependsOn\":[4]},{\"Id\":2,\"Name\":\"Commit!\",\"DependsOn\":[3]},{\"Id\":1,\"Name\":\"Commit!\",\"DependsOn\":[2]}],\"OperationRoot\":1,\"Providers\":[],\"OperationStats\":{\"Commit!\":2,\"DqQuery!\":1,\"DqStage\":4}},\"Basic\":{\"nodes\":[{\"id\":6,\"level\":1,\"name\":\"DqStage #6\",\"type\":\"op\"},{\"id\":17,\"level\":1,\"name\":\"DqStage #17\",\"type\":\"op\"},{\"id\":15,\"level\":2,\"name\":\"DqStage #15\",\"type\":\"op\"},{\"id\":4,\"level\":3,\"name\":\"DqStage #4\",\"type\":\"op\"},{\"id\":3,\"level\":4,\"name\":\"DqQuery!\",\"type\":\"op\"},{\"id\":2,\"level\":5,\"name\":\"Commit!\",\"type\":\"op\"},{\"id\":1,\"level\":6,\"name\":\"Commit!\",\"type\":\"op\"}],\"links\":[{\"source\":17,\"target\":15},{\"source\":6,\"target\":4},{\"source\":15,\"target\":4},{\"source\":4,\"target\":3},{\"source\":3,\"target\":2},{\"source\":2,\"target\":1}]}}"
  }
  issue {
    message: "ABORTED_BY_USER"
    severity: 1
  }
  statistics {
    json: "{\"Graph=0\":{\"Tasks\":{\"sum\":5,\"count\":4,\"avg\":1,\"max\":2,\"min\":1},\"CpuTimeUs\":{\"sum\":\"0.44s\",\"count\":5,\"avg\":\"88ms\",\"max\":\"0.22s\",\"min\":\"0.00s\"},\"IngressBytes\":{\"sum\":80,\"count\":2,\"avg\":40,\"max\":54,\"min\":26},\"IngressRows\":{\"sum\":3,\"count\":2,\"avg\":1,\"max\":2,\"min\":1},\"InputBytes\":{\"sum\":26,\"count\":1,\"avg\":26,\"max\":26,\"min\":26},\"InputRows\":{\"sum\":3,\"count\":1,\"avg\":3,\"max\":3,\"min\":3},\"OutputBytes\":{\"sum\":49,\"count\":3,\"avg\":16,\"max\":23,\"min\":8},\"OutputRows\":{\"sum\":6,\"count\":3,\"avg\":2,\"max\":3,\"min\":1},\"MaxMemoryUsage\":{\"sum\":6094848,\"count\":3,\"avg\":2031616,\"max\":2031616,\"min\":2031616},\"IngressQueuedBytes\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0},\"IngressQueuedRows\":{\"sum\":0,\"count\":3,\"avg\":0,\"max\":0,\"min\":0}}}"
  }
  ast {
    data: "(\n(let $1 (Configure! world (DataSource \'\"config\") \'\"DqEngine\" \'\"force\"))\n(let $2 (Configure! $1 (DataSource \'\"dq\" \'\"$all\") \'\"Attr\" \'\"maxtasksperstage\" \'\"2\"))\n(let $3 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $4 (DataSource \'\"pq\" $3))\n(let $5 \'(\'(\'\"PartitionsCount\" \'1)))\n(let $6 (DataType \'String))\n(let $7 (StructType \'(\'\"Data\" $6)))\n(let $8 (PqTopic $3 \'\"local\" \'\"yds_dict_input\" $5 \'() $7))\n(let $9 \'(\'\"Endpoint\" \'\"localhost:12880\"))\n(let $10 \'(\'\"SharedReading\" \'0))\n(let $11 \'(\'\"AddBearerToToken\" \'1))\n(let $12 \'($9 $10 \'(\'\"ReconnectPeriod\" \'\"\") \'(\'\"Format\" \'\"raw\") \'(\'\"ReadGroup\" \'\"ptcudsomsr0dvvo0otgs\") $11))\n(let $13 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydsyds\")\n(let $14 (SecureParam $13))\n(let $15 (DqPqTopicSource $2 $8 \'(\'\"Data\") $12 $14 \'\"\" $7 \'\"\"))\n(let $16 \'(\'format \'\"raw\"))\n(let $17 (lambda \'($41) (AsStruct \'(\'\"Data\" $41))))\n(let $18 (ResourceType \'\"Yson2.Node\"))\n(let $19 \'(\'(\'\"strict\")))\n(let $20 (Bool \'\"true\"))\n(let $21 (DataType \'Yson))\n(let $22 \'($18 \'\"\" \'1))\n(let $23 (CallableType \'() \'($21) $22))\n(let $24 (OptionalType (DataType \'Int64)))\n(let $25 \'($18))\n(let $26 (OptionalType $6))\n(let $27 (DqStage \'((DqSource $4 $15)) (lambda \'($38) (block \'(\n  (let $39 \'($16 \'(\'\"formatSettings\" \'(\'(\'\"data.datetime.formatname\" \'\"POSIX\") \'(\'\"data.timestamp.formatname\" \'\"POSIX\"))) \'(\'settings \'($10))))\n  (let $40 (DqSourceWideWrap $38 $4 $7 $39))\n  (return (FlatMap (NarrowMap $40 $17) (lambda \'($42) (block \'(\n    (let $43 (ResourceType \'\"Yson2.Options\"))\n    (let $44 (TupleType (TupleType $6 $43) (StructType) (TupleType)))\n    (let $45 \'(\'1))\n    (let $46 \'($6 \'\"\" \'1))\n    (let $47 \'((OptionalType $43)))\n    (let $48 (CallableType $45 \'((OptionalType $18)) $46 $47))\n    (let $49 (Udf \'\"Yson2.Parse\" (Void) $44 \'\"\" $48 (VoidType) \'\"\" \'()))\n    (let $50 (OptionalType (DataType \'Bool)))\n    (let $51 (CallableType \'(\'\"2\") \'($43) \'($50 \'\"AutoConvert\") \'($50 \'\"Strict\")))\n    (let $52 (Udf \'\"Yson2.Options\" (Void) (VoidType) \'\"\" $51 (VoidType) \'\"\" $19))\n    (let $53 (Just (NamedApply $52 \'() (AsStruct \'(\'\"AutoConvert\" (Just (Bool \'\"false\"))) \'(\'\"Strict\" (Just $20))))))\n    (let $54 (Apply $49 (Member $42 \'\"Data\") $53))\n    (let $55 (FlatMap $54 (lambda \'($61) (block \'(\n      (let $62 (Udf \'\"Yson2.Serialize\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n      (return (Just (Apply $62 $61)))\n    )))))\n    (let $56 \'($6))\n    (let $57 (TupleType (TupleType $21) (StructType) (TupleType)))\n    (let $58 \'($21 \'\"\" \'1))\n    (let $59 (CallableType $45 $25 $58 $47))\n    (let $60 (Udf \'\"Yson2.Parse\" (Void) $57 \'\"\" $59 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"key\" (FlatMap $55 (lambda \'($63) (block \'(\n      (let $64 (CallableType $45 \'($24) $22 $56 $47))\n      (let $65 (Udf \'\"Yson2.LookupInt64\" (Void) (VoidType) \'\"\" $64 (VoidType) \'\"\" \'()))\n      (return (Apply $65 (Apply $60 $63) (String \'\"key\") $53))\n    ))))) \'(\'\"val\" (FlatMap $55 (lambda \'($66) (block \'(\n      (let $67 (CallableType $45 \'($26) $22 $56 $47))\n      (let $68 (Udf \'\"Yson2.LookupString\" (Void) (VoidType) \'\"\" $67 (VoidType) \'\"\" \'()))\n      (return (Apply $68 (Apply $60 $66) (String \'\"val\") $53))\n    ))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211804))))\n(let $28 \'\"h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $29 (DataSource \'\"s3\" $28))\n(let $30 \'\"Paths {\\n  Name: \\\"a\\\"\\n  Children {\\n    Name: \\\"b\\\"\\n    Children {\\n      Name: \\\"c\\\"\\n      Children {\\n        Name: \\\"1.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"2.json\\\"\\n        Size: 26\\n        Read: true\\n      }\\n      Children {\\n        Name: \\\"3.json\\\"\\n        Size: 28\\n        Read: true\\n      }\\n      IsDirectory: true\\n    }\\n    IsDirectory: true\\n  }\\n  IsDirectory: true\\n}\\n\")\n(let $31 \'\"cluster:default_h8575797213936842846_test_checkpoints_on_join_s3_with_ydss3_dict\")\n(let $32 (S3SourceSettings $2 \'(\'((String $30) $20 (AsStruct))) (SecureParam $31) \'\"\" \'\"* \" (Void) (Void) (Void)))\n(let $33 (DqStage \'((DqSource $29 $32)) (lambda \'($69) (block \'(\n  (let $70 (DqSourceWideWrap $69 $29 $7 \'($16 \'(\'settings \'()))))\n  (return (FlatMap (NarrowMap $70 $17) (lambda \'($71) (block \'(\n    (let $72 (SafeCast (Member $71 \'\"Data\") (OptionalType (DataType \'Json))))\n    (let $73 (JsonValue $72 (Utf8 \'\"$.key\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (let $74 (JsonValue $72 (Utf8 \'\"$.value\") (EmptyDict) \'DefaultValue (Null) \'DefaultValue (Null)))\n    (return (Just (AsStruct \'(\'\"key\" (SafeCast $73 $24)) \'(\'\"value\" (SafeCast $74 $26)))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'211846))))\n(let $34 (DqStage \'((DqCnUnionAll (TDqOutput $33 \'0))) (lambda \'($75) $75) \'(\'(\'\"_logical_id\" \'211902))))\n(let $35 (DataSink \'\"pq\" $3))\n(let $36 (PqTopic $3 \'\"local\" \'\"yds_dict_output\" $5 \'() $7))\n(let $37 (DqPqTopicSink $36 \'($9 $11) $14))\n(return (Commit! (Commit! (DqQuery! $2 \'((DqStage \'((DqCnMap (TDqOutput $27 \'0)) (DqCnBroadcast (TDqOutput $34 \'0))) (lambda \'($76 $77) (block \'(\n  (let $78 \'(\'\"key\"))\n  (let $79 (DqPhyMapJoin (SkipNullMembers $76 $78) (SkipNullMembers $77 $78) \'\"yds_seq\" \'\"s3_dict\" \'Inner \'(\'(\'\"yds_seq\" \'\"key\" \'\"s3_dict\" \'\"key\")) \'(\'\"yds_seq.key\") \'(\'\"s3_dict.key\")))\n  (return (FlatMap (ExtractMembers $79 \'(\'\"s3_dict.value\" \'\"yds_seq.val\")) (lambda \'($80) (block \'(\n    (let $81 (Udf \'\"Yson2.SerializeText\" (Void) (VoidType) \'\"\" $23 (VoidType) \'\"\" $19))\n    (let $82 (StructType \'(\'\"num\" $26) \'(\'\"word\" $26)))\n    (let $83 (TupleType (TupleType $82) (StructType) (TupleType)))\n    (let $84 (CallableType \'() $25 \'($82)))\n    (let $85 (Udf \'\"Yson2.From\" (Void) $83 \'\"\" $84 (VoidType) \'\"\" $19))\n    (return (Just (AsStruct \'(\'\"column0\" (Apply $81 (Apply $85 (AsStruct \'(\'\"num\" (Member $80 \'\"s3_dict.value\")) \'(\'\"word\" (Member $80 \'\"yds_seq.val\")))))))))\n  )))))\n))) \'(\'(\'\"_logical_id\" \'212047)) \'((DqSink \'0 $35 $37))))) $35) (DataSink \'\"s3\" $28)))\n)\n"
  }
}

2025-11-10 09:37:37,288 - INFO - ya.test - pytest_runtest_teardown: Test teardown
