简单的wordcount程序,当设置了             
env.setStateBackend(new RocksDBStateBackend(checkpointPath, true));
就会报
Caused by: java.lang.IllegalArgumentException: The fraction of memory to
allocate should not be 0. Please make sure that all types of managed memory
consumers contained in the job are configured with a non-negative weight via
`taskmanager.memory.managed.consumer-weights`.
查看源码是在 
StreamConfig的
getManagedMemoryFractionOperatorUseCaseOfSlot 方法内,得到的是0.0
因为getAllManagedMemoryUseCases 返回的是0导致的。
因为config不存在一个key : managedMemFraction.STATE_BACKEND
当我手动添加这个key就可以正常执行了。
执行代码如下:
https://paste.ubuntu.com/p/9WrBz3Xrc6/



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复