Hi all, I noticed distributed cache is not supported in async io, is there any reason for that? It's understandable that state apis are not supported since the data might be changed in working threads. But I don't know why distributed cache is not supported either.
org.apache.flink.streaming.api.functions.async.RichAsyncFunction @Override public DistributedCache getDistributedCache() { throw new UnsupportedOperationException( "Distributed cache is not supported in rich async functions."); } Here's some background: My task needs to query a kerberos secured hbase cluster. It registers kerberos configuration file and keytab file via distributed cache. For performance consideration hbase query is done in async io function. When async io meets distributed cache, it no longer works. Thanks, Yaming