【修复中】使用 arrow flight sql 开启pipline-x 后，查询数据报错 Unknown result sink type

Viewed 84
2.1 query

使用 arrow flight sql 开启pipline-x 后查询数据报错 Unknown result sink type

doris版本2.1.2

case: select * from test.case_test;

BE日志

I20240422 14:52:06.321456 39473 wal_manager.cpp:481] Scheduled(every 10s) WAL info: [/mnt/mydata/sfinx/doris212/be/storage/wal: limit 614965585510 Bytes, used 0 Bytes, estimated wal bytes 0 Bytes, available 614965585510 Bytes.];
I20240422 14:52:07.485213 40154 fragment_mgr.cpp:636] query_id: 478604d9ba4f494c-9c7f8433d01f7f14 coord_addr TNetworkAddress(hostname=192.168.0.230, port=34011) total fragment num on current host: 33 fe process uuid: 1713768603177
I20240422 14:52:07.485258 40154 fragment_mgr.cpp:661] Query/load id: 478604d9ba4f494c-9c7f8433d01f7f14, use workload group: TG[id = 1, name = normal, cpu_share = 1024, memory_limit = 68.00 GB, enable_memory_overcommit = true, version = 0, cpu_hard_limit = -1, scan_thread_num = 128, max_remote_scan_thread_num = 128, min_remote_scan_thread_num = 128, spill_low_watermark=50, spill_high_watermark=80], is pipeline: 1, enable cgroup soft limit: 1
I20240422 14:52:07.485275 40154 fragment_mgr.cpp:674] Register query/load memory tracker, query/load id: 478604d9ba4f494c-9c7f8433d01f7f14 limit: 0
I20240422 14:52:07.485291 40154 pipeline_x_fragment_context.cpp:174] PipelineXFragmentContext::prepare|query_id=478604d9ba4f494c-9c7f8433d01f7f14|fragment_id=1|pthread_id=140141879858944
I20240422 14:52:07.485487 40154 pipeline_x_fragment_context.cpp:174] PipelineXFragmentContext::prepare|query_id=478604d9ba4f494c-9c7f8433d01f7f14|fragment_id=0|pthread_id=140141879858944
W20240422 14:52:07.509462 40713 status.h:380] meet error status: [INTERNAL_ERROR]Unknown result sink type

        0#  doris::pipeline::ResultSinkLocalState::open(doris::RuntimeState*) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:0
        1#  doris::pipeline::PipelineXTask::_open() at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:449
        2#  doris::pipeline::PipelineXTask::execute(bool*) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:449
        3#  doris::pipeline::TaskScheduler::_do_work(unsigned long) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:345
        4#  doris::ThreadPool::dispatch_thread() at /home/zcp/repo_center/doris_release/doris/be/src/util/threadpool.cpp:0
        5#  doris::Thread::supervise_thread(void*) at /var/local/ldb_toolchain/bin/../usr/include/pthread.h:562
        6#  start_thread
        7#  clone
W20240422 14:52:07.509521 40713 task_scheduler.cpp:353] Pipeline task failed. query_id: 0-0|478604d9ba4f494c-9c7f8433d01f7f14 reason: [INTERNAL_ERROR]Unknown result sink type

        0#  doris::pipeline::ResultSinkLocalState::open(doris::RuntimeState*) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:0
        1#  doris::pipeline::PipelineXTask::_open() at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:449
        2#  doris::pipeline::PipelineXTask::execute(bool*) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:449
        3#  doris::pipeline::TaskScheduler::_do_work(unsigned long) at /home/zcp/repo_center/doris_release/doris/be/src/common/status.h:345
        4#  doris::ThreadPool::dispatch_thread() at /home/zcp/repo_center/doris_release/doris/be/src/util/threadpool.cpp:0
        5#  doris::Thread::supervise_thread(void*) at /var/local/ldb_toolchain/bin/../usr/include/pthread.h:562
        6#  start_thread
        7#  clone
I20240422 14:52:07.509552 40713 pipeline_x_fragment_context.cpp:129] PipelineXFragmentContext::cancel|query_id=478604d9ba4f494c-9c7f8433d01f7f14|fragment_id=1|reason=3|error message=Unknown result sink type
I20240422 14:52:07.509562 40713 pipeline_x_fragment_context.cpp:129] PipelineXFragmentContext::cancel|query_id=478604d9ba4f494c-9c7f8433d01f7f14|fragment_id=0|reason=3|error message=Unknown result sink type
alexcheung3
4 Answers

已经记录，内部在排查，会及时同步动态

阿渊@SelectDB3266

请提供下 case_test 的 schema，谢谢

shuke101

这个是表结构

show create table case_test;

CREATE TABLE `case_test` (
                            `uid` VARCHAR(50) NOT NULL,
                            `subject` BIGINT NULL,
                            `date` DATE NOT NULL,
                            `update_time` DATETIME NOT NULL,
                            `value` DOUBLE NULL,
                            `fill_type` TINYINT NULL DEFAULT 0
) ENGINE=OLAP
    UNIQUE KEY(`uid`, `subject`, `date`, `update_time`)
