2025-10-27 08:37:19,250 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-10-27 08:37:19,251 - INFO - ya.test - pytest_runtest_setup: test[column]
2025-10-27 08:37:19,251 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-10-27 08:37:19,251 - INFO - ya.test - pytest_runtest_setup: Test setup
2025-10-27 08:37:19,252 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd
2025-10-27 08:37:19,318 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/7928
2025-10-27 08:37:19,321 - DEBUG - ydb.tests.library.harness.kikimr_runner - start: Working directory: /home/runner/.ya/build/build_root/dyq9/002e17/r3tmp/kikimr_cluster_r7eei_7c
2025-10-27 08:37:19,356 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/17350
2025-10-27 08:37:19,364 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/5082
2025-10-27 08:37:19,366 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/61185
2025-10-27 08:37:19,368 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/5728
2025-10-27 08:37:19,372 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/kikimr_configs"
2025-10-27 08:37:19,372 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/dyq9/002e17/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/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_kvhx_l6y.log --grpc-port=17350 --mon-port=5082 --ic-port=7928 --module=1
2025-10-27 08:37:19,374 - DEBUG - ydb.tests.library.harness.kikimr_runner - format_pdisk: Formatting pdisk SectorMap:1:64 on node localhost:17350/1, disk_size 68719476736
2025-10-27 08:37:19,374 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/kikimr_configs"
2025-10-27 08:37:19,379 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/dyq9/002e17/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/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_kvhx_l6y.log --grpc-port=17350 --mon-port=5082 --ic-port=7928 --module=1
2025-10-27 08:37:19,380 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/kikimr_configs/config.yaml', '--node=1', '--log-file-name=/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_kvhx_l6y.log', '--grpc-port=17350', '--mon-port=5082', '--ic-port=7928', '--module=1')' in '/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1' (no wait)
2025-10-27 08:37:19,382 - DEBUG - ya.test - execute: Command pid: 3605697
2025-10-27 08:37:19,382 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:17350/1
2025-10-27 08:37:19,383 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.2
2025-10-27 08:37:19,384 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.2
2025-10-27 08:37:19,384 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-10-27 08:37:19,385 - DEBUG - ya.test - execute: Command pid: 3605706
2025-10-27 08:37:19,896 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) rc: 0
2025-10-27 08:37:19,897 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) elapsed time (sec): 0.5098211765289307
2025-10-27 08:37:19,897 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) idrss: 0
2025-10-27 08:37:19,897 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) inblock: 0
2025-10-27 08:37:19,897 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) isrss: 0
2025-10-27 08:37:19,898 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) ixrss: 0
2025-10-27 08:37:19,904 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) majflt: 0
2025-10-27 08:37:19,905 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) maxrss: 540192
2025-10-27 08:37:19,905 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) minflt: 16125
2025-10-27 08:37:19,905 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) msgrcv: 0
2025-10-27 08:37:19,905 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) msgsnd: 0
2025-10-27 08:37:19,911 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) nivcsw: 92
2025-10-27 08:37:19,911 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) nsignals: 0
2025-10-27 08:37:19,911 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) nswap: 0
2025-10-27 08:37:19,916 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) nvcsw: 16
2025-10-27 08:37:19,916 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) oublock: 8
2025-10-27 08:37:19,917 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) stime: 0.251809
2025-10-27 08:37:19,917 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) utime: 0.127783
2025-10-27 08:37:19,917 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) wtime: 0.511
2025-10-27 08:37:19,917 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) output:
Git info:
    Commit: adb44c074251a1871f952a1fe07a46be1893a61c
    Branch: 
    Author: nfrmtk <nfrmtk.aka.fkfka@gmail.com>
    Summary: Merge 48882a55d21ba4abb146d6a9c2cd1aadf2a909fc into 959c4f93fed7b73b12b83b26b671758583f027f9

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-aathosbtb4
    Host information: 
        Linux ghrun-aathosbtb4 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-10-27 08:37:19,918 - DEBUG - ya.test - _save_outputs: Command (pid 3605706) errors:

