1 [2024-10-12 18:19:27.542] [ERROR] [sinkTask-50] [Failed to offer sink] 2 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 3 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 4 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 5 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 6 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 7 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 8 at java.lang.Thread.run(Thread.java:853) 9 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 10 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 11 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 12 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 13 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 14 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 15 ... 4 common frames omitted 16 [2024-10-12 18:19:27.544] [ERROR] [sinkTask-50] [notifyStopped:] 17 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 18 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 19 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 20 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 21 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 22 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 23 at java.lang.Thread.run(Thread.java:853) 24 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 25 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 26 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 27 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 28 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 29 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 30 ... 4 common frames omitted 31 [2024-10-12 18:19:27.546] [ERROR] [sinkTask-53] [Failed to offer sink] 32 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 33 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 34 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 35 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 36 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 37 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 38 at java.lang.Thread.run(Thread.java:853) 39 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 40 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 41 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 42 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 43 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 44 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 45 ... 4 common frames omitted 46 [2024-10-12 18:19:27.549] [ERROR] [sinkTask-53] [notifyStopped:] 47 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 48 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 49 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 50 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 51 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 52 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 53 at java.lang.Thread.run(Thread.java:853) 54 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 55 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 56 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 57 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 58 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 59 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 60 ... 4 common frames omitted 61 [2024-10-12 18:19:31.040] [ERROR] [nioEventLoopGroup-2-1] [put buf failed, client may have stopped] 62 java.lang.Exception: put buf failed, client may have stopped 63 at alibaba.drcnet.processer.DRCNetProcesser.porcessCompressContent(DRCNetProcesser.java:238) 64 at alibaba.drcnet.processer.DRCNetProcesser.process(DRCNetProcesser.java:215) 65 at alibaba.drcnet.reactor.DRCNetReactor.channelRead(DRCNetReactor.java:46) 66 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) 67 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 68 at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) 69 at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) 70 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) 71 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 72 at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) 73 at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) 74 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) 75 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 76 at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) 77 at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) 78 at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) 79 at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) 80 at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) 81 at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) 82 at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) 83 at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 84 at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) 85 at java.lang.Thread.run(Thread.java:853) 86 [2024-10-12 18:19:41.044] [ERROR] [forceDeadThread] [jdbc-connector force to quit] 87 [2024-10-12 18:28:09.742] [ERROR] [sinkTask-55] [Failed to offer sink] 88 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 89 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 90 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 91 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 92 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 93 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 94 at java.lang.Thread.run(Thread.java:853) 95 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 96 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 97 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 98 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 99 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 100 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 101 ... 4 common frames omitted 102 [2024-10-12 18:28:09.742] [ERROR] [sinkTask-55] [notifyStopped:] 103 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 104 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 105 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 106 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 107 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 108 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 109 at java.lang.Thread.run(Thread.java:853) 110 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 111 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 112 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 113 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 114 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 115 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 116 ... 4 common frames omitted 117 [2024-10-12 18:28:09.747] [ERROR] [sinkTask-16] [Failed to offer sink] 118 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 119 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 120 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 121 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 122 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 123 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 124 at java.lang.Thread.run(Thread.java:853) 125 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 126 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 127 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 128 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 129 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 130 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 131 ... 4 common frames omitted 132 [2024-10-12 18:28:09.747] [ERROR] [sinkTask-16] [notifyStopped:] 133 com.oceanbase.oms.connector.common.exception.NotifyException: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 134 at com.oceanbase.oms.connector.error.AbstractErrorHandler.buildNotifyException(AbstractErrorHandler.java:105) 135 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:279) 136 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 137 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 138 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 139 at java.lang.Thread.run(Thread.java:853) 140 Caused by: com.oceanbase.oms.connector.exception.SchemaCacheException: table not existed, table:__CTAS_3223039000_1728709960081899,db:NCMS_XZ 141 at com.oceanbase.oms.connector.cache.loader.LazyTableLoader.loadTable(LazyTableLoader.java:39) 142 at com.oceanbase.oms.connector.cache.AbstractTableSchemaCache.getSchema(AbstractTableSchemaCache.java:118) 143 at com.oceanbase.oms.connector.cache.TableSchemaCacheManager.getSchema(TableSchemaCacheManager.java:27) 144 at com.oceanbase.oms.connector.jdbc.sink.Writer.tryBatchRecord(Writer.java:465) 145 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:257) 146 ... 4 common frames omitted 147 [2024-10-12 18:28:13.723] [ERROR] [nioEventLoopGroup-2-1] [put buf failed, client may have stopped] 148 java.lang.Exception: put buf failed, client may have stopped 149 at alibaba.drcnet.processer.DRCNetProcesser.porcessCompressContent(DRCNetProcesser.java:238) 150 at alibaba.drcnet.processer.DRCNetProcesser.process(DRCNetProcesser.java:215) 151 at alibaba.drcnet.reactor.DRCNetReactor.channelRead(DRCNetReactor.java:46) 152 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) 153 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 154 at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) 155 at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) 156 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) 157 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 158 at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) 159 at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) 160 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) 161 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) 162 at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) 163 at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) 164 at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) 165 at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) 166 at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) 167 at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) 168 at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) 169 at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 170 at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) 171 at java.lang.Thread.run(Thread.java:853) 172 [2024-10-12 18:28:23.728] [ERROR] [forceDeadThread] [jdbc-connector force to quit]