请教一个问题在使用flink1.11 提交作业的时候 抛出了一个异常 #Flink
请教一个问题 在使用flink1.11 提交作业的时候 抛出了一个异常
org.apache.kafka.common.serialization.ByteArraySerializer for configuration key.serializer: Class org.apache.kafka.common.serialization.ByteArraySerializer could not be found.
表面上看 应该是jar包引入的问题，但是这个class 我确实是引入了 经过排查 我发现，在程序进行提交的时候 会将jar上传至hdfs，并下发至各个执行节点 但是 发现在执行节点调度任务的时候 并没有下载到对应的jar（在blob store中 没有发现） 这个现象不是必现，但是频率很高 基本都是有问题的 不知道是不是我的姿势不对 还是flink1.11.0存在的问题？？？#Flink
展开
收起
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