COMMENT 'OLAP'
PARTITION BY RANGE(`date`)
(PARTITION p1900_1970 VALUES [('1900-01-01'), ('1970-01-01')),
PARTITION p1970_2010 VALUES [('1970-01-01'), ('2010-01-01')),
PARTITION p2010_2015 VALUES [('2010-01-01'), ('2015-01-01')),
PARTITION p2015_2020 VALUES [('2015-01-01'), ('2020-01-01')),
PARTITION p202006 VALUES [('2020-01-01'), ('2020-07-01')),
PARTITION p202012 VALUES [('2020-07-01'), ('2021-01-01')),
PARTITION p202106 VALUES [('2021-01-01'), ('2021-07-01')),
PARTITION p202112 VALUES [('2021-07-01'), ('2022-01-01')),
PARTITION p202206 VALUES [('2022-01-01'), ('2022-07-01')),
PARTITION p202212 VALUES [('2022-07-01'), ('2023-01-01')),
PARTITION p202306 VALUES [('2023-01-01'), ('2023-07-01')),
PARTITION p202312 VALUES [('2023-07-01'), ('2024-01-01')),
PARTITION p202406 VALUES [('2024-01-01'), ('2024-07-01')),
PARTITION p202412 VALUES [('2024-07-01'), ('2025-01-01')),
PARTITION p202506 VALUES [('2025-01-01'), ('2025-07-01')),
PARTITION p202512 VALUES [('2025-07-01'), ('2026-01-01')),
PARTITION p202606 VALUES [('2026-01-01'), ('2026-07-01')),
PARTITION p202612 VALUES [('2026-07-01'), ('2027-01-01')),
PARTITION p202706 VALUES [('2027-01-01'), ('2027-07-01')),
PARTITION p202712 VALUES [('2027-07-01'), ('2028-01-01')),
PARTITION p202806 VALUES [('2028-01-01'), ('2028-07-01')),
PARTITION p202812 VALUES [('2028-07-01'), ('2029-01-01')),
PARTITION p202906 VALUES [('2029-01-01'), ('2029-07-01')),
PARTITION p202912 VALUES [('2029-07-01'), ('2030-01-01')),
PARTITION p203006 VALUES [('2030-01-01'), ('2030-07-01')),
PARTITION p203012 VALUES [('2030-07-01'), ('2031-01-01')),
PARTITION p203106 VALUES [('2031-01-01'), ('2031-07-01')),
PARTITION p203112 VALUES [('2031-07-01'), ('2032-01-01')),
PARTITION p203206 VALUES [('2032-01-01'), ('2032-07-01')),
PARTITION p203212 VALUES [('2032-07-01'), ('2033-01-01')),
PARTITION p203306 VALUES [('2033-01-01'), ('2033-07-01')),
PARTITION p203312 VALUES [('2033-07-01'), ('2034-01-01')),
PARTITION p203406 VALUES [('2034-01-01'), ('2034-07-01')),
PARTITION p203412 VALUES [('2034-07-01'), ('2035-01-01')),
PARTITION p203506 VALUES [('2035-01-01'), ('2035-07-01')),
PARTITION p203512 VALUES [('2035-07-01'), ('2036-01-01')),
PARTITION p203606 VALUES [('2036-01-01'), ('2036-07-01')),
PARTITION p203612 VALUES [('2036-07-01'), ('2037-01-01')),
PARTITION p203706 VALUES [('2037-01-01'), ('2037-07-01')),
PARTITION p203712 VALUES [('2037-07-01'), ('2038-01-01')),
PARTITION p203806 VALUES [('2038-01-01'), ('2038-07-01')),
PARTITION p203812 VALUES [('2038-07-01'), ('2039-01-01')),
PARTITION p203906 VALUES [('2039-01-01'), ('2039-07-01')),
PARTITION p203912 VALUES [('2039-07-01'), ('2040-01-01')),
PARTITION p204006 VALUES [('2040-01-01'), ('2040-07-01')),
PARTITION p204012 VALUES [('2040-07-01'), ('2041-01-01')),
PARTITION p204106 VALUES [('2041-01-01'), ('2041-07-01')),
PARTITION p204112 VALUES [('2041-07-01'), ('2042-01-01')),
PARTITION p204206 VALUES [('2042-01-01'), ('2042-07-01')),
PARTITION p204212 VALUES [('2042-07-01'), ('2043-01-01')),
PARTITION p204306 VALUES [('2043-01-01'), ('2043-07-01')),
PARTITION p204312 VALUES [('2043-07-01'), ('2044-01-01')),
PARTITION p204406 VALUES [('2044-01-01'), ('2044-07-01')),
PARTITION p204412 VALUES [('2044-07-01'), ('2045-01-01')),
PARTITION p204506 VALUES [('2045-01-01'), ('2045-07-01')),
PARTITION p204512 VALUES [('2045-07-01'), ('2046-01-01')),
PARTITION p204606 VALUES [('2046-01-01'), ('2046-07-01')),
PARTITION p204612 VALUES [('2046-07-01'), ('2047-01-01')),
PARTITION p204706 VALUES [('2047-01-01'), ('2047-07-01')),
PARTITION p204712 VALUES [('2047-07-01'), ('2048-01-01')),
PARTITION p204806 VALUES [('2048-01-01'), ('2048-07-01')),
PARTITION p204812 VALUES [('2048-07-01'), ('2049-01-01')),
PARTITION p204906 VALUES [('2049-01-01'), ('2049-07-01')),
PARTITION p204912 VALUES [('2049-07-01'), ('2050-01-01')),
PARTITION p205006 VALUES [('2050-01-01'), ('2050-07-01')),
PARTITION p205012 VALUES [('2050-07-01'), ('2051-01-01')))
DISTRIBUTED BY HASH(`uid`) BUCKETS 10
PROPERTIES (
"replication_allocation" = "tag.location.default: 3",
"min_load_replica_num" = "-1",
"is_being_synced" = "false",
"storage_format" = "V2",
"inverted_index_storage_format" = "DEFAULT",
"enable_unique_key_merge_on_write" = "false",
"disable_auto_compaction" = "false",
"enable_single_replica_compaction" = "false",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728"
);

image.png

alexcheung3

2.1.3 已经解决了这个问题，可以重试下，感觉反馈问题 @alexcheung

xinyiZzz262