2025-10-27 08:37:19,919 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: adb44c074251a1871f952a1fe07a46be1893a61c
    Branch: 
    Author: nfrmtk <nfrmtk.aka.fkfka@gmail.com>
    Summary: Merge 48882a55d21ba4abb146d6a9c2cd1aadf2a909fc into 959c4f93fed7b73b12b83b26b671758583f027f9
2025-10-27 08:37:21,760 - DEBUG - ydb.tests.library.harness.kikimr_runner - __call_kikimr_new_cli: Executing command = ['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:17350', '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: 7928\n      }\n      HostConfigId: 1\n    }\n  }\n}\n']
2025-10-27 08:37:21,761 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.3
2025-10-27 08:37:21,762 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.3
2025-10-27 08:37:21,762 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:17350', '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: 7928\n      }\n      HostConfigId: 1\n    }\n  }\n}\n']' in 'None' (waiting)
2025-10-27 08:37:21,763 - DEBUG - ya.test - execute: Command pid: 3607483
2025-10-27 08:37:22,358 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) rc: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) elapsed time (sec): 0.5928292274475098
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) idrss: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) inblock: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) isrss: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) ixrss: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) majflt: 0
2025-10-27 08:37:22,359 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) maxrss: 548576
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) minflt: 18269
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) msgrcv: 0
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) msgsnd: 0
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) nivcsw: 153
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) nsignals: 0
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) nswap: 0
2025-10-27 08:37:22,360 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) nvcsw: 133
2025-10-27 08:37:22,361 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) oublock: 8
2025-10-27 08:37:22,361 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) stime: 0.331721
2025-10-27 08:37:22,361 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) utime: 0.138253
2025-10-27 08:37:22,361 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) wtime: 0.595
2025-10-27 08:37:22,361 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) output:
Status {
  Success: true
}
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 4

2025-10-27 08:37:22,362 - DEBUG - ya.test - _save_outputs: Command (pid 3607483) errors:

2025-10-27 08:37:22,383 - DEBUG - ydb.tests.library.harness.kikimr_runner - __call_kikimr_new_cli: Executing command = ['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:17350', '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']
2025-10-27 08:37:22,385 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.4
2025-10-27 08:37:22,385 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.4
2025-10-27 08:37:22,385 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:17350', '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-10-27 08:37:22,391 - DEBUG - ya.test - execute: Command pid: 3607982
2025-10-27 08:37:22,998 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) rc: 0
2025-10-27 08:37:23,013 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) elapsed time (sec): 0.5751125812530518
2025-10-27 08:37:23,015 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) idrss: 0
2025-10-27 08:37:23,015 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) inblock: 0
2025-10-27 08:37:23,015 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) isrss: 0
2025-10-27 08:37:23,015 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) ixrss: 0
2025-10-27 08:37:23,016 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) majflt: 0
2025-10-27 08:37:23,016 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) maxrss: 548464
2025-10-27 08:37:23,016 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) minflt: 18268
2025-10-27 08:37:23,016 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) msgrcv: 0
2025-10-27 08:37:23,016 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) msgsnd: 0
2025-10-27 08:37:23,021 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) nivcsw: 95
2025-10-27 08:37:23,021 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) nsignals: 0
2025-10-27 08:37:23,021 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) nswap: 0
2025-10-27 08:37:23,021 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) nvcsw: 126
2025-10-27 08:37:23,021 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) oublock: 8
2025-10-27 08:37:23,022 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) stime: 0.318992
2025-10-27 08:37:23,022 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) utime: 0.12124099999999999
2025-10-27 08:37:23,022 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) wtime: 0.58
2025-10-27 08:37:23,022 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) output:
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 5

2025-10-27 08:37:23,022 - DEBUG - ya.test - _save_outputs: Command (pid 3607982) errors:

2025-10-27 08:37:23,023 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Binding storage pools to domain Root: {'dynamic_storage_pool:1': 'hdd'}
2025-10-27 08:37:23,053 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-10-27 08:37:23,091 - 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-10-27 08:37:23,094 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:37:23,094 - 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-10-27 08:37:23,109 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-27 08:37:23,110 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 06d8c972-99ea-421e-be34-d2f1e5384879, localhost:17350): creating call state
2025-10-27 08:37:23,111 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 06d8c972-99ea-421e-be34-d2f1e5384879, localhost:17350): request = { database: "/Root" }
2025-10-27 08:37:23,114 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 06d8c972-99ea-421e-be34-d2f1e5384879, localhost:17350): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-aathosbtb4.auto.internal" port: 17350 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-10-27 08:37:23,114 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-aathosbtb4.auto.internal:17350, location 1, ssl: False>]>
2025-10-27 08:37:23,115 - 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-10-27 08:37:23,138 - INFO - ya.test - pytest_runtest_call: Test call (class_name: test_workload.py::TestYdbLogWorkload, test_name: test[column])
2025-10-27 08:37:23,138 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/workload_log
2025-10-27 08:37:23,141 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to workload_log.out.0
2025-10-27 08:37:23,149 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to workload_log.err.0
2025-10-27 08:37:23,154 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/workload_log', '--endpoint', 'grpc://localhost:17350', '--database', '/Root', '--store_type', 'column', '--duration', '120']' in 'None' (waiting)
2025-10-27 08:37:23,164 - DEBUG - ya.test - execute: Command pid: 3608440
2025-10-27 08:38:26,005 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:38:26,005 - 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-10-27 08:38:35,694 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:38:35,695 - 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-10-27 08:38:35,700 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-27 08:38:35,705 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, c09be8ad-7d3d-4e1e-b5a0-7abdea642703, localhost:17350): creating call state
2025-10-27 08:38:35,711 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, c09be8ad-7d3d-4e1e-b5a0-7abdea642703, localhost:17350): request = { database: "/Root" }
2025-10-27 08:38:35,731 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, c09be8ad-7d3d-4e1e-b5a0-7abdea642703, localhost:17350): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-aathosbtb4.auto.internal" port: 17350 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-10-27 08:38:35,740 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-aathosbtb4.auto.internal:17350, location 1, ssl: False>]>
2025-10-27 08:38:35,740 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:17350
2025-10-27 08:38:36,008 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:38:36,141 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:38:37,421 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:38:37,422 - 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-10-27 08:38:47,425 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:38:47,574 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:38:49,346 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:38:49,346 - 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-10-27 08:38:59,355 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:38:59,491 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:01,003 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:01,004 - 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-10-27 08:39:11,007 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:39:11,160 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:12,679 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:12,680 - 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-10-27 08:39:22,683 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:39:22,849 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:24,372 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:24,372 - 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-10-27 08:39:34,382 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:39:34,535 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:35,573 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:35,574 - 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-10-27 08:39:45,577 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:39:45,692 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:47,397 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:47,398 - 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-10-27 08:39:57,401 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:39:57,524 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:39:58,950 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:39:58,950 - 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-10-27 08:40:08,953 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:40:09,068 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:40:10,584 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:10,585 - 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-10-27 08:40:20,588 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:40:20,710 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:40:21,967 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:21,967 - 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-10-27 08:40:27,093 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:27,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-10-27 08:40:27,097 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-27 08:40:27,097 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 70c44c51-a0d3-4a9b-8972-1ed92dbaf088, localhost:17350): creating call state
2025-10-27 08:40:27,097 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 70c44c51-a0d3-4a9b-8972-1ed92dbaf088, localhost:17350): request = { database: "/Root" }
2025-10-27 08:40:27,100 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 70c44c51-a0d3-4a9b-8972-1ed92dbaf088, localhost:17350): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-aathosbtb4.auto.internal" port: 17350 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-10-27 08:40:27,100 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-aathosbtb4.auto.internal:17350, location 1, ssl: False>]>
2025-10-27 08:40:27,100 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:17350
2025-10-27 08:40:31,970 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:40:32,085 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:40:33,443 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:33,444 - 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-10-27 08:40:43,446 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:40:43,567 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:40:44,906 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:44,907 - 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-10-27 08:40:54,910 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:40:55,028 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:40:56,601 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:40:56,602 - 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-10-27 08:41:06,605 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:41:06,733 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:41:07,960 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:07,961 - 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-10-27 08:41:17,964 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:41:18,087 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:41:19,093 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:19,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-10-27 08:41:29,096 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:41:29,216 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:41:30,899 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:30,900 - 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-10-27 08:41:33,459 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:33,459 - 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-10-27 08:41:33,464 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-27 08:41:33,465 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 03aadc6c-26fa-4ae9-97bd-95f77dec7a0f, localhost:17350): creating call state
2025-10-27 08:41:33,465 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 03aadc6c-26fa-4ae9-97bd-95f77dec7a0f, localhost:17350): request = { database: "/Root" }
2025-10-27 08:41:33,468 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 03aadc6c-26fa-4ae9-97bd-95f77dec7a0f, localhost:17350): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-aathosbtb4.auto.internal" port: 17350 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-10-27 08:41:33,472 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-aathosbtb4.auto.internal:17350, location 1, ssl: False>]>
2025-10-27 08:41:33,472 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:17350
2025-10-27 08:41:40,903 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:41:41,034 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:41:42,472 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:42,473 - 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-10-27 08:41:52,476 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:41:52,607 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:41:54,365 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:41:54,366 - 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-10-27 08:42:04,369 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:42:04,505 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:42:06,117 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:42:06,118 - 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-10-27 08:42:16,121 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:42:16,243 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:42:17,009 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) rc: 0
2025-10-27 08:42:17,009 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) elapsed time (sec): 293.83061814308167
2025-10-27 08:42:17,009 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) idrss: 0
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) inblock: 15512
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) isrss: 0
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) ixrss: 0
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) majflt: 22
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) maxrss: 1740888
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) minflt: 991739
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) msgrcv: 0
2025-10-27 08:42:17,010 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) msgsnd: 0
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) nivcsw: 8033
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) nsignals: 0
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) nswap: 0
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) nvcsw: 3579334
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) oublock: 765936
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) stime: 22.709393
2025-10-27 08:42:17,011 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) utime: 81.250159
2025-10-27 08:42:17,012 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) wtime: 293.849
2025-10-27 08:42:17,012 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) output:
Remove path log/log_column...
Remove path log/log_column...Ok
Init tables ...
Init tables ...Ok
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
Fill table log/log_column...
1	      0	0	0	0	0	0	0	0
2	     10	10	0	2	1095	1183	1183	1183
3	     11	11	0	1	1239	1607	1655	1655
4	      8	8	0	1	1023	1247	1247	1247
5	      9	9	0	2	1167	1511	1511	1511
6	      3	3	0	0	1319	1807	1807	1807
7	      6	6	0	0	1551	2015	2015	2015
8	      9	9	0	1	1447	2463	2463	2463
9	      9	9	0	1	883	2511	2511	2511
10	     11	11	0	3	947	1199	1399	1399
11	     10	10	0	0	975	1167	1167	1167
12	      7	7	0	1	1183	1295	1295	1295
13	      6	6	0	0	1207	1655	1655	1655
14	      7	7	0	2	1519	1751	1751	1751
15	      4	4	0	1	1487	2047	2047	2047
16	      6	6	0	1	1967	2127	2127	2127
17	      8	8	0	0	1335	2863	2863	2863
18	      2	2	0	1	1519	1831	1831	1831
19	      3	3	0	0	1775	1943	1943	1943
20	      6	6	0	1	2303	2911	2911	2911
21	      4	4	0	0	1599	2639	2639	2639
22	      1	1	0	1	1927	1927	1927	1927
23	      3	3	0	0	3711	4415	4415	4415
24	      5	5	0	1	3407	3919	3919	3919
25	      0	0	0	0	0	0	0	0
26	      4	4	0	0	2607	2879	2879	2879
27	      4	4	0	0	3087	5599	5599	5599
28	      2	2	0	0	4159	6751	6751	6751
29	      0	0	0	0	0	0	0	0
30	      0	0	0	0	0	0	0	0
31	      1	1	0	0	5439	5439	5439	5439
32	      9	9	0	1	5343	5919	5919	5919
33	     10	10	0	0	1519	1927	1927	1927
34	      1	1	0	0	1079	1079	1079	1079
35	      7	7	0	0	1663	1767	1767	1767
36	      2	2	0	0	2255	2815	2815	2815
37	     10	10	0	0	2207	2703	2703	2703
38	      0	0	0	0	0	0	0	0
39	      3	3	0	1	1695	2303	2303	2303
40	      5	5	0	0	2687	2927	2927	2927
41	      7	7	0	0	1775	3967	3967	3967
42	      2	2	0	0	2143	2815	2815	2815
43	      1	1	0	0	3295	3295	3295	3295
44	      7	7	0	0	2991	3135	3135	3135
45	      3	3	0	0	3135	3759	3759	3759
46	      0	0	0	0	0	0	0	0
47	      7	7	0	2	2591	3279	3279	3279
48	      6	6	0	0	1383	3471	3471	3471
49	      5	5	0	0	2207	3839	3839	3839
50	      8	8	0	0	2079	2559	2559	2559
51	      3	3	0	2	1319	1543	1543	1543
52	      3	3	0	0	1711	2007	2007	2007
53	      4	4	0	1	2319	2559	2559	2559
54	      4	4	0	0	2367	3455	3455	3455
55	      5	5	0	1	1847	4607	4607	4607
56	      4	4	0	1	2239	3103	3103	3103
57	      6	6	0	0	1463	1599	1599	1599
58	      3	3	0	1	3135	5471	5471	5471
59	      7	7	0	0	1743	3551	3551	3551
60	      4	4	0	1	963	1207	1207	1207
61	      5	5	0	1	1607	2111	2111	2111
62	      9	9	0	1	1671	5535	5535	5535
63	      5	5	0	0	899	1135	1135	1135
64	      7	7	0	0	1431	2703	2703	2703
65	     10	10	0	0	1127	1975	1975	1975
66	      8	8	0	0	1087	1727	1727	1727
67	      7	7	0	1	987	1663	1663	1663
68	      7	7	0	3	1319	2639	2639	2639
69	      6	6	0	0	911	2911	2911	2911
70	     10	10	0	1	1511	2271	2271	2271
71	      5	5	0	0	1071	1247	1247	1247
72	      9	9	0	2	1591	2559	2559	2559
73	      5	5	0	1	1191	1535	1535	1535
74	      7	7	0	0	1239	1887	1887	1887
75	     10	10	0	0	1295	2687	2687	2687
76	      2	2	0	1	1895	1927	1927	1927
77	     10	10	0	0	1359	1919	1919	1919
78	      0	0	0	0	0	0	0	0
79	      8	8	0	1	1735	2079	2079	2079
80	      6	6	0	0	1335	1695	1695	1695
81	      4	4	0	0	2079	3743	3743	3743
82	      6	6	0	1	1383	2287	2287	2287
83	      5	5	0	2	2591	4159	4159	4159
84	      4	4	0	0	1503	1943	1943	1943
85	      4	4	0	0	2143	2575	2575	2575
86	      6	6	0	1	2783	4511	4511	4511
87	      2	2	0	1	1231	1511	1511	1511
88	      7	7	0	0	1815	3711	3711	3711
89	      3	3	0	0	775	2007	2007	2007
90	      5	5	0	0	2095	3311	3311	3311
91	      3	3	0	0	2751	2879	2879	2879
92	      2	2	0	0	2959	3551	3551	3551
93	      9	9	0	2	2511	3199	3199	3199
94	      8	8	0	0	1535	1759	1759	1759
95	      4	4	0	0	1391	1879	1879	1879
96	      7	7	0	0	1479	1887	1887	1887
97	     10	10	0	2	1479	2431	2431	2431
98	      3	3	0	0	1231	1271	1271	1271
99	      5	5	0	1	1855	1887	1887	1887
100	      5	5	0	0	1159	2847	2847	2847
101	      8	8	0	0	1279	3775	3775	3775
102	      3	3	0	0	1535	2703	2703	2703
103	      5	5	0	0	1983	2271	2271	2271
104	      3	3	0	1	2591	3407	3407	3407
105	      2	2	0	0	1039	1847	1847	1847
106	      8	8	0	1	2879	3503	3503	3503
107	      4	4	0	0	1503	1847	1847	1847
108	      4	4	0	0	1991	2815	2815	2815
109	      7	7	0	1	1143	3023	3023	3023
110	     10	10	0	0	1383	3231	3231	3231
111	      3	3	0	0	1071	3343	3343	3343
112	      6	6	0	1	1271	1687	1687	1687
113	      7	7	0	1	1631	2799	2799	2799
114	      1	1	0	1	1303	1303	1303	1303
115	      7	7	0	0	2255	3087	3087	3087
116	      4	4	0	0	2207	4319	4319	4319
117	      2	2	0	0	1663	2287	2287	2287
118	      4	4	0	0	2095	2367	2367	2367
119	      4	4	0	0	1143	2927	2927	2927
120	     19	19	0	3	1011	4927	5439	5439

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
120	    644	5.36667	0	62	1559	3743	5471	6751
Fill table log/log_column OK 100000 / 100000 (168.557802s)
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    764	764	0	0	12	15	20	24
2	    836	836	0	0	11	13	22	23
3	    851	851	0	0	11	13	14	15
4	    852	852	0	0	11	13	17	19
5	    874	874	0	0	11	12	14	16
6	    887	887	0	0	10	12	12	13
7	    861	861	0	0	11	13	17	19
8	    862	862	0	0	11	13	17	21
9	    834	834	0	0	11	14	16	17
10	    863	863	0	0	11	13	14	15
11	    847	847	0	0	11	14	16	21
12	    832	832	0	0	11	14	16	21
13	    842	842	0	0	11	13	15	16
14	    827	827	0	0	11	13	18	22
15	    848	848	0	0	11	12	14	14
16	    819	819	0	0	11	13	14	15
17	    818	818	0	0	11	14	19	24
18	    816	816	0	0	11	14	16	21
19	    768	768	0	0	12	14	16	19
20	    756	756	0	0	12	14	18	21
21	    776	776	0	0	12	14	15	17
22	    782	782	0	0	12	14	16	19
23	    762	762	0	0	12	15	24	27
24	    738	738	0	0	13	16	18	22
25	    723	723	0	0	13	16	20	24
26	    751	751	0	0	12	15	17	20
27	    744	744	0	0	13	15	17	19
28	    761	761	0	0	12	14	18	21
29	    694	694	0	0	13	18	21	23
30	    725	725	0	0	12	17	22	23
31	    741	741	0	0	12	15	22	28
32	    726	726	0	0	13	17	23	25
33	    757	757	0	0	12	15	16	20
34	    775	775	0	0	12	14	16	18
35	    757	757	0	0	12	15	17	22
36	    741	741	0	0	12	17	22	26
37	    810	810	0	0	11	14	15	18
38	    785	785	0	0	12	15	16	18
39	    761	761	0	0	12	15	18	21
40	    811	811	0	0	11	16	22	24

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  31777	794.425	0	0	12	15	18	28
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    370	370	0	0	20	46	71	76
2	    487	487	0	0	19	25	29	30
3	    471	471	0	0	19	29	30	32
4	    372	372	0	0	22	45	58	63
5	    394	394	0	0	23	35	43	48
6	    418	418	0	0	20	33	46	47
7	    440	440	0	0	20	29	31	39
8	    454	454	0	0	19	31	41	57
9	    495	495	0	0	19	21	29	30
10	    459	459	0	0	19	30	35	39
11	    478	478	0	0	19	28	30	36
12	    455	455	0	0	19	42	48	56
13	    355	355	0	0	26	42	47	51
14	    480	480	0	0	19	29	30	31
15	    483	483	0	0	19	27	30	35
16	    479	479	0	0	19	28	29	31
17	    486	486	0	0	19	28	32	34
18	    452	452	0	0	19	35	46	52
19	    473	473	0	0	19	29	30	31
20	    467	467	0	0	19	29	31	35
21	    457	457	0	0	19	30	34	38
22	    446	446	0	0	20	30	33	35
23	    430	430	0	0	20	37	45	48
24	    468	468	0	0	19	29	31	34
25	    473	473	0	0	19	29	30	34
26	    472	472	0	0	19	28	29	31
27	    488	488	0	0	19	26	29	31
28	    441	441	0	0	20	30	47	53
29	    452	452	0	0	20	31	51	54
30	    386	386	0	0	20	42	44	49
31	    443	443	0	0	20	35	40	48
32	    443	443	0	0	20	30	31	35
33	    433	433	0	0	20	30	38	46
34	    402	402	0	0	21	34	50	54
35	    421	421	0	0	20	31	42	46
36	    413	413	0	0	20	31	50	51
37	    390	390	0	0	25	34	40	44
38	    365	365	0	0	28	38	41	42
39	    365	365	0	0	27	38	46	53
40	    354	354	0	0	29	45	52	54

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  17510	437.75	0	0	20	33	43	76
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    286	286	0	0	30	60	84	88
2	    348	348	0	0	29	39	47	52
3	    372	372	0	0	28	38	43	53
4	    391	391	0	0	26	31	33	39
5	    381	381	0	0	28	34	40	58
6	    380	380	0	0	28	32	39	40
7	    364	364	0	0	28	40	53	60
8	    311	311	0	0	29	47	50	55
9	    348	348	0	0	29	43	50	58
10	    362	362	0	0	28	38	40	43
11	    383	383	0	0	27	34	46	52
12	    341	341	0	0	28	39	49	50
13	    342	342	0	0	26	39	209	212
14	    370	370	0	0	28	37	51	52
15	    364	364	0	0	28	37	39	44
16	    359	359	0	0	28	38	46	50
17	    368	368	0	0	28	33	39	45
18	    361	361	0	0	28	41	51	55
19	    384	384	0	0	26	34	40	42
20	    392	392	0	0	25	32	39	43
21	    370	370	0	0	28	34	43	44
22	    352	352	0	0	28	37	54	58
23	    362	362	0	0	28	40	47	51
24	    364	364	0	0	28	35	40	43
25	    368	368	0	0	28	38	40	42
26	    371	371	0	0	28	36	40	42
27	    380	380	0	0	27	32	38	39
28	    373	373	0	0	28	36	40	51
29	    415	415	0	0	20	30	44	47
30	    388	388	0	0	25	34	51	55
31	    292	292	0	0	31	51	57	59
32	    390	390	0	0	26	32	39	42
33	    394	394	0	0	27	31	39	41
34	    352	352	0	0	29	38	48	51
35	    345	345	0	0	29	42	49	52
36	    347	347	0	0	28	49	56	68
37	    336	336	0	0	29	40	53	54
38	    366	366	0	0	28	34	40	43
39	    392	392	0	0	27	30	37	40
40	    410	410	0	0	23	30	32	39

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  14574	364.35	0	0	28	39	50	212

