Doris 2.0.9 insert into select 导入Mysql中数据报错:[INTERNAL_ERROR]OutOfMemoryError: Java heap space

Viewed 78

使用MySQL Catalog导入数据到Doris中报错:

mysql> insert into sixlens.weifengqi_zebra_query_log select * from mysql_prod.weifengqi.zebra_query_log;
ERROR 1105 (HY000): errCode = 2, detailMessage = (192.168.88.210)[INTERNAL_ERROR]OutOfMemoryError: Java heap space

查看192.168.88.210 be.INFO文件报错信息如下:

I0624 09:44:49.107246 18279 fragment_mgr.cpp:695] query_id: 8fdb89c300b3438e-a54fcc694b02619b coord_addr TNetworkAddress(hostname=192.168.88.210, port=9020) total fragment num on current host: 1
I0624 09:44:49.107295 18279 fragment_mgr.cpp:767] Register query/load memory tracker, query/load id: 8fdb89c300b3438e-a54fcc694b02619b limit: 12.00 GB
I0624 09:44:49.107348 18279 plan_fragment_executor.cpp:115] PlanFragmentExecutor::prepare|query_id=8fdb89c300b3438e-a54fcc694b02619b|instance_id=8fdb89c300b3438e-a54fcc694b02619c|backend_num=0|pthread_id=140469285291776
I0624 09:44:49.107723 17085 fragment_mgr.cpp:532] PlanFragmentExecutor::_exec_actual|query_id=8fdb89c300b3438e-a54fcc694b02619b|instance_id=8fdb89c300b3438e-a54fcc694b02619c|pthread_id=140481828902656
I0624 09:44:49.107738 17085 plan_fragment_executor.cpp:242] PlanFragmentExecutor::open|query_id=8fdb89c300b3438e-a54fcc694b02619b|instance_id=8fdb89c300b3438e-a54fcc694b02619c|mem_limit=12.00 GB
I0624 09:44:49.108105 18280 tablets_channel.cpp:103] open tablets channel: (load_id=8fdb89c300b3438e-a54fcc694b02619b, index_id=1181182), tablets num: 10, timeout(s): 14400
I0624 09:44:49.335117 17190 vjdbc_connector.cpp:236] JdbcConnector::query has exec success: SELECT `id`, `data_type`, `task_no`, `step`, `req`, `resp`, `req_time`, `resp_time`, `error` FROM `weifengqi`.`zebra_query_log`
I0624 09:44:50.533371 16805 daemon.cpp:221] os physical memory 30.26 GB. process memory used 3.54 GB, limit 12.10 GB, soft limit 10.89 GB. sys available memory 24.18 GB, low water mark 3.03 GB, warning water mark 6.05 GB. Refresh interval memory growth 0 B
I0624 09:44:51.438186 16805 daemon.cpp:221] os physical memory 30.26 GB. process memory used 3.79 GB, limit 12.10 GB, soft limit 10.89 GB. sys available memory 23.91 GB, low water mark 3.03 GB, warning water mark 6.05 GB. Refresh interval memory growth 0 B
W0624 09:44:52.439059 17190 jni-util.cpp:241] java.lang.OutOfMemoryError: Java heap space
	at java.util.Arrays.copyOf(Arrays.java:3236)
	at java.lang.StringCoding.safeTrim(StringCoding.java:79)
	at java.lang.StringCoding.encode(StringCoding.java:365)
	at java.lang.String.getBytes(String.java:941)
	at org.apache.doris.jdbc.JdbcExecutor.stringPutToString(JdbcExecutor.java:1831)
	at org.apache.doris.jdbc.JdbcExecutor.copyBatchJsonResult(JdbcExecutor.java:2282)
