Hi Yun,
Here's the stack trace
java.util.concurrent.ExecutionException: java.io.IOException: Size of the state
is larger than the maximum permitted memory-backed state. Size=100091190 ,
maxSize=5242880 . Consider using a different state backend, like the File
System State backend.
at j
Hi Flink Community,
I have an issue regarding create a savepoint with EmbeddedRocksDBStateBackend.
Since I have to use dataset for state processor api, it seems that the
checkpoint storage is always set to jobmanager even though I pass:
state.checkpoint-storage: filesystem
state.checkpoints.dir: '
