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

FlinkSQL 消费kafka写入iceberg，报java.nio.channels.Close

FlinkSQL 消费kafka写入iceberg，报java.nio.channels.ClosedByInterruptException: null咋办？

展开

收起

爱喝咖啡嘿 2022-12-21 11:53:26 362 版权

1 条回答

写回答

取消提交回答

co63oc_

GitHub https://github.com/co63oc/cloud

查看iceberg错误日志

2022-12-25 11:05:20

赞同展开评论

问答分类：

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

问答标签：

云消息队列 Kafka 版java kafka Java flinksql云消息队列 Kafka 版云消息队列 Kafka 版iceberg 云消息队列 Kafka 版flinksql

问答地址：

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

相关问答

实时计算 Flink版

flinksql写kafka，有时输出数据连续，有时却不连续？？

134

flinksql消费kafka然后look up join doris纬表，出现下面问题怎么解决？

125

在机器学习PAI中，有没有用flinkSQL直接连kafka的？

给一个使用Java实现的Kafka消费者示例代码？

134

斗鱼是如何解决 Kafka 和 Iceberg 各自问题的？

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？

如果用flinksql的方式同步mysql数据到kafka，是类似DTS那样吗？

消息队列kafka版发送消息报错java.util.concurrent.ExecutionE...

flinksql 读取kafka数据写入到mysql 按照主键更新会不会导致数据乱序？

Flink CDC里flinksql如何接受kafka中value是[{},{}]格式的数据？

大数据与机器学习

实时计算 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，提供丰富的企业级增值功能。

AI Agent 发展趋势与架构演进

可视化生成RocketMQ配置工具

从纳秒到毫秒的“时空之旅”：CPU是如何看待内存与硬盘的？

分布式爬虫的全局请求间隔协调与IP轮换策略

FlinkSQL 消费kafka写入iceberg，报java.nio.channels.Close

实时计算 Flink

相关文章

热门讨论

热门文章