W0624 09:44:53.020782 17190 status.h:396] meet error status: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.020888 17190 scanner_scheduler.cpp:396] Scan thread read VScanner failed: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.021036 17085 fragment_mgr.cpp:145] query_id=8fdb89c300b3438e-a54fcc694b02619b, instance_id=8fdb89c300b3438e-a54fcc694b02619c meet error status [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.021214 17085 fragment_mgr.cpp:486] Query 8fdb89c300b3438e-a54fcc694b02619b instance 8fdb89c300b3438e-a54fcc694b02619c report error status to coor 192.168.88.210:9020, error status: 6
W0624 09:44:53.024153 17085 fragment_mgr.cpp:267] Got error while opening fragment 8fdb89c300b3438e-a54fcc694b02619c, query id: 8fdb89c300b3438e-a54fcc694b02619b: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
I0624 09:44:53.024187 17085 plan_fragment_executor.cpp:469] PlanFragmentExecutor::cancel|query_id=8fdb89c300b3438e-a54fcc694b02619b|instance_id=TUniqueId(hi=-8080713635762846834, lo=-6534779781689220708)|reason=3|error message=PlanFragmentExecutor open failed, reason: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.024214 17085 runtime_state.h:175] Task is cancelled, query id: 8fdb89c300b3438e-a54fcc694b02619b, instance id: 8fdb89c300b3438e-a54fcc694b02619c, st = [CANCELLED]PlanFragmentExecutor open failed, reason: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
I0624 09:44:53.106781 32418 task_worker_pool.cpp:264] successfully submit task|type=CLEAR_TRANSACTION_TASK|signature=43008|queue_size=1
I0624 09:44:53.106833 18015 task_worker_pool.cpp:1686] get clear transaction task. signature=43008, transaction_id=43008, partition_id_size=0
I0624 09:44:53.106834 32418 task_worker_pool.cpp:264] successfully submit task|type=CLEAR_TRANSACTION_TASK|signature=43056|queue_size=1
I0624 09:44:53.106909 18015 storage_engine.cpp:679] begin to clear transaction task. transaction_id=43008
I0624 09:44:53.106914 18015 storage_engine.cpp:701] finish to clear transaction task. transaction_id=43008
I0624 09:44:53.106916 18015 task_worker_pool.cpp:1704] finish to clear transaction task. signature=43008, transaction_id=43008
I0624 09:44:53.106922 32418 task_worker_pool.cpp:264] successfully submit task|type=CLEAR_TRANSACTION_TASK|signature=43081|queue_size=2
I0624 09:44:53.107044 18015 task_worker_pool.cpp:1686] get clear transaction task. signature=43056, transaction_id=43056, partition_id_size=0
I0624 09:44:53.107051 18015 storage_engine.cpp:679] begin to clear transaction task. transaction_id=43056
I0624 09:44:53.107054 18015 storage_engine.cpp:701] finish to clear transaction task. transaction_id=43056
I0624 09:44:53.107056 18015 task_worker_pool.cpp:1704] finish to clear transaction task. signature=43056, transaction_id=43056
I0624 09:44:53.107133 18015 task_worker_pool.cpp:1686] get clear transaction task. signature=43081, transaction_id=43081, partition_id_size=0
I0624 09:44:53.107138 18015 storage_engine.cpp:679] begin to clear transaction task. transaction_id=43081
I0624 09:44:53.107141 18015 storage_engine.cpp:701] finish to clear transaction task. transaction_id=43081
I0624 09:44:53.107143 18015 task_worker_pool.cpp:1704] finish to clear transaction task. signature=43081, transaction_id=43081
W0624 09:44:53.129649 17085 status.h:396] meet error status: [ABORTED]PlanFragmentExecutor open failed, reason: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone


	0#  doris::PlanFragmentExecutor::cancel(doris::PPlanFragmentCancelReason const&, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:0
	1#  doris::FragmentExecState::cancel(doris::PPlanFragmentCancelReason const&, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:1291
	2#  doris::FragmentExecState::execute() at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/unique_ptr.h:360
	3#  doris::FragmentMgr::_exec_actual(std::shared_ptr<doris::FragmentExecState>, std::function<void (doris::RuntimeState*, doris::Status*)> const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  std::_Function_handler<void (), doris::FragmentMgr::exec_plan_fragment(doris::TExecPlanFragmentParams const&, std::function<void (doris::RuntimeState*, doris::Status*)> const&)::$_0>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	5#  doris::ThreadPool::dispatch_thread() at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/threadpool.cpp:0
	6#  doris::Thread::supervise_thread(void*) at /var/local/ldb_toolchain/bin/../usr/include/pthread.h:562
	7#  start_thread
	8#  clone
