2025-10-16 17:28:53,870 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-10-16 17:28:53,871 - INFO - ya.test - pytest_runtest_setup: test[column]
2025-10-16 17:28:53,871 - INFO - ya.test - pytest_runtest_setup: ####################################################################################################
2025-10-16 17:28:53,872 - INFO - ya.test - pytest_runtest_setup: Test setup
2025-10-16 17:28:53,875 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd
2025-10-16 17:28:53,942 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/9489
2025-10-16 17:28:53,961 - DEBUG - ydb.tests.library.harness.kikimr_runner - start: Working directory: /home/runner/.ya/build/build_root/7v33/0009a6/r3tmp/kikimr_cluster_sggxj1x1
2025-10-16 17:28:54,001 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/2305
2025-10-16 17:28:54,002 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/22729
2025-10-16 17:28:54,003 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/31967
2025-10-16 17:28:54,004 - DEBUG - library.python.filelock - acquire: Acquiring FileLock (blocking=False): /home/runner/.ya/build/port_sync_dir/2022
2025-10-16 17:28:54,005 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/kikimr_configs"
2025-10-16 17:28:54,008 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/7v33/0009a6/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/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_sdvobw99.log --grpc-port=2305 --mon-port=22729 --ic-port=9489
2025-10-16 17:28:54,009 - DEBUG - ydb.tests.library.harness.kikimr_runner - format_pdisk: Formatting pdisk SectorMap:1:64 on node localhost:2305/1, disk_size 68719476736
2025-10-16 17:28:54,009 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: CFG_DIR_PATH="/home/runner/.ya/build/build_root/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/kikimr_configs"
2025-10-16 17:28:54,011 - INFO - ydb.tests.library.harness.kikimr_runner - __make_run_command: Final command: /home/runner/.ya/build/build_root/7v33/0009a6/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/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_sdvobw99.log --grpc-port=2305 --mon-port=22729 --ic-port=9489
2025-10-16 17:28:54,013 - DEBUG - ya.test - execute: Executing '('/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', 'server', '--suppress-version-check', '--yaml-config=/home/runner/.ya/build/build_root/7v33/0009a6/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/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1/logfile_sdvobw99.log', '--grpc-port=2305', '--mon-port=22729', '--ic-port=9489')' in '/home/runner/.ya/build/build_root/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/testing_out_stuff/test_workload.py.TestYdbLogWorkload.test.column/cluster/node_1' (no wait)
2025-10-16 17:28:54,019 - DEBUG - ya.test - execute: Command pid: 3719073
2025-10-16 17:28:54,020 - INFO - ydb.tests.library.harness.kikimr_runner - start: Started node localhost:2305/1
2025-10-16 17:28:54,021 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.2
2025-10-16 17:28:54,022 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.2
2025-10-16 17:28:54,022 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', '-V']' in 'None' (waiting)
2025-10-16 17:28:54,023 - DEBUG - ya.test - execute: Command pid: 3719074
2025-10-16 17:28:54,537 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) rc: 0
2025-10-16 17:28:54,538 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) elapsed time (sec): 0.5139343738555908
2025-10-16 17:28:54,538 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) idrss: 0
2025-10-16 17:28:54,539 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) inblock: 0
2025-10-16 17:28:54,540 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) isrss: 0
2025-10-16 17:28:54,540 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) ixrss: 0
2025-10-16 17:28:54,541 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) majflt: 0
2025-10-16 17:28:54,541 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) maxrss: 776884
2025-10-16 17:28:54,543 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) minflt: 16089
2025-10-16 17:28:54,543 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) msgrcv: 0
2025-10-16 17:28:54,546 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) msgsnd: 0
2025-10-16 17:28:54,546 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) nivcsw: 264
2025-10-16 17:28:54,547 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) nsignals: 0
2025-10-16 17:28:54,547 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) nswap: 0
2025-10-16 17:28:54,547 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) nvcsw: 15
2025-10-16 17:28:54,548 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) oublock: 8
2025-10-16 17:28:54,549 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) stime: 0.282078
2025-10-16 17:28:54,550 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) utime: 0.099492
2025-10-16 17:28:54,551 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) wtime: 0.515
2025-10-16 17:28:54,551 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) output:
Git info:
    Commit: d615d0ffd6e2f23c896ca96121aca842413fb672
    Branch: 
    Author: Andrey Zaspa <zacpa@ya.ru>
    Summary: Merge 2f4fc663ace566d7ea72dd9c85ebd0092851e7e4 into 6819ac59eb1f43dd80b94010061f13b3ff17d91a

