[2024-10-25 00:38:00.897] [ERROR] [sinkTask-3] [Fatal exception oms record [meta[ncms_gd.ncms_gd-rpt_prv_rent_basesite_tx,1729786887,DDL,1729786886]post[Struct{ddl(VAR_CHAR_STRING)=TRUNCATE TABLE `rpt_prv_rent_basesite_tx`,env(VAR_CHAR_STRING)=1729786886952208,ddlType(VAR_STRING)=TRUNCATE_TABLE,srcDatabase(VAR_STRING)=ncms_gd.ncms_gd,srcTable(VAR_STRING)=rpt_prv_rent_basesite_tx,destDatabase(VAR_STRING)=ncms_gd,destTable(VAR_STRING)=rpt_prv_rent_basesite_tx,originalDDL(VAR_STRING)=truncate table rpt_prv_rent_basesite_TX;,affectObjects(LIST)={"db":"ncms_gd","table":"rpt_prv_rent_basesite_tx"}}]], exception message [com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_tx' doesn't exist], errorCode [1146], sqlState [42S02]] [2024-10-25 00:38:00.907] [ERROR] [sinkTask-3] [Failed to offer sink] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_tx' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_tx' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted [2024-10-25 00:38:00.907] [ERROR] [sinkTask-3] [notifyStopped:] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_tx' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_tx' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted [2024-10-25 00:38:03.549] [ERROR] [nioEventLoopGroup-2-1] [put buf failed, client may have stopped] java.lang.Exception: put buf failed, client may have stopped at alibaba.drcnet.processer.DRCNetProcesser.porcessCompressContent(DRCNetProcesser.java:238) at alibaba.drcnet.processer.DRCNetProcesser.process(DRCNetProcesser.java:215) at alibaba.drcnet.reactor.DRCNetReactor.channelRead(DRCNetReactor.java:46) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:853) [2024-10-25 10:14:51.513] [ERROR] [sinkTask-1] [Fatal exception oms record [meta[ncms_gd.ncms_gd-rpt_prv_rent_basesite_yf,1729786887,DDL,1729786886]post[Struct{ddl(VAR_CHAR_STRING)=TRUNCATE TABLE `rpt_prv_rent_basesite_yf`,env(VAR_CHAR_STRING)=1729786887264640,ddlType(VAR_STRING)=TRUNCATE_TABLE,srcDatabase(VAR_STRING)=ncms_gd.ncms_gd,srcTable(VAR_STRING)=rpt_prv_rent_basesite_yf,destDatabase(VAR_STRING)=ncms_gd,destTable(VAR_STRING)=rpt_prv_rent_basesite_yf,originalDDL(VAR_STRING)=truncate table rpt_prv_rent_basesite_YF;,affectObjects(LIST)={"db":"ncms_gd","table":"rpt_prv_rent_basesite_yf"}}]], exception message [com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_yf' doesn't exist], errorCode [1146], sqlState [42S02]] [2024-10-25 10:14:51.524] [ERROR] [sinkTask-1] [Failed to offer sink] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_yf' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_yf' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted [2024-10-25 10:14:51.525] [ERROR] [sinkTask-1] [notifyStopped:] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_yf' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_rent_basesite_yf' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted [2024-10-25 10:14:52.444] [ERROR] [nioEventLoopGroup-2-1] [put buf failed, client may have stopped] java.lang.Exception: put buf failed, client may have stopped at alibaba.drcnet.processer.DRCNetProcesser.porcessCompressContent(DRCNetProcesser.java:238) at alibaba.drcnet.processer.DRCNetProcesser.process(DRCNetProcesser.java:215) at alibaba.drcnet.reactor.DRCNetReactor.channelRead(DRCNetReactor.java:46) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:853) [2024-10-25 21:42:46.601] [ERROR] [sinkTask-5] [Fatal exception oms record [meta[ncms_gd.ncms_gd-rpt_prv_ele_keyindicator_tx,1729863766,DDL,1729863765]post[Struct{ddl(VAR_CHAR_STRING)=TRUNCATE TABLE `rpt_prv_ele_keyindicator_tx`,env(VAR_CHAR_STRING)=1729863766286160,ddlType(VAR_STRING)=TRUNCATE_TABLE,srcDatabase(VAR_STRING)=ncms_gd.ncms_gd,srcTable(VAR_STRING)=rpt_prv_ele_keyindicator_tx,destDatabase(VAR_STRING)=ncms_gd,destTable(VAR_STRING)=rpt_prv_ele_keyindicator_tx,originalDDL(VAR_STRING)=truncate table rpt_prv_ele_keyindicator_TX,affectObjects(LIST)={"db":"ncms_gd","table":"rpt_prv_ele_keyindicator_tx"}}]], exception message [com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_ele_keyindicator_tx' doesn't exist], errorCode [1146], sqlState [42S02]] [2024-10-25 21:42:46.609] [ERROR] [sinkTask-5] [Failed to offer sink] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_ele_keyindicator_tx' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_ele_keyindicator_tx' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted [2024-10-25 21:42:46.610] [ERROR] [sinkTask-5] [notifyStopped:] com.oceanbase.oms.connector.common.exception.NotifyException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_ele_keyindicator_tx' doesn't exist at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnknownError(NotifyExceptionHelper.java:19) at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:107) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:527) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDDL(Writer.java:443) at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:179) at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) at java.lang.Thread.run(Thread.java:853) Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'ncms_gd.rpt_prv_ele_keyindicator_tx' doesn't exist at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) at com.mysql.jdbc.Util.getInstance(Util.java:408) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:944) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2043) at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeUpdate(DruidPooledPreparedStatement.java:255) at com.oceanbase.oms.connector.jdbc.sink.Writer.writeDDL(Writer.java:641) at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:484) ... 5 common frames omitted