I0624 09:44:53.129739 17085 exec_node.cpp:192] fragment_instance_id=8fdb89c300b3438e-a54fcc694b02619c closed
I0624 09:44:53.202127 17085 exec_node.cpp:206] query= 8fdb89c300b3438e-a54fcc694b02619b, fragment_instance_id=8fdb89c300b3438e-a54fcc694b02619c, id=0 type=JDBC_SCAN_NODE closed
W0624 09:44:53.202174 17085 vtablet_sink.cpp:680] cancel node channel VNodeChannel[1181182-10004], load_id=8fdb89c300b3438e-a54fcc694b02619b, txn_id=43081, node=192.168.88.210:8060, error message: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.202292 17085 vtablet_sink.cpp:680] cancel node channel VNodeChannel[1181182-10003], load_id=8fdb89c300b3438e-a54fcc694b02619b, txn_id=43081, node=192.168.88.208:8060, error message: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
W0624 09:44:53.202348 17085 vtablet_sink.cpp:680] cancel node channel VNodeChannel[1181182-10002], load_id=8fdb89c300b3438e-a54fcc694b02619b, txn_id=43081, node=192.168.88.209:8060, error message: [INTERNAL_ERROR]OutOfMemoryError: Java heap space

	0#  doris::JniUtil::GetJniExceptionMsg(JNIEnv_*, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/jni-util.h:117
	1#  doris::vectorized::JdbcConnector::_convert_batch_result_set(JNIEnv_*, _jobject*, doris::SlotDescriptor const*, doris::vectorized::IColumn*, int, int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/basic_string.h:187
	2#  doris::vectorized::JdbcConnector::get_next(bool*, std::vector<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn>, std::allocator<COW<doris::vectorized::IColumn>::mutable_ptr<doris::vectorized::IColumn> > >&, doris::vectorized::Block*, int) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/vjdbc_connector.cpp:507
	3#  doris::vectorized::NewJdbcScanner::_get_block_impl(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:446
	4#  doris::vectorized::VScanner::get_block(doris::RuntimeState*, doris::vectorized::Block*, bool*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/vec/exec/scan/vscanner.cpp:0
	5#  doris::vectorized::ScannerScheduler::_scanner_scan(doris::vectorized::ScannerScheduler*, doris::vectorized::ScannerContext*, std::shared_ptr<doris::vectorized::VScanner>) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:357
	6#  std::_Function_handler<void (), doris::vectorized::ScannerScheduler::_schedule_scanners(doris::vectorized::ScannerContext*)::$_1::operator()() const::{lambda()#4}>::_M_invoke(std::_Any_data const&) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:701
	7#  doris::WorkThreadPool<true>::work_thread(int) at /var/local/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	8#  execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	9#  start_thread
	10# clone