Other info:
    Build by: runner
    Top src dir: /home/runner/actions_runner/_work/ydb/ydb
    Top build dir: /home/runner/.ya/build
    Hostname: ghrun-rhpjeeeody
    Host information: 
        Linux ghrun-rhpjeeeody 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-16 17:28:54,552 - DEBUG - ya.test - _save_outputs: Command (pid 3719074) errors:

2025-10-16 17:28:54,552 - INFO - ydb.tests.library.harness.kikimr_runner - start: Node 1 version:
Git info:
    Commit: d615d0ffd6e2f23c896ca96121aca842413fb672
    Branch: 
    Author: Andrey Zaspa <zacpa@ya.ru>
    Summary: Merge 2f4fc663ace566d7ea72dd9c85ebd0092851e7e4 into 6819ac59eb1f43dd80b94010061f13b3ff17d91a
2025-10-16 17:28:56,736 - DEBUG - ydb.tests.library.harness.kikimr_runner - __call_kikimr_new_cli: Executing command = ['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:2305', '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: 9489\n      }\n      HostConfigId: 1\n    }\n  }\n}\n']
2025-10-16 17:28:56,737 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.3
2025-10-16 17:28:56,738 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.3
2025-10-16 17:28:56,741 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:2305', '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: 9489\n      }\n      HostConfigId: 1\n    }\n  }\n}\n']' in 'None' (waiting)
2025-10-16 17:28:56,746 - DEBUG - ya.test - execute: Command pid: 3719519
2025-10-16 17:28:57,199 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) rc: 0
2025-10-16 17:28:57,207 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) elapsed time (sec): 0.4492478370666504
2025-10-16 17:28:57,208 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) idrss: 0
2025-10-16 17:28:57,208 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) inblock: 0
2025-10-16 17:28:57,213 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) isrss: 0
2025-10-16 17:28:57,213 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) ixrss: 0
2025-10-16 17:28:57,216 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) majflt: 0
2025-10-16 17:28:57,216 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) maxrss: 776884
2025-10-16 17:28:57,220 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) minflt: 18230
2025-10-16 17:28:57,222 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) msgrcv: 0
2025-10-16 17:28:57,222 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) msgsnd: 0
2025-10-16 17:28:57,222 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) nivcsw: 76
2025-10-16 17:28:57,224 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) nsignals: 0
2025-10-16 17:28:57,224 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) nswap: 0
2025-10-16 17:28:57,224 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) nvcsw: 130
2025-10-16 17:28:57,225 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) oublock: 8
2025-10-16 17:28:57,225 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) stime: 0.26194999999999996
2025-10-16 17:28:57,225 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) utime: 0.123037
2025-10-16 17:28:57,226 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) wtime: 0.452
2025-10-16 17:28:57,226 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) output:
Status {
  Success: true
}
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 4

2025-10-16 17:28:57,229 - DEBUG - ya.test - _save_outputs: Command (pid 3719519) errors:

2025-10-16 17:28:57,230 - DEBUG - ydb.tests.library.harness.kikimr_runner - __call_kikimr_new_cli: Executing command = ['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:2305', '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-16 17:28:57,231 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to ydbd.out.4
2025-10-16 17:28:57,233 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to ydbd.err.4
2025-10-16 17:28:57,233 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/apps/ydbd/ydbd', '--server=grpc://localhost:2305', '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-16 17:28:57,237 - DEBUG - ya.test - execute: Command pid: 3719798
2025-10-16 17:28:57,676 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) rc: 0
2025-10-16 17:28:57,677 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) elapsed time (sec): 0.43790507316589355
2025-10-16 17:28:57,677 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) idrss: 0
2025-10-16 17:28:57,677 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) inblock: 0
2025-10-16 17:28:57,677 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) isrss: 0
2025-10-16 17:28:57,678 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) ixrss: 0
2025-10-16 17:28:57,678 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) majflt: 0
2025-10-16 17:28:57,679 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) maxrss: 776884
2025-10-16 17:28:57,679 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) minflt: 18232
2025-10-16 17:28:57,680 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) msgrcv: 0
2025-10-16 17:28:57,680 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) msgsnd: 0
2025-10-16 17:28:57,680 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) nivcsw: 44
2025-10-16 17:28:57,681 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) nsignals: 0
2025-10-16 17:28:57,681 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) nswap: 0
2025-10-16 17:28:57,681 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) nvcsw: 130
2025-10-16 17:28:57,681 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) oublock: 8
2025-10-16 17:28:57,682 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) stime: 0.234819
2025-10-16 17:28:57,683 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) utime: 0.133064
2025-10-16 17:28:57,684 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) wtime: 0.443
2025-10-16 17:28:57,684 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) output:
Status {
  Success: true
}
Success: true
ConfigTxSeqNo: 5

2025-10-16 17:28:57,685 - DEBUG - ya.test - _save_outputs: Command (pid 3719798) errors:

2025-10-16 17:28:57,685 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Binding storage pools to domain Root: {'dynamic_storage_pool:1': 'hdd'}
2025-10-16 17:28:57,707 - INFO - ydb.tests.library.harness.kikimr_runner - __run: Cluster started and initialized
2025-10-16 17:28:57,719 - 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-16 17:28:57,722 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:28:57,730 - 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-16 17:28:57,739 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-16 17:28:57,741 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 5133455f-e725-4462-be79-5d44d1a1e7fb, localhost:2305): creating call state
2025-10-16 17:28:57,742 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 5133455f-e725-4462-be79-5d44d1a1e7fb, localhost:2305): request = { database: "/Root" }
2025-10-16 17:28:57,746 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 5133455f-e725-4462-be79-5d44d1a1e7fb, localhost:2305): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-rhpjeeeody.auto.internal" port: 2305 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-16 17:28:57,753 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-rhpjeeeody.auto.internal:2305, location 1, ssl: False>]>
2025-10-16 17:28:57,754 - 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-16 17:28:57,770 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:28:57,772 - INFO - ya.test - pytest_runtest_call: Test call (class_name: test_workload.py::TestYdbLogWorkload, test_name: test[column])
2025-10-16 17:28:57,773 - DEBUG - ya.test - get_binary: Binary was found by /home/runner/.ya/build/build_root/7v33/0009a6/ydb/tests/stress/log/workload_log
2025-10-16 17:28:57,800 - DEBUG - ya.test - _get_command_output_file: Command out will be placed to workload_log.out.0
2025-10-16 17:28:57,812 - DEBUG - ya.test - _get_command_output_file: Command err will be placed to workload_log.err.0
2025-10-16 17:28:57,817 - DEBUG - ya.test - execute: Executing '['/home/runner/.ya/build/build_root/7v33/0009a6/ydb/tests/stress/log/workload_log', '--endpoint', 'grpc://localhost:2305', '--database', '/Root', '--store_type', 'column', '--duration', '120']' in 'None' (waiting)
2025-10-16 17:28:57,823 - DEBUG - ya.test - execute: Command pid: 3719973
2025-10-16 17:29:36,904 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:29:36,904 - 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-16 17:29:46,908 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:29:47,081 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:29:48,363 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:29:48,364 - 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-16 17:29:58,382 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:29:58,391 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:29:59,462 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:29:59,463 - 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-16 17:30:09,470 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:30:09,652 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:30:10,916 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:10,917 - 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-16 17:30:20,922 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:30:21,108 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:30:22,470 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:22,471 - 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-16 17:30:32,474 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:30:32,635 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:30:34,337 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:34,338 - 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-16 17:30:41,315 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:41,316 - 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-16 17:30:41,336 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-16 17:30:41,337 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 751d26cf-1610-4903-9cc3-f1db27e9ce0e, localhost:2305): creating call state
2025-10-16 17:30:41,338 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 751d26cf-1610-4903-9cc3-f1db27e9ce0e, localhost:2305): request = { database: "/Root" }
2025-10-16 17:30:41,345 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 751d26cf-1610-4903-9cc3-f1db27e9ce0e, localhost:2305): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-rhpjeeeody.auto.internal" port: 2305 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-16 17:30:41,346 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-rhpjeeeody.auto.internal:2305, location 1, ssl: False>]>
2025-10-16 17:30:41,346 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:30:44,341 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:30:44,491 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:30:45,616 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:45,616 - 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-16 17:30:55,630 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:30:55,765 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:30:57,452 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:30:57,455 - 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-16 17:31:07,458 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:31:07,589 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:31:09,089 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:31:09,089 - 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-16 17:31:19,093 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:31:19,216 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:31:20,232 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:31:20,233 - 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-16 17:31:30,236 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:31:30,352 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:31:32,080 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:31:32,081 - 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-16 17:31:42,084 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:31:42,214 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:31:44,134 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:31:44,134 - 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-16 17:31:54,138 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:31:54,264 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:31:55,626 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:31:55,629 - 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-16 17:32:03,432 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:03,433 - 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-16 17:32:03,438 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-16 17:32:03,438 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 7b69611e-23a4-4c90-90c3-f1839b82a0e5, localhost:2305): creating call state
2025-10-16 17:32:03,439 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 7b69611e-23a4-4c90-90c3-f1839b82a0e5, localhost:2305): request = { database: "/Root" }
2025-10-16 17:32:03,442 - DEBUG - ydb.connection - _log_response: RpcState(ListEndpoints, 7b69611e-23a4-4c90-90c3-f1839b82a0e5, localhost:2305): response = { operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "ghrun-rhpjeeeody.auto.internal" port: 2305 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-16 17:32:03,442 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Resolved endpoints for database /Root: DiscoveryResult <self_location: 1, endpoints [<Endpoint ghrun-rhpjeeeody.auto.internal:2305, location 1, ssl: False>]>
2025-10-16 17:32:03,443 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:32:05,633 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:32:05,753 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:32:06,885 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:06,886 - 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-16 17:32:16,890 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:32:16,959 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:32:18,302 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:18,303 - 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-16 17:32:28,306 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:32:28,429 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:32:30,311 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:30,311 - 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-16 17:32:40,314 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:32:40,446 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:32:41,650 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:41,651 - 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-16 17:32:51,653 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:32:51,782 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:32:53,723 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:32:53,724 - 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-16 17:33:03,727 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:33:03,848 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:33:05,735 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:05,736 - 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-16 17:33:15,738 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:33:15,864 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:33:17,473 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:17,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-16 17:33:27,476 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:33:27,608 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:33:29,529 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:29,530 - 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-16 17:33:39,532 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:33:39,646 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:33:40,693 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:40,709 - 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-16 17:33:50,712 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:33:50,827 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:33:52,615 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:52,615 - 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-16 17:33:55,740 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) rc: 0
2025-10-16 17:33:55,740 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) elapsed time (sec): 297.9029700756073
2025-10-16 17:33:55,740 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) idrss: 0
2025-10-16 17:33:55,741 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) inblock: 82184
2025-10-16 17:33:55,741 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) isrss: 0
2025-10-16 17:33:55,741 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) ixrss: 0
2025-10-16 17:33:55,741 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) majflt: 50
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) maxrss: 1645084
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) minflt: 875876
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) msgrcv: 0
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) msgsnd: 0
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) nivcsw: 9331
2025-10-16 17:33:55,742 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) nsignals: 0
2025-10-16 17:33:55,743 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) nswap: 0
2025-10-16 17:33:55,743 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) nvcsw: 3396611
2025-10-16 17:33:55,743 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) oublock: 763368
2025-10-16 17:33:55,743 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) stime: 21.144305
2025-10-16 17:33:55,743 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) utime: 79.913478
2025-10-16 17:33:55,744 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) wtime: 297.917
2025-10-16 17:33:55,744 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) output:
Remove path log/log_column...
Remove path log/log_column...Ok
Init tables ...
Init tables ...Ok
Fill table log/log_column...
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	     10	10	0	1	783	791	791	791
2	      3	3	0	1	955	963	963	963
3	      9	9	0	1	1279	1503	1503	1503
4	      9	9	0	2	1215	1415	1415	1415
5	     11	11	0	1	911	1247	1247	1247
6	      8	8	0	0	1327	1471	1471	1471
7	      9	9	0	1	1087	1511	1511	1511
8	      9	9	0	1	983	2735	2735	2735
9	      9	9	0	3	999	1327	1327	1327
10	      7	7	0	0	1215	1559	1559	1559
11	      5	5	0	0	1671	1815	1815	1815
12	      6	6	0	1	1471	2207	2207	2207
13	      5	5	0	0	1399	2559	2559	2559
14	     10	10	0	3	1375	2703	2703	2703
15	      3	3	0	1	1543	1607	1607	1607
16	      8	8	0	1	1791	2047	2047	2047
17	      1	1	0	0	1719	1719	1719	1719
18	      9	9	0	0	2015	2607	2607	2607
19	      1	1	0	1	2815	2815	2815	2815
20	      1	1	0	0	1975	1975	1975	1975
21	      4	4	0	0	3199	3615	3615	3615
22	      5	5	0	2	3503	3615	3615	3615
23	      1	1	0	0	2415	2415	2415	2415
24	      0	0	0	0	0	0	0	0
25	      0	0	0	0	0	0	0	0
26	     10	10	0	1	4095	4479	4479	4479
27	      0	0	0	0	0	0	0	0
28	      0	0	0	0	0	0	0	0
29	      0	0	0	0	0	0	0	0
30	      0	0	0	0	0	0	0	0
31	      4	4	0	0	5311	5887	5887	5887
32	      6	6	0	0	5919	6111	6111	6111
33	      0	0	0	0	0	0	0	0
34	      0	0	0	0	0	0	0	0
35	      0	0	0	0	0	0	0	0
36	      0	0	0	0	0	0	0	0
37	      0	0	0	0	0	0	0	0
38	      0	0	0	0	0	0	0	0
39	      6	6	0	0	7679	8319	8319	8319
40	      4	4	0	0	8191	8959	8959	8959
41	      0	0	0	0	0	0	0	0
42	      0	0	0	0	0	0	0	0
43	      0	0	0	0	0	0	0	0
44	     10	10	0	0	4287	4543	4543	4543
45	      0	0	0	0	0	0	0	0
46	      0	0	0	0	0	0	0	0
47	      0	0	0	0	0	0	0	0
48	      0	0	0	0	0	0	0	0
49	     10	10	0	0	4927	5215	5215	5215
50	      0	0	0	0	0	0	0	0
51	      0	0	0	0	0	0	0	0
52	      0	0	0	0	0	0	0	0
53	      0	0	0	0	0	0	0	0
54	     10	10	0	1	5439	5823	5823	5823
55	      0	0	0	0	0	0	0	0
56	      0	0	0	0	0	0	0	0
57	      0	0	0	0	0	0	0	0
58	      0	0	0	0	0	0	0	0
59	      0	0	0	0	0	0	0	0
60	      0	0	0	0	0	0	0	0
61	     10	10	0	0	6783	6975	6975	6975
62	      0	0	0	0	0	0	0	0
63	      0	0	0	0	0	0	0	0
64	      0	0	0	0	0	0	0	0
65	      6	6	0	0	4607	4671	4671	4671
66	      4	4	0	0	4767	4959	4959	4959
67	      4	4	0	0	1583	2039	2039	2039
68	      5	5	0	1	2207	2863	2863	2863
69	      1	1	0	0	2895	2895	2895	2895
70	      0	0	0	0	0	0	0	0
71	      2	2	0	0	4031	4191	4191	4191
72	      8	8	0	2	3855	4415	4415	4415
73	      0	0	0	0	0	0	0	0
74	      2	2	0	0	2399	3199	3199	3199
75	      4	4	0	1	3503	3871	3871	3871
76	      3	3	0	0	4159	4735	4735	4735
77	      1	1	0	0	6207	6207	6207	6207
78	      0	0	0	0	0	0	0	0
79	      0	0	0	0	0	0	0	0
80	      0	0	0	0	0	0	0	0
81	      0	0	0	0	0	0	0	0
82	      8	8	0	1	6559	7775	7775	7775
83	      2	2	0	0	7135	7263	7263	7263
84	      0	0	0	0	0	0	0	0
85	      0	0	0	0	0	0	0	0
86	      0	0	0	0	0	0	0	0
87	      0	0	0	0	0	0	0	0
88	      6	6	0	0	5375	5919	5919	5919
89	      1	1	0	0	7007	7007	7007	7007
90	      0	0	0	0	0	0	0	0
91	      3	3	0	0	3775	8959	8959	8959
92	      4	4	0	2	4831	9855	9855	9855
93	      1	1	0	0	5055	5055	5055	5055
94	     10	10	0	3	1847	4383	4383	4383
95	      2	2	0	0	1407	1799	1799	1799
96	      6	6	0	1	1903	2543	2543	2543
97	      8	8	0	0	1191	3023	3023	3023
98	      5	5	0	1	1519	1607	1607	1607
99	      3	3	0	0	2383	3487	3487	3487
100	      7	7	0	0	2063	3199	3199	3199
101	      0	0	0	0	0	0	0	0
102	      7	7	0	0	2271	3519	3519	3519
103	      3	3	0	0	3183	3743	3743	3743
104	      0	0	0	0	0	0	0	0
105	      3	3	0	1	2687	3135	3135	3135
106	      6	6	0	0	3487	3823	3823	3823
107	      1	1	0	0	3839	3839	3839	3839
108	      0	0	0	0	0	0	0	0
109	      0	0	0	0	0	0	0	0
110	      0	0	0	0	0	0	0	0
111	      5	5	0	0	5823	6463	6463	6463
112	      5	5	0	2	5599	6015	6015	6015
113	      1	1	0	0	895	895	895	895
114	      0	0	0	0	0	0	0	0
115	      0	0	0	0	0	0	0	0
116	     10	10	0	0	4479	5055	5055	5055
117	      0	0	0	0	0	0	0	0
118	     10	10	0	2	1759	1959	1959	1959
119	      2	2	0	1	1327	1335	1335	1335
120	     17	17	0	0	2079	3551	3759	3759

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
120	    389	3.24167	0	40	2319	6975	8319	9855
Fill table log/log_column OK 100000 / 100000 (172.427935s)
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    789	789	0	0	11	14	23	26
2	    762	762	0	0	12	16	19	28
3	    743	743	0	0	12	18	21	23
4	    744	744	0	0	12	16	19	23
5	    720	720	0	0	12	18	27	30
6	    754	754	0	0	12	15	17	20
7	    717	717	0	0	12	18	23	27
8	    601	601	0	0	14	29	41	48
9	    713	713	0	0	13	19	23	26
10	    739	739	0	0	12	16	23	28
11	    739	739	0	0	12	17	18	21
12	    741	741	0	0	12	18	20	24
13	    708	708	0	0	13	17	23	31
14	    707	707	0	0	12	20	29	41
15	    675	675	0	0	13	20	28	31
16	    742	742	0	0	12	16	20	22
17	    713	713	0	0	13	18	22	25
18	    728	728	0	0	12	17	27	33
19	    713	713	0	0	13	18	23	26
20	    693	693	0	0	13	19	25	27
21	    726	726	0	0	13	18	20	32
22	    733	733	0	0	12	17	23	27
23	    757	757	0	0	12	17	23	30
24	    795	795	0	0	11	15	18	20
25	    749	749	0	0	12	18	20	24
26	    719	719	0	0	13	17	19	22
27	    677	677	0	0	13	18	24	27
28	    658	658	0	0	14	20	25	30
29	    659	659	0	0	14	19	25	33
30	    639	639	0	0	14	22	30	32
31	    617	617	0	0	14	23	26	30
32	    634	634	0	0	14	22	26	32
33	    698	698	0	0	13	19	23	34
34	    761	761	0	0	12	16	19	24
35	    761	761	0	0	12	16	19	29
36	    787	787	0	0	12	14	20	21
37	    747	747	0	0	12	17	24	25
38	    795	795	0	0	12	14	16	21
39	    813	813	0	0	11	13	19	23
40	    779	779	0	0	12	15	17	21

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  28945	723.625	0	0	12	18	24	48
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    465	465	0	0	19	29	45	56
2	    490	490	0	0	19	25	29	31
3	    494	494	0	0	19	20	30	30
4	    490	490	0	0	19	24	29	30
5	    455	455	0	0	19	30	36	39
6	    468	468	0	0	19	30	39	47
7	    487	487	0	0	19	26	29	32
8	    483	483	0	0	19	27	30	32
9	    418	418	0	0	21	31	36	39
10	    364	364	0	0	26	42	50	54
11	    338	338	0	0	28	41	44	48
12	    320	320	0	0	30	46	51	53
13	    396	396	0	0	21	43	47	55
14	    455	455	0	0	20	29	30	40
15	    413	413	0	0	20	34	41	51
16	    381	381	0	0	25	37	40	46
17	    414	414	0	0	21	31	38	47
18	    415	415	0	0	21	30	37	40
19	    383	383	0	0	25	36	53	64
20	    428	428	0	0	20	31	47	53
21	    390	390	0	0	25	32	41	48
22	    450	450	0	0	20	30	40	41
23	    474	474	0	0	19	29	32	43
24	    470	470	0	0	19	29	31	33
25	    467	467	0	0	19	29	31	39
26	    447	447	0	0	19	34	41	49
27	    412	412	0	0	19	44	110	111
28	    426	426	0	0	19	40	50	61
29	    480	480	0	0	19	28	29	30
30	    470	470	0	0	19	29	30	31
31	    445	445	0	0	20	30	34	35
32	    403	403	0	0	19	47	82	83
33	    483	483	0	0	19	27	30	33
34	    448	448	0	0	19	30	57	72
35	    497	497	0	0	19	20	29	30
36	    486	486	0	0	19	25	29	30
37	    466	466	0	0	19	29	32	36
38	    450	450	0	0	20	30	34	39
39	    439	439	0	0	20	30	31	33
40	    485	485	0	0	19	28	42	60

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  17645	441.125	0	0	20	32	43	111
Window	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
1	    318	318	0	0	29	40	63	63
2	    352	352	0	0	29	31	40	40
3	    348	348	0	0	28	40	59	66
4	    338	338	0	0	29	41	51	51
5	    356	356	0	0	28	39	41	48
6	    352	352	0	0	28	36	40	41
7	    339	339	0	0	29	40	43	47
8	    319	319	0	0	29	44	47	49
9	    299	299	0	0	30	48	57	67
10	    338	338	0	0	29	42	50	53
11	    346	346	0	0	29	36	41	45
12	    350	350	0	0	29	36	40	41
13	    352	352	0	0	28	36	41	45
14	    332	332	0	0	29	40	52	56
15	    374	374	0	0	28	34	40	44
16	    353	353	0	0	28	38	45	50
17	    352	352	0	0	28	32	39	42
18	    344	344	0	0	28	37	41	44
19	    347	347	0	0	28	38	42	42
20	    313	313	0	0	30	41	47	48
21	    321	321	0	0	29	48	54	62
22	    320	320	0	0	29	42	51	57
23	    317	317	0	0	29	44	48	52
24	    297	297	0	0	31	44	51	60
25	    282	282	0	0	35	49	56	61
26	    298	298	0	0	30	45	48	51
27	    281	281	0	0	35	49	53	60
28	    295	295	0	0	31	52	60	71
29	    308	308	0	0	30	48	50	53
30	    309	309	0	0	31	45	51	52
31	    308	308	0	0	30	54	69	70
32	    350	350	0	0	29	39	42	48
33	    374	374	0	0	26	39	41	50
34	    386	386	0	0	27	35	41	41
35	    373	373	0	0	27	42	48	53
36	    368	368	0	0	28	38	41	52
37	    389	389	0	0	28	31	39	40
38	    407	407	0	0	21	30	32	39
39	    409	409	0	0	20	30	32	39
40	    413	413	0	0	20	30	53	63

