1 [2026-01-09 11:04:21.655] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [ETLBatchProcessor: meet error java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported, recordBatch [[meta[jwell_dq_demo-class,1767927391,DDL,1767927391]post[Struct{ddl(CHAR_STRING)=CREATE TABLE class ( 2 Cno CHAR(9), 3 Cname VARCHAR(20) NOT NULL 4 ),env(CHAR_STRING)=null}]]]] 5 [2026-01-09 11:04:21.662] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [] 6 java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 7 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) 8 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) 9 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:783) 10 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 11 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 12 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 13 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 14 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 15 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 16 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 17 at java.lang.Thread.run(Thread.java:853) 18 Caused by: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 19 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 20 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 21 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 22 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 23 ... 8 common frames omitted 24 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 25 ... 12 common frames omitted 26 [2026-01-09 11:04:21.667] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [notifyStopped:] 27 com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 28 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 29 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 30 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 31 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 32 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 33 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 34 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 35 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 36 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 37 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 38 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 39 at java.lang.Thread.run(Thread.java:853) 40 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 41 ... 12 common frames omitted 42 [2026-01-09 11:09:10.161] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [ETLBatchProcessor: meet error java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported, recordBatch [[meta[jwell_dq_demo-class,1767927391,DDL,1767927391]post[Struct{ddl(CHAR_STRING)=CREATE TABLE class ( 43 Cno CHAR(9), 44 Cname VARCHAR(20) NOT NULL 45 ),env(CHAR_STRING)=null}]]]] 46 [2026-01-09 11:09:10.166] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [] 47 java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 48 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) 49 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) 50 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:783) 51 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 52 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 53 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 54 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 55 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 56 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 57 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 58 at java.lang.Thread.run(Thread.java:853) 59 Caused by: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 60 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 61 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 62 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 63 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 64 ... 8 common frames omitted 65 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 66 ... 12 common frames omitted 67 [2026-01-09 11:09:10.168] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [notifyStopped:] 68 com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 69 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 70 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 71 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 72 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 73 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 74 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 75 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 76 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 77 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 78 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 79 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 80 at java.lang.Thread.run(Thread.java:853) 81 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 82 ... 12 common frames omitted 83 [2026-01-09 11:13:49.432] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [ETLBatchProcessor: meet error java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported, recordBatch [[meta[jwell_dq_demo-class,1767927391,DDL,1767927391]post[Struct{ddl(CHAR_STRING)=CREATE TABLE class ( 84 Cno CHAR(9), 85 Cname VARCHAR(20) NOT NULL 86 ),env(CHAR_STRING)=null}]]]] 87 [2026-01-09 11:13:49.436] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [] 88 java.util.concurrent.CompletionException: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 89 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) 90 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) 91 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:783) 92 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 93 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 94 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 95 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 96 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 97 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 98 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 99 at java.lang.Thread.run(Thread.java:853) 100 Caused by: com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 101 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 102 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 103 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 104 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 105 ... 8 common frames omitted 106 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 107 ... 12 common frames omitted 108 [2026-01-09 11:13:49.438] [ERROR] [forward_slot0-(ETLProcessor)-queue_slot1] [notifyStopped:] 109 com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 110 at com.oceanbase.oms.connector.common.exception.hanlder.NotifyExceptionHelper.buildUnsupportedError(NotifyExceptionHelper.java:14) 111 at com.oceanbase.oms.connector.transformer.ddl.CompensateDDLGenerator.getCompensateDDL(CompensateDDLGenerator.java:92) 112 at com.oceanbase.oms.connector.transformer.DDLTransformer.lambda$buildTargetSQL$0(DDLTransformer.java:457) 113 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) 114 at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) 115 at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) 116 at com.oceanbase.oms.connector.transformer.DDLTransformer.buildTargetSQL(DDLTransformer.java:432) 117 at com.oceanbase.oms.connector.transformer.DDLTransformer.transform(DDLTransformer.java:305) 118 at com.oceanbase.oms.connector.customize.batchprocessor.ETLBatchProcessor.process(ETLBatchProcessor.java:40) 119 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.processRecordBatch(SerialBridgeConnectorTask.java:105) 120 at com.oceanbase.connector.framework.threadmanager.bridgetask.SerialBridgeConnectorTask.run(SerialBridgeConnectorTask.java:79) 121 at java.lang.Thread.run(Thread.java:853) 122 Caused by: java.lang.UnsupportedOperationException: create no pk or not null uk table is not supported 123 ... 12 common frames omitted