I0624 09:44:53.202391 18281 load_channel_mgr.cpp:228] load channel has been cancelled: 8fdb89c300b3438e-a54fcc694b02619b
I0624 09:44:53.202394 17085 vtablet_sink.cpp:1477] close olap table sink. load_id=8fdb89c300b3438e-a54fcc694b02619b, txn_id=43081, canceled all node channels due to error: false
I0624 09:44:53.202415 18281 load_channel.cpp:46] load channel removed. mem peak usage=0, info=label: LoadChannel#senderIp=192.168.88.210#loadID=8fdb89c300b3438e-a54fcc694b02619b; consumption: 0; peak_consumption: 0; , load_id=8fdb89c300b3438e-a54fcc694b02619b, is high priority=0, sender_ip=192.168.88.210
I0624 09:44:53.203276 18419 vtablet_sink.cpp:1189] all node channels are stopped(maybe finished/offending/cancelled), sender thread exit. 8fdb89c300b3438e-a54fcc694b02619b
I0624 09:44:53.203474 17085 plan_fragment_executor.cpp:541] Query : 8fdb89c300b3438e-a54fcc694b02619b instance 8fdb89c300b3438e-a54fcc694b02619c
Fragment 8fdb89c300b3438e-a54fcc694b02619c:(Active: 3s913ms, non-child: 0.00%)
   - DorisBeVersion: b5c08438c2
   - BlocksProduced: 0
   - FragmentCpuTime: 352.708us
   - RowsProduced: 0
  OlapTableSink:(Active: 2.179ms, non-child: 0.06%)
     - CloseWaitTime: 1.419ms
     - MaxAddBatchExecTime: 0.000ns
     - MaxWaitExecTime: 0.000ns
     - NonBlockingSendTime: 4s094ms
       - NonBlockingSendWorkTime: 0.000ns
         - SerializeBatchTime: 0.000ns
     - NumberBatchAdded: 0
     - NumberNodeChannels: 0
     - OpenTime: 950.739us
     - RowsFiltered: 0
     - RowsRead: 0
     - RowsReturned: 0
     - SendDataTime: 0.000ns
       - AppendNodeChannelTime: 0.000ns
       - FilterTime: 0.000ns
       - RowDistributionTime: 0.000ns
       - WaitMemLimitTime: 0.000ns
       - WhereClauseTime: 0.000ns
     - TotalAddBatchExecTime: 0.000ns
     - TotalWaitExecTime: 0.000ns
     - ValidateDataTime: 0.000ns
  VNewJdbcScanNode(`weifengqi`.`zebra_query_log`) (id=0):(Active: 3s912ms, non-child: 99.98%)
     - RuntimeFilters: : 
     - UseSpecificThreadToken: False
     - AcquireRuntimeFilterTime: 858.000ns
     - AllocateResourceTime: 78.340us
     - GetNextTime: 3s912ms
     - MaxScannerThreadNum: 1
     - MemoryUsage: 
       - PeakMemoryUsage: 0
     - NumScanners: 1
     - OpenTime: 78.713us
     - ProjectionTime: 0.000ns
     - RowsReturned: 0
     - RowsReturnedRate: 0
     - ScanByteRead: 0
     - ScanRowsRead: 0
     - ScannerWorkerWaitTime: 34.675us
     - TotalReadThroughput: 0
    VScanner:
       - JdbcDriverClass: com.mysql.jdbc.Driver
       - JdbcDriverUrl: mysql-connector-java-8.0.25.jar
       - JdbcUrl: jdbc:mysql://rm-uf6dbb15l39c90pf5.mysql.rds.aliyuncs.com:3306/cc?yearIsDateType=false&tinyInt1isBit=false&useUnicode=true&rewriteBatchedStatements=true&characterEncoding=utf-8
       - QuerySql: SELECT `id`, `data_type`, `task_no`, `step`, `req`, `resp`, `req_time`, `resp_time`, `error` FROM `weifengqi`.`zebra_query_log`
       - PerScannerRunningTime: [3s685ms, ]
       - PerScannerRowsRead: [0, ]
       - PerScannerWaitTime: [34.675us, ]
       - CheckTypeTime: 0.000ns
       - ConnectorCloseTime: 0.000ns
       - ExecteReadTime: 0.000ns
       - GetDataTime: 0.000ns
         - CallJniNextTime: 0.000ns
         - ConvertBatchTime: 0.000ns
       - InitConnectorTime: 0.000ns
       - LoadJarTime: 0.000ns
       - MemoryUsage: 
         - FreeBlocks: 0
         - QueuedBlocks: 0
       - NewlyCreateFreeBlocksNum: 1
       - ScannerBatchWaitTime: 3s912ms
       - ScannerConvertBlockTime: 0.000ns
       - ScannerCpuTime: 1s735ms
       - ScannerCtxSchedCount: 1
       - ScannerCtxSchedTime: 12.454us
       - ScannerFilterTime: 0.000ns
       - ScannerGetBlockTime: 3s685ms
       - ScannerPrefilterTime: 0.000ns
       - ScannerSchedCount: 1
<unnamed>:
I0624 09:44:53.203509 17085 plan_fragment_executor.cpp:545] Close() fragment_instance_id=8fdb89c300b3438e-a54fcc694b02619c
I0624 09:44:53.203519 17085 fragment_mgr.cpp:554] Query 8fdb89c300b3438e-a54fcc694b02619b finished
I0624 09:44:53.203699 17085 query_context.h:71] Deregister query/load memory tracker, queryId=8fdb89c300b3438e-a54fcc694b02619b, Limit=12.00 GB, CurrUsed=1.15 MB, PeakUsed=2.18 MB
1 Answers