一、protobuf-java版本过低

Exception in thread "Canal Receiver" java.lang.IllegalAccessError: tried to access field com.google.protobuf.AbstractMessage.memoizedSize from class com.alibaba.otter.canal.protocol.CanalPacket$ClientAuth
	at com.alibaba.otter.canal.protocol.CanalPacket$ClientAuth.getSerializedSize(CanalPacket.java:3274)
	at com.google.protobuf.AbstractMessageLite.toByteString(AbstractMessageLite.java:49)
	at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:171)
	at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.connect(SimpleCanalConnector.java:113)
	at cn.touna.scala.spark.streaming.CanalReceiver.cn$touna$scala$spark$streaming$CanalReceiver$$receive(CanalReceiver.scala:101)
	at cn.touna.scala.spark.streaming.CanalReceiver$$anon$1.run(CanalReceiver.scala:88)

解决:
1.引入高版本依赖

<dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java</artifactId>
            <version>3.5.1</version>
        </dependency>

2.使用IED或者mvn dependency:tree -Dverbose 查看是否有版本冲突,排除低版本
3.如果1,2还不能解决,可能是某些依赖是个shade包,已经将protobuf-java低版本打入包中,debug查看即可,我项目中是hive-exec将低版本打包了,只有去除该依赖才能解决

GitHub 加速计划 / ca / canal
28.21 K
7.57 K
下载
alibaba/canal: Canal 是由阿里巴巴开源的分布式数据库同步系统,主要用于实现MySQL数据库的日志解析和实时增量数据订阅与消费,广泛应用于数据库变更消息的捕获、数据迁移、缓存更新等场景。
最近提交(Master分支:1 个月前 )
1e5b8a20 - 1 个月前
ff82fd65 1 个月前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