Total	    Txs	Txs/Sec	Retries	Errors	p50(ms)	p95(ms)	p99(ms)	pMax(ms)
40	  13627	340.675	0	0	29	41	50	71

2025-10-16 17:33:55,744 - DEBUG - ya.test - _save_outputs: Command (pid 3719973) errors:
No authentication methods were found. Going without authentication
No authentication methods were found. Going without authentication
No authentication methods were found. Going without authentication
No authentication methods were found. Going without authentication
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: 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: 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
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: 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: 2 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>: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>: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>: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: 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: 
-- 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>: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>: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>: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: 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: 
-- 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>: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: 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: 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: 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: 6 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: 6 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: 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: 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: 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: 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: 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: 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: 8 Status: CLIENT_DEADLINE_EXCEEDED <main>: Error: GRpc error: (4): Deadline Exceeded

 Query text: 
-- Q21: Анализ ошибок с URL
SELECT
    message,
    MIN(JSON_VALUE(metadata, "$.url")),
    COUNT(*) AS c
FROM `log/log_column`
WHERE JSON_VALUE(metadata, "$.url") LIKE '%api%'
    AND message <> ''
GROUP BY message
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: 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: 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: 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: 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: 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: 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: 4 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>: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

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/7v33/0009a6/ydb/tests/stress/log/tests/test-results/py3test/tmpi3r_oelv'>