2025-10-27 08:42:17,013 - DEBUG - ya.test - _save_outputs: Command (pid 3608440) errors:
...le
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 3 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 6 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 7 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 1 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 3 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 4 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 8 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 4 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 1 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 9 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 0 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 9 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 6 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 7 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 9 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 2 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 7 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 0 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 3 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 0 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 1 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 8 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 2 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 4 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 1 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 0 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 9 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 1 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 8 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 7 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q30: Группировка по нескольким полям
SELECT
    level,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY level, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 6 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 3 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:13:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q31: Аналогичная группировка с другими полями
SELECT
    request_id,
    client_ip,
COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
WHERE message <> ''
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 7 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 5 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:12:1: Error: At function: OrderedFlatMap, At function: TopSort
            <main>:9:6: Error: At function: AggregateMergeFinalize
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:9:6: Error: At function: CombineByKey, At lambda, At function: AsStruct, At tuple
                        [/lib/yql/aggregate.yqls:443:22-<main>:443:22]: Error: At function: FlatMap
                            <main>:8:9: Error: At function: SafeCast
                                <main>:8:13: Error: At function: JsonValue
                                    <main>:8:25: Error: At function: Member
                                        <main>:9:6: Error: At function: CastStruct, At function: CastStruct, At function: CastStruct
                                            <main>:9:6: Error: Failed to convert member with name: metadata from type Optional<Utf8> to type Optional<JsonDocument>

 Query text: 
