Hi,
Using Flink 1.20.1, we get this error when trying to read a savepoint:
Caused by: java.lang.RuntimeException: Record size is too large for
CollectSinkFunction. Record size is 5411925 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
at
org.apache.flink.streaming.api.operators.collect.CollectSinkFunction.invoke(CollectSinkFunction.java:288)
...
I tried to set collect-sink.batch-size.max in the flink-conf.yaml, but I
still hit the same error. It's like it's not taken into account. I see
there is a fix in 1.20.1 (https://github.com/apache/flink/pull/25764) for
this, but I still face the same issue,
JM