2025-10-16 17:33:55,748 - INFO - ya.test - pytest_runtest_teardown: Test teardown
2025-10-16 17:33:59,614 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:33:59,614 - 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-16 17:33:59,618 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Resolving endpoints for database /Root
2025-10-16 17:33:59,624 - DEBUG - ydb.connection - _prepare_call: RpcState(ListEndpoints, 35229c86-2097-4e5c-b764-9936c41cbeff, localhost:2305): creating call state
2025-10-16 17:33:59,624 - DEBUG - ydb.connection - _log_request: RpcState(ListEndpoints, 35229c86-2097-4e5c-b764-9936c41cbeff, localhost:2305): request = { database: "/Root" }
2025-10-16 17:34:02,580 - DEBUG - ydb.connection - _rpc_error_handler: RpcState(ListEndpoints, 35229c86-2097-4e5c-b764-9936c41cbeff, localhost:2305): received error, <_InactiveRpcError of RPC that terminated with:
	status = StatusCode.CANCELLED
	details = "Cancelled on the server side"
	debug_error_string = "UNKNOWN:Error received from peer  {grpc_message:"Cancelled on the server side", grpc_status:1, created_time:"2025-10-16T17:34:02.579846294+00:00", file_line:1211, file:"/home/runner/actions_runner/_work/ydb/ydb/contrib/libs/grpc/src/core/lib/surface/call.cc"}"
