lide-reed opened a new issue, #9289: URL: https://github.com/apache/incubator-doris/issues/9289
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version Dev 1.0.1 ### What's Wrong? MySQL [test]> SELECT -> * -> FROM -> ( -> SELECT -> table_1.abcd AS exist_key, -> table_1.create_time AS business_time -> FROM -> table_1 -> ) source -> RIGHT JOIN ( -> SELECT -> table_2.abcd AS exist_key, -> table_2.create_time AS business_time -> FROM -> table_2 -> ) target ON source.exist_key = target.exist_key; ERROR 1105 (HY000): RpcException, msg: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason *** Aborted at 1651129043 (unix time) try "date -d @1651129043" if you are using GNU date *** *** SIGSEGV unkown detail explain (@0x0) received by PID 637678 (TID 0x7fb3f5371700) from PID 0; stack trace: *** 0# doris::signal::(anonymous namespace)::FailureSignalHandler(int, siginfo_t*, void*) at /root/dev-1.0.1/be/src/common/signal_handler.h:420 1# 0x00007FB43D922400 in /lib64/libc.so.6 2# doris::vectorized::ColumnNullable::insert_join_null_data() at /root/dev-1.0.1/be/src/vec/columns/column_nullable.cpp:116 3# auto doris::vectorized::HashJoinNode::get_next(doris::RuntimeState*, doris::vectorized::Block*, bool*)::{lambda(auto:1&&, auto:2&&)#3}::operator()<doris::vectorized::SerializedHashTableContext&, std::integral_constant<doris::TJoinOp::type, (doris::TJoinOp::type)3>&>(doris::vectorized::SerializedHashTableContext&, std::integral_constant<doris::TJoinOp::type, (doris::TJoinOp::type)3>&) const [clone .constprop.0] at /root/dev-1.0.1/be/src/vec/exec/join/vhash_join_node.cpp:920 4# doris::vectorized::HashJoinNode::get_next(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /root/dev-1.0.1/be/src/vec/exec/join/vhash_join_node.cpp:928 5# doris::PlanFragmentExecutor::get_vectorized_internal(doris::vectorized::Block**) at /root/dev-1.0.1/be/src/runtime/plan_fragment_executor.cpp:346 6# doris::PlanFragmentExecutor::open_vectorized_internal() at /root/dev-1.0.1/be/src/runtime/plan_fragment_executor.cpp:295 7# doris::PlanFragmentExecutor::open() at /root/dev-1.0.1/be/src/runtime/plan_fragment_executor.cpp:255 8# doris::FragmentExecState::execute() at /root/dev-1.0.1/be/src/runtime/fragment_mgr.cpp:231 9# doris::FragmentMgr::_exec_actual(std::shared_ptr<doris::FragmentExecState>, std::function<void (doris::PlanFragmentExecutor*)>) at /root/dev-1.0.1/be/src/runtime/fragment_mgr.cpp:466 10# std::_Function_handler<void (), std::_Bind_result<void, void (doris::FragmentMgr::*(doris::FragmentMgr*, std::shared_ptr<doris::FragmentExecState>, std::function<void (doris::PlanFragmentExecutor*)>))(std::shared_ptr<doris::FragmentExecState>, std::function<void (doris::PlanFragmentExecutor*)>)> >::_M_invoke(std::_Any_data const&) at /var/local/ldb-toolchain/include/c++/11/bits/std_function.h:291 11# doris::ThreadPool::dispatch_thread() at /root/dev-1.0.1/be/src/util/threadpool.cpp:578 12# doris::Thread::supervise_thread(void*) at /root/dev-1.0.1/be/src/util/thread.cpp:403 13# start_thread in /lib64/libpthread.so.0 14# __clone in /lib64/libc.so.6 ### What You Expected? MySQL [test]> SELECT -> * -> FROM -> ( -> SELECT -> table_1.abcd AS exist_key, -> table_1.create_time AS business_time -> FROM -> table_1 -> ) source -> RIGHT JOIN ( -> SELECT -> table_2.abcd AS exist_key, -> table_2.create_time AS business_time -> FROM -> table_2 -> ) target ON source.exist_key = target.exist_key; +-----------+---------------+------------------------+---------------------+ | exist_key | business_time | exist_key | business_time | +-----------+---------------+------------------------+---------------------+ | NULL | NULL | T220427400136970192083 | 2022-04-27 16:00:51 | | NULL | NULL | T220427400124330112931 | 2022-04-27 16:00:56 | | NULL | NULL | T220427400126530112854 | 2022-04-27 16:00:34 | | NULL | NULL | T220427400128350120717 | 2022-04-27 16:00:56 | | NULL | NULL | T220427400153170104281 | 2022-04-27 16:00:31 | | NULL | NULL | T220427400129940120380 | 2022-04-27 16:00:23 | | NULL | NULL | T220427400109910160949 | 2022-04-27 16:00:54 | | NULL | NULL | T220427601780480120027 | 2022-04-27 16:00:58 | | NULL | NULL | H220427011909770192580 | 2022-04-27 16:00:04 | | NULL | NULL | H220427011909820192943 | 2022-04-27 16:00:23 | | NULL | NULL | T220427400123770120058 | 2022-04-27 16:00:56 | | NULL | NULL | T220427400109930192249 | 2022-04-27 16:00:56 | | NULL | NULL | T220427400146320176530 | 2022-04-27 16:00:34 | | NULL | NULL | H220427011909850160918 | 2022-04-27 16:00:33 | | NULL | NULL | T220427400124430144718 | 2022-04-27 16:00:07 | | NULL | NULL | T220427400127900184511 | 2022-04-27 16:00:34 | | NULL | NULL | T220427400129680120838 | 2022-04-27 16:00:39 | | NULL | NULL | T220427400127160144672 | 2022-04-27 16:00:10 | | NULL | NULL | T220427400137600160704 | 2022-04-27 16:00:35 | | NULL | NULL | T220427400144590176969 | 2022-04-27 16:00:49 | | NULL | NULL | H220427011909800104411 | 2022-04-27 16:00:14 | | NULL | NULL | T220427400109110184990 | 2022-04-27 16:00:29 | | NULL | NULL | T220427400130570160488 | 2022-04-27 16:00:34 | | NULL | NULL | T220427400123050168464 | 2022-04-27 16:00:37 | | NULL | NULL | T220427400140260152375 | 2022-04-27 16:00:02 | | NULL | NULL | T220427400115770144416 | 2022-04-27 16:00:12 | | NULL | NULL | T220427400126390112736 | 2022-04-27 16:00:19 | | NULL | NULL | T220427400139720192986 | 2022-04-27 16:00:34 | | NULL | NULL | T220427400130610112671 | 2022-04-27 16:00:30 | | NULL | NULL | H220427011909870184823 | 2022-04-27 16:00:36 | +-----------+---------------+------------------------+---------------------+ 30 rows in set (0.25 sec) ### How to Reproduce? CREATE TABLE `table_1` ( `abcd` varchar(150) NULL COMMENT "", `create_time` datetime NULL COMMENT "" ) ENGINE=OLAP UNIQUE KEY(`abcd`) COMMENT "OLAP" DISTRIBUTED BY HASH(`abcd`) BUCKETS 3; CREATE TABLE `table_2` ( `abcd` varchar(150) NULL COMMENT "", `create_time` datetime NULL COMMENT "" ) ENGINE=OLAP UNIQUE KEY(`abcd`) COMMENT "OLAP" DISTRIBUTED BY HASH(`abcd`) BUCKETS 3; INSERT INTO `table_2` VALUES ('H220427011909850160918','2022-04-27 16:00:33'),('T220427400109910160949','2022-04-27 16:00:54'),('T220427400123770120058','2022-04-27 16:00:56'),('T220427400126530112854','2022-04-27 16:00:34'),('T220427400127160144672','2022-04-27 16:00:10'),('T220427400127900184511','2022-04-27 16:00:34'),('T220427400129940120380','2022-04-27 16:00:23'),('T220427400139720192986','2022-04-27 16:00:34'),('T220427400140260152375','2022-04-27 16:00:02'),('T220427400153170104281','2022-04-27 16:00:31'),('H220427011909800104411','2022-04-27 16:00:14'),('H220427011909870184823','2022-04-27 16:00:36'),('T220427400115770144416','2022-04-27 16:00:12'),('T220427400126390112736','2022-04-27 16:00:19'),('T220427400128350120717','2022-04-27 16:00:56'),('T220427400129680120838','2022-04-27 16:00:39'),('T220427400136970192083','2022-04-27 16:00:51'),('H220427011909770192580','2022-04-27 16:00:04'),('H220427011909820192943','2022-04-27 16:00:23'),('T220427400109110184990','2022-04- 27 16:00:29'),('T220427400109930192249','2022-04-27 16:00:56'),('T220427400123050168464','2022-04-27 16:00:37'),('T220427400124330112931','2022-04-27 16:00:56'),('T220427400124430144718','2022-04-27 16:00:07'),('T220427400130570160488','2022-04-27 16:00:34'),('T220427400130610112671','2022-04-27 16:00:30'),('T220427400137600160704','2022-04-27 16:00:35'),('T220427400144590176969','2022-04-27 16:00:49'),('T220427400146320176530','2022-04-27 16:00:34'),('T220427601780480120027','2022-04-27 16:00:58'); SELECT * FROM ( SELECT table_1.abcd AS exist_key, table_1.create_time AS business_time FROM table_1 ) source RIGHT JOIN ( SELECT table_2.abcd AS exist_key, table_2.create_time AS business_time FROM table_2 ) target ON source.exist_key = target.exist_key; ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
