当前位置:网站首页>Environment: Flink version: 1.15.1 jar package: flink-sql-connector-oracle
Environment: Flink version: 1.15.1 jar package: flink-sql-connector-oracle
2022-08-09 21:35:00 【Alibaba Cloud Q&A】
Environment: Flink version: 1.15.1 Jar package: flink-sql-connector-oracle-cdc-2.2.1.jar OS version: CentOS7.6 Source Oracle: version 11.2.0.4
After the source table is created on the flink sql client, simply use the select query, because the Oracle source table has a lob field. This should be because the stored lob field is too large and an error is reported. I tried another table that also has a lob field, butWhen reading, the error message is as follows: [ERROR] Could not execute SQL statement. Reason: java.lang.RuntimeException: Record size is too large for CollectSinkFunction. Record size is 2421996 bytes, but max bytes per batch is only 2097152 bytes. Please consider increasing max bytes per batch value by setting collect-sink.batch-size.max
Looking at the prompt, it should be to modify the parameter collect-sink.batch-size.max, but I can't find where this parameter is set, please ask God for guidance, thank you.
Accepted answer 1:
A single record is too large, collect-sink needs to configure this parameter, and it can be done directly in the sql client set (this answer is organized from the Flink CDC community)
边栏推荐
- Iptables防火墙常见的典型应用场景
- 2022.08.05_每日一题
- Flume (五) --------- 自定义 Interceptor、自定义 Source 与 自定义 Sink
- 正则表达式(全)
- 2022 RoboCom 世界机器人开发者大赛-本科组(省赛)-RC-u5 树与二分图
- 日本著名设计师三宅一生去世:产品曾被国人高价抢 乔布斯也是粉丝
- [免费专栏] Android安全之和平精英(FZ)APK逆向分析
- Start cleaning up the long-term divers in the electronic chart development group again
- IS31FL3737B 通用12×12 LED驱动器 I2C 42mA 40QFN
- vim编辑器使用
猜你喜欢

uniapp离线推送华为厂商申请流程

每周给我10分钟,我给你一个Flink SQL 菜谱——甜点:数据过滤

Iptables防火墙常见的典型应用场景

启动 CM agent 报错——ImportError: libssl.so.10: cannot open shared object file: No such file or directory

这年头还不来尝试线稿图视频??

2022深圳(软考高级)信息系统项目管理师认证报名

数学建模——模拟退火

Fully automated machine learning modeling!The effect hangs the primary alchemist!

2021 RoboCom 世界机器人开发者大赛-本科组(决赛)

ebook download | "Business executives' IT strategy guide - why enterprises should implement DevOps"
随机推荐
论文精读:VIT - AN IMAGE IS WORTH 16X16 WORDS: TRANSFORMERS FOR IMAGE RECOGNITION AT SCALE
How to suppress alarm storms?
numpy中nan_to_num如何使用
牛客网 Verilog 在线编程题库解答(VL1~VL10)
电商项目架构图
awk use
Typora 结合 Picgo 自动上传图像
对应运放 RC 滤波负反馈的波形
毕昇编译器优化:Lazy Code Motion
Fully automated machine learning modeling!The effect hangs the primary alchemist!
JMeter压测时如何在达到给定错误数量后停止测试
web正则表达式中^和$的含义是什么
ebook下载 | 《 企业高管IT战略指南——企业为何要落地DevOps》
21天学习挑战赛--第四天打卡(横竖屏切换)
Iptables防火墙常见的典型应用场景
单片机编程-状态机
基于CC2530 E18-MS1-PCB Zigbee DIY作品
[] free column Android dynamic debugging GDB APP of safety
[免费专栏] Android安全之动态代码注入技术(利用JDB调试APK)
双屏协作更高效,华硕灵耀X 双屏Pro 2022创作体验再升级