I think it's a code bug in flink sink. I had this same problem some time ago. I think it's caused by compiler optimization of variable initialization in multi thread environment(flink cluster mode). In this case, the variable "cacheName" is not initialized when being used because compile will optimize the variable initialize order in multi thread environment.
I have created the ticket in jira and assigned to the author of flink sink. https://issues.apache.org/jira/browse/IGNITE-8697 -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
