开发者社区大数据与机器学习实时计算 Flink 正文

提交的job有使用kafka自定义序列化器有用到第三方jar包，提交job的时候出现异常，有大佬帮

提交的job有使用kafka自定义序列化器有用到第三方jar包，提交job的时候出现异常，有大佬帮帮看看吗 2591问.png

展开

收起

游客3oewgrzrf6o5c 2022-08-03 17:37:19 409 版权

1 条回答

写回答

取消提交回答

游客bcfx2q4kttgbm

这不是类型转换异常吗（此答案整理自【③群】Apache Flink China社区）

2022-08-03 17:59:40

赞同展开评论

问答分类：

消息中间件 Java Kafka 实时计算 Flink版云消息队列 Kafka 版

问答标签：

自定义jar 云消息队列 Kafka 版异常自定义序列化云消息队列 Kafka 版自定义云消息队列 Kafka 版序列化

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink cdc里 Oracle to kafka sql的提交方式咋还有序列化错误？

Flink如何打印Jar包中的自定义日志

242

消息队列Kafka版ram自定义策略能不能控制到topic级别

Flink的jar作业,mysql cdc全量阶段,啥时候支持自定义查询语句？

126

大数据计算MaxCompute自定义的函数，从哪儿能导出之前注册的jar文件？

133

Flink CDC 使用jar包启动异常

867

话说Serverless 应用引擎上传自定义jar包，自动vpc，启动的时候为啥报了个错？

115

Flink CDC提交任务可以指定第三方的jar包么？根据官网的一个参数好像没生效？

Flink CDC在跑kafka的时候有这个异常？

313

Cloud Toolkit第三方如何在上传jar包前运行打包命令呢？文档里没找到哈。请支持。

106

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

从 Java 到 AI：三周求职冲刺打卡，步步为营拿 offer

Java 转 AI 不用慌！3 周求职打卡表，帮你按天推进、高效拿 offer

《驾驭云原生复杂性：隐性Bug的全链路防御体系构建》

《微服务协作实战指南：构建全链路稳健性的防御体系》

FastJson 完全学习指南（初学者从零入门）

提交的job有使用kafka自定义序列化器有用到第三方jar包，提交job的时候出现异常，有大佬帮

实时计算 Flink

相关文章

热门讨论

热门文章