When I create table with sql like this:
CREATE TABLE demo (id bigint(20) NOT NULL AUTO_INCREMENT ,create_time datetime NOT NULL ON UPDATE CURRENT_TIMESTAMP ,update_time datetime NOT NULL ON UPDATE CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP ,create_by varchar(255) NOT NULL DEFAULT '' ,update_by varchar(255) NOT NULL DEFAULT '' ,
PRIMARY KEY (id),
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
Then I insert a row, the ex will be log, the log of pipeline like this:
pid:16 nid:2 exception:setl:com.google.common.collect.ComputationException: org.apache.commons.lang.exception.NestableRuntimeException: find table [otter2.demo] error
at com.google.common.collect.MapMaker$ComputingMapAdapter.get(MapMaker.java:889)
at com.alibaba.otter.node.etl.common.db.dialect.AbstractDbDialect.findTable(AbstractDbDialect.java:109)
at com.alibaba.otter.node.etl.common.db.dialect.AbstractDbDialect.findTable(AbstractDbDialect.java:113)
at com.alibaba.otter.node.etl.transform.transformer.RowDataTransformer.transform(RowDataTransformer.java:135)
at com.alibaba.otter.node.etl.transform.transformer.RowDataTransformer.transform(RowDataTransformer.java:55)
at com.alibaba.otter.node.etl.transform.transformer.OtterTransformerFactory.transform(OtterTransformerFactory.java:79)
at com.alibaba.otter.node.etl.transform.TransformTask$1.run(TransformTask.java:86)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
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:748)
Caused by: org.apache.commons.lang.exception.NestableRuntimeException: find table [otter2.demo] error
at com.alibaba.otter.node.etl.common.db.dialect.AbstractDbDialect$2.apply(AbstractDbDialect.java:188)
at com.alibaba.otter.node.etl.common.db.dialect.AbstractDbDialect$2.apply(AbstractDbDialect.java:172)
at com.google.common.collect.ComputingConcurrentHashMap$ComputingValueReference.compute(ComputingConcurrentHashMap.java:356)
at com.google.common.collect.ComputingConcurrentHashMap$ComputingSegment.compute(ComputingConcurrentHashMap.java:182)
at com.google.common.collect.ComputingConcurrentHashMap$ComputingSegment.getOrCompute(ComputingConcurrentHashMap.java:151)
at com.google.common.collect.ComputingConcurrentHashMap.getOrCompute(ComputingConcurrentHashMap.java:67)
at com.google.common.collect.MapMaker$ComputingMapAdapter.get(MapMaker.java:885)
... 12 more
Caused by: org.apache.commons.lang.exception.NestableRuntimeException: no found table [otter2.demo] , pls check
at com.alibaba.otter.node.etl.common.db.dialect.AbstractDbDialect$2.apply(AbstractDbDialect.java:182)
... 18 more
I guess this is a bug
7条答案
按热度按时间slhcrj9b1#
Let's say you create a synchronization between database A and database B, and you execute sql(create table) on database A.
Then you should openddlat the pipeline whose sync direction isfrom A to B
7d7tgy0s2#
Let's say you create a synchronization between database A and database B, and you execute sql(create table) on database A.
Then you should openddlat the pipeline whose sync direction isfrom A to B
yes, this config is enable, but it doesn't work
0x6upsns3#
Let's say you create a synchronization between database A and database B, and you execute sql(create table) on database A.
Then you should openddlat the pipeline whose sync direction isfrom A to B
yes, this config is enable, but it doesn't work
Do you click "推送" button and restart channel after change pipeline configuration?
iklwldmw4#
你是不是ddl开错边了？
在另外一个数据库创建表然后插入数据，看能不能同步过来
p8h8hvxi5#
Let's say you create a synchronization between database A and database B, and you execute sql(create table) on database A.
Then you should openddlat the pipeline whose sync direction isfrom A to B
yes, this config is enable, but it doesn't work
Do you click "推送" button and restart channel after change pipeline configuration?
do not click
bsxbgnwa6#
你是不是ddl开错边了？ 在另外一个数据库创建表然后插入数据，看能不能同步过来
when I test this scene, I repaeat some times, then I found some tables can sync, but some can not.
ckocjqey7#
@agapple