2019-05-27 11:23:37.496 [pool-2-thread-1] ERROR c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - java.lang.IllegalArgumentException: Not found the mapping info of index: lezf_house
java.lang.RuntimeException: java.lang.IllegalArgumentException: Not found the mapping info of index: lezf_house
at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:113)
at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:61)
at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:176)
at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:155)
at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.batchSync(AbstractCanalAdapterWorker.java:198)
at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$1(AbstractCanalAdapterWorker.java:62)
at java.util.ArrayList.forEach(ArrayList.java:1257)
at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$2(AbstractCanalAdapterWorker.java:58)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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: java.lang.IllegalArgumentException: Not found the mapping info of index: lezf_house
at com.alibaba.otter.canal.client.adapter.es.support.ESTemplate.getEsType(ESTemplate.java:504)
at com.alibaba.otter.canal.client.adapter.es.support.ESTemplate.getValFromData(ESTemplate.java:340)
at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.wholeSqlOperation(ESSyncService.java:684)
at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.update(ESSyncService.java:309)
at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:98)
... 11 common frames omitted
通过名称查看本机es index列表:
lezf@lezf:~/tools/canal-adapter$ curl 'localhost:9200/_cat/indices?v'
health status index uuid pri rep docs.count docs.deleted store.size pri.store.size
yellow open lezf_house iQUkRXjXRLSLprYdk6gXEA 5 1 2999 20 1.7mb 1.7mb
yellow open lezf_cd_user Ixmsm_3FSPiTiqUVFCORqw 5 1 1091 6 198.4kb 198.4kb
yellow open lezf_cd_common Iq_3XFHIQvSOS4NDumGmnQ 5 1 15612 0 17.9mb 17.9mb
17条答案
按热度按时间pn9klfpd16#
这个问题解决了么
bqucvtff17#
你应该是用了别名的方式吧。