@consumables 该问题已解决，请留意一下这个问题的相关历史回复。

权限问题：https://www.askcug.com/topic/263

@脱发的山顶洞人 任务订阅事实表，自定义代码里面使用你的sql查询维表的数据组装成宽表行即可。这里关键是维表数据更新后也要将数据同步到对端。这时候建议维表更新时触发事实表的更新(业务去做)，这样自定义代码仍然会接收到事实表的变更，然后再去查询维表最新的信息，组装成新的宽表行。这样就达到你想要的效果了

@xlm 哈咯，添加文章底部的微信二维码就可以哈

@peison mysql主从有serverId可以识别来源的，也可以防回环，你可以搜相关资料查看下

@魑魅 目录叫做es6或者es7，es的yaml 扔到conf/es6/下

@junyu-cloudcanal 在 MySQL 到 Elasticsearch 实时同步构建数据检索服务的选型与思考 中说：

我们目前支持的分别订阅源端 主表和非主表，采用 upsert 语义到对端 es ，分别更新各自的字段(delete 就分别删)

upsert这个现在有支持么，看demo里面没有体现呀，我们现在有两个一对一关联的表，如果支持upsert那可以避免反查，效率应该会很高。希望能详细介绍下这块儿的功能

clickhouse 表结构 comment 只有最新版本 clickhouse 才支持，2022年3月时期 CloudCanal 版本并未对 clickhouse 做版本鉴别。

目前最新版 CloudCanal 已解决 该问题，老版的 clickhouse 不会同步 comment。

@cloudcanal-万少 这边没有改代码，没有相关日志

@fanduzi 在 5分钟搞定 MySQL 到 ClickHouse 实时数据同步进阶篇-CloudCanal实战 中说：

新

对

@cloudcanal-万少 我把用union all 拼接的其中一个sql 单独拿出来是可以同步的，但是放上那个拼接的 就不可以了 您这边有什么好的建议吗？

@lockijiang 作为对端是的。

@arcueid 在 5分钟搞定 MySQL 到 ElasticSearch 宽表构建和同步-CloudCanal实战 中说：

@junyu-cloudcanal 好的。谢谢！

@arcueid 在 5分钟搞定 MySQL 到 ElasticSearch 宽表构建和同步-CloudCanal实战 中说：

@junyu-cloudcanal 好的。谢谢！

客气，有问题社区群或者帖子中交流。

@junyu-cloudcanal 大佬麻烦看下
2021-03-10 10:05:41.922 [Thread-6] INFO com.alibaba.otter.canal.deployer.CanalStarter - ## stop the canal server
2021-03-10 10:05:41.922 [Thread-7] INFO c.a.o.canal.connector.kafka.producer.CanalKafkaProducer - ## stop the kafka producer
2021-03-10 10:05:41.927 [Thread-7] INFO c.a.o.canal.connector.kafka.producer.CanalKafkaProducer - ## kafka producer is down.
2021-03-10 10:05:43.106 [Thread-6] INFO com.alibaba.otter.canal.deployer.CanalController - ## stop the canal server[172.16..(172.16..**):11111]
2021-03-10 10:05:43.109 [Thread-6] INFO com.alibaba.otter.canal.deployer.CanalStarter - ## canal server is down.
2021-03-10 10:10:42.901 [main] INFO com.alibaba.otter.canal.deployer.CanalLauncher - ## set default uncaught exception handler
2021-03-10 10:10:42.947 [main] INFO com.alibaba.otter.canal.deployer.CanalLauncher - ## load canal configurations
2021-03-10 10:10:43.404 [main] WARN org.apache.kafka.clients.producer.ProducerConfig - The configuration ‘kerberos.enable’ was supplied but isn’t a known config.
2021-03-10 10:10:43.406 [main] WARN org.apache.kafka.clients.producer.ProducerConfig - The configuration ‘kerberos.krb5.file’ was supplied but isn’t a known config.
2021-03-10 10:10:43.406 [main] WARN org.apache.kafka.clients.producer.ProducerConfig - The configuration ‘kerberos.jaas.file’ was supplied but isn’t a known config.
2021-03-10 10:10:43.408 [main] INFO com.alibaba.otter.canal.deployer.CanalStarter - ## start the canal server.
2021-03-10 10:10:43.505 [main-SendThread(jt-xw-test01:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.lang.NoClassDefFoundError: org/apache/log4j/Logger
at org.apache.zookeeper.Login.<init>(Login.java:44) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.createSaslClient(ZooKeeperSaslClient.java:198) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:104) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:943) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:993) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
Caused by: java.lang.ClassNotFoundException: org.apache.log4j.Logger
at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_141]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_141]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) ~[na:1.8.0_141]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_141]
… 5 common frames omitted
2021-03-10 10:10:44.607 [main-SendThread(jt-xw-test01:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.lang.NoClassDefFoundError: org/apache/log4j/Logger
at org.apache.zookeeper.Login.<init>(Login.java:44) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.createSaslClient(ZooKeeperSaslClient.java:198) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:104) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:943) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:993) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
2021-03-10 10:10:45.708 [main-SendThread(jt-xw-test01:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.lang.NoClassDefFoundError: org/apache/log4j/Logger
at org.apache.zookeeper.Login.<init>(Login.java:44) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.createSaslClient(ZooKeeperSaslClient.java:198) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:104) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:943) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:993) ~[zookeeper-3.4.5.jar:3.4.5-1392090]

现在这个值是console.config.product.trial=true 不能修改成数字了 可以解决吗

@楚天乐 这里发起的请求是dump binlog，可以看看订阅的DB实例的本地binlog file是否正常。show binary logs, show master status都可以查看

@野人 我看你另外开了个提问帖，那边我贴了代码 你可以断点调试下，或者加日志调试下

@chenzhenxu123 不需要自己调整我们支持的