环境：Flink版本：1.15.1jar包：flink-sql-connector-oracle

环境： Flink版本：1.15.1 jar包：flink-sql-connector-oracle-cdc-2.2.1.jar OS版本：CentOS7.6 源Oracle：版本11.2.0.4

在flink sql客户端创建好source表之后，简单使用select 查询，因为Oracle源表有lob字段，这个应该是存储的lob字段太大导致报错，尝试了另外一张表也有lob字段，但是读取时正常的，报错信息如下： [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

看提示应该是修改一下参数 collect-sink.batch-size.max 即可，但是我没有找到这个参数是在哪里设置的，求大神指点，感谢。