-- Q32: Похожая группировка без фильтра
SELECT
    request_id,
    client_ip,
    COUNT(*) AS c,
    SUM(CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32)),
    AVG(CAST(JSON_VALUE(metadata, "$.response_time") AS DOUBLE))
FROM `log/log_column`
GROUP BY request_id, JSON_VALUE(metadata, "$.client_ip") AS client_ip
ORDER BY c DESC
LIMIT 10
Task ID: 9 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000
Task ID: 0 Status: GENERIC_ERROR <main>: Error: Execution, code: 1060
    <main>:3:1: Error: At tuple, At tuple, At tuple
        <main>:26:1: Error: At function: OrderedFlatMap, At function: Take, At function: Skip, At function: TopSort
            <main>:10:6: Error: At function: AggregateMergeFinalize, At function: AggregateCombine
                <main>:3:1: Error: At function: DqCnUnionAll, At function: TDqOutput, At function: DqStage, At lambda
                    <main>:10:6: Error: At function: FlatMap, At lambda, At function: Just, At function: AsStruct, At tuple
                        <main>:21:35: Error: At function: If
                            <main>:21:13: Error: At function: FlatMap, At function: JsonValue, At function: JsonValue, At function: JsonValue
                                <main>:17:16: Error: Expected Json, Json?, JsonDocument or JsonDocument?, but got: Optional<Utf8>

 Query text: 
-- Q39: Сложная группировка с множеством условий
SELECT
    traffic_source_id,
    search_engine_id,
    adv_engine_id,
    src,
    dst,
    COUNT(*) AS views
FROM `log/log_column`
WHERE service_name = 'service1'
    AND timestamp BETWEEN (CurrentUtcTimestamp() - Interval("P7D")) AND CurrentUtcTimestamp()
    AND CAST(JSON_VALUE(metadata, "$.is_refresh") AS Int32) = 0
GROUP BY
    JSON_VALUE(metadata, "$.traffic_source_id") AS traffic_source_id,
    JSON_VALUE(metadata, "$.search_engine_id") AS search_engine_id,
    JSON_VALUE(metadata, "$.adv_engine_id") AS adv_engine_id,
    CASE
        WHEN JSON_VALUE(metadata, "$.search_engine_id") = '0'
        AND JSON_VALUE(metadata, "$.adv_engine_id") = '0'
        THEN JSON_VALUE(metadata, "$.referer")
        ELSE ''
    END AS src,
    JSON_VALUE(metadata, "$.url") AS dst
ORDER BY views DESC
LIMIT 10
OFFSET 1000

No authentication methods were found. Going without authentication
No authentication methods were found. Going without authentication
No authentication methods were found. Going without authentication
contrib/tools/python3/Lib/tempfile.py:940: ResourceWarning: Implicitly cleaning up <TemporaryDirectory '/home/runner/.ya/build/build_root/dyq9/002e17/ydb/tests/stress/log/tests/test-results/py3test/tmp5atrz9m6'>

2025-10-27 08:42:17,018 - INFO - ya.test - pytest_runtest_teardown: Test teardown
2025-10-27 08:42:18,072 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-27 08:42:18,073 - 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-10-27 08:42:28,076 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:15331
2025-10-27 08:42:28,212 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:15331". Check endpoint correctness.
2025-10-27 08:42:29,020 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:17350/1
2025-10-27 08:42:29,021 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/5728
2025-10-27 08:42:29,021 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/61185
2025-10-27 08:42:29,021 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/5082
2025-10-27 08:42:29,022 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/17350
2025-10-27 08:42:29,022 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/7928