>
2025-10-16 17:34:02,580 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to resolve endpoints for database /Root. Endpoint: "localhost:2305". Error details:
 Cancelled on the server side
2025-10-16 17:34:02,580 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:34:02,618 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:34:02,732 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:34:03,935 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:03,935 - 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-16 17:34:04,587 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:04,588 - 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-16 17:34:13,937 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:34:14,051 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:2305". Check endpoint correctness.
2025-10-16 17:34:14,591 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:34:14,706 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:34:15,101 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:15,101 - 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-16 17:34:16,706 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:16,706 - 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-16 17:34:25,104 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:34:25,220 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:2305". Check endpoint correctness.
2025-10-16 17:34:26,323 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:26,324 - 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-16 17:34:26,709 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:21953
2025-10-16 17:34:26,823 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:21953". Check endpoint correctness.
2025-10-16 17:34:27,995 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - context_resolve: Preparing initial endpoint to resolve endpoints
2025-10-16 17:34:27,996 - 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-16 17:34:36,326 - DEBUG - ydb.connection - close: Closing channel for endpoint localhost:2305
2025-10-16 17:34:36,442 - DEBUG - ydb.resolver.DiscoveryEndpointsResolver - _add_debug_details: Failed to establish connection to YDB discovery endpoint: "localhost:2305". Check endpoint correctness.
2025-10-16 17:34:37,760 - INFO - ydb.tests.library.harness.kikimr_runner - stop: Stopped node localhost:2305/1
2025-10-16 17:34:37,766 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/2022
2025-10-16 17:34:37,766 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/31967
2025-10-16 17:34:37,766 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/22729
2025-10-16 17:34:37,766 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/2305
2025-10-16 17:34:37,766 - DEBUG - library.python.filelock - release: Ensuring FileLock released: /home/runner/.ya/build/port_sync_dir/9489
