SQLSERVER Catalog 写入内表错误

Viewed 14

版本:selectdb-doris-2.1.6
sqlserver 2019
语句:

insert into databasename.tablename select a,b,c,d from sqlserver.dbo.tablename;

报错信息:

[ERROR] 2024-10-11 10:46:31.047 +0800 - execute sql error: errCode = 2, detailMessage = (172.16.9.8)[CANCELLED]tablet error: tablet writer write failed, tablet_id=408746766, txn_id=92170773, err=[INTERNAL_ERROR]failed to get tablet: 408746766, reason: tablet does not exist. 172.16.9.6

	0#  doris::ExecEnv::get_tablet(long) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:365
	1#  doris::RowsetBuilder::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/expected.hpp:1986
	2#  doris::BaseDeltaWriter::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	3#  doris::BaseDeltaWriter::write(doris::vectorized::Block const*, std::vector<unsigned int, std::allocator<unsigned int> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	4#  std::_Function_handler<doris::Status (doris::BaseDeltaWriter*), doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*)::$_2>::_M_invoke(std::_Any_data const&, doris::BaseDeltaWriter*&&) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
	5#  doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	6#  doris::LoadChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	7#  doris::LoadChannelMgr::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	8#  std::_Function_handler<void (), doris::PInternalServiceImpl::tablet_writer_add_block(google::protobuf::RpcController*, doris::PTabletWriterAddBlockRequest const*, doris::PTabletWriterAddBlockResult*, google::protobuf::Closure*)::$_0>::_M_invoke(std::_Any_data const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	9#  doris::WorkThreadPool<false>::work_thread(int) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	10# execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	11# start_thread
	12# clone
, host: 172.16.9.6
[ERROR] 2024-10-11 10:46:31.047 +0800 - sql task error
java.sql.SQLException: errCode = 2, detailMessage = (172.16.9.8)[CANCELLED]tablet error: tablet writer write failed, tablet_id=408746766, txn_id=92170773, err=[INTERNAL_ERROR]failed to get tablet: 408746766, reason: tablet does not exist. 172.16.9.6

	0#  doris::ExecEnv::get_tablet(long) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:365
	1#  doris::RowsetBuilder::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/expected.hpp:1986
	2#  doris::BaseDeltaWriter::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	3#  doris::BaseDeltaWriter::write(doris::vectorized::Block const*, std::vector<unsigned int, std::allocator<unsigned int> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	4#  std::_Function_handler<doris::Status (doris::BaseDeltaWriter*), doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*)::$_2>::_M_invoke(std::_Any_data const&, doris::BaseDeltaWriter*&&) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
	5#  doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	6#  doris::LoadChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	7#  doris::LoadChannelMgr::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	8#  std::_Function_handler<void (), doris::PInternalServiceImpl::tablet_writer_add_block(google::protobuf::RpcController*, doris::PTabletWriterAddBlockRequest const*, doris::PTabletWriterAddBlockResult*, google::protobuf::Closure*)::$_0>::_M_invoke(std::_Any_data const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	9#  doris::WorkThreadPool<false>::work_thread(int) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	10# execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	11# start_thread
	12# clone
, host: 172.16.9.6
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
	at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:955)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1094)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1042)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1345)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdate(ClientPreparedStatement.java:1027)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.executeUpdate(SqlTask.java:316)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.executeFuncAndSql(SqlTask.java:212)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.handle(SqlTask.java:163)
	at org.apache.dolphinscheduler.server.worker.runner.DefaultWorkerDelayTaskExecuteRunnable.executeTask(DefaultWorkerDelayTaskExecuteRunnable.java:49)
	at org.apache.dolphinscheduler.server.worker.runner.WorkerTaskExecuteRunnable.run(WorkerTaskExecuteRunnable.java:174)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
	at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74)
	at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
[ERROR] 2024-10-11 10:46:31.047 +0800 - Task execute failed, due to meet an exception
org.apache.dolphinscheduler.plugin.task.api.TaskException: Execute sql task failed
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.handle(SqlTask.java:170)
	at org.apache.dolphinscheduler.server.worker.runner.DefaultWorkerDelayTaskExecuteRunnable.executeTask(DefaultWorkerDelayTaskExecuteRunnable.java:49)
	at org.apache.dolphinscheduler.server.worker.runner.WorkerTaskExecuteRunnable.run(WorkerTaskExecuteRunnable.java:174)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
	at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74)
	at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.sql.SQLException: errCode = 2, detailMessage = (172.16.9.8)[CANCELLED]tablet error: tablet writer write failed, tablet_id=408746766, txn_id=92170773, err=[INTERNAL_ERROR]failed to get tablet: 408746766, reason: tablet does not exist. 172.16.9.6

	0#  doris::ExecEnv::get_tablet(long) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:365
	1#  doris::RowsetBuilder::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/util/expected.hpp:1986
	2#  doris::BaseDeltaWriter::init() at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	3#  doris::BaseDeltaWriter::write(doris::vectorized::Block const*, std::vector<unsigned int, std::allocator<unsigned int> > const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	4#  std::_Function_handler<doris::Status (doris::BaseDeltaWriter*), doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*)::$_2>::_M_invoke(std::_Any_data const&, doris::BaseDeltaWriter*&&) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
	5#  doris::BaseTabletsChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	6#  doris::LoadChannel::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	7#  doris::LoadChannelMgr::add_batch(doris::PTabletWriterAddBlockRequest const&, doris::PTabletWriterAddBlockResult*) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	8#  std::_Function_handler<void (), doris::PInternalServiceImpl::tablet_writer_add_block(google::protobuf::RpcController*, doris::PTabletWriterAddBlockRequest const*, doris::PTabletWriterAddBlockResult*, google::protobuf::Closure*)::$_0>::_M_invoke(std::_Any_data const&) at /home/zcp/repo_center/doris_enterprise/doris/be/src/common/status.h:491
	9#  doris::WorkThreadPool<false>::work_thread(int) at /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:646
	10# execute_native_thread_routine at /data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/bits/unique_ptr.h:85
	11# start_thread
	12# clone
, host: 172.16.9.6
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
	at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
	at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:955)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1094)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1042)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1345)
	at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdate(ClientPreparedStatement.java:1027)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.executeUpdate(SqlTask.java:316)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.executeFuncAndSql(SqlTask.java:212)
	at org.apache.dolphinscheduler.plugin.task.sql.SqlTask.handle(SqlTask.java:163)
	... 9 common frames omitted
[INFO] 2024-10-11 10:46:31.048 +0800 - Get a exception when execute the task, will send the task execute result to master, the current task execute result is TaskExecutionStatus{code=6, desc='failure'}
1 Answers