tispark icon indicating copy to clipboard operation
tispark copied to clipboard

Published 20 hours ago • verified publisher icon pingcap

[BUG] cacheInvalidateCallback does not work

Open marsishandsome opened this issue 5 years ago • 1 comments 

val tiSession: TiSession = TiSession.create(tiConf)
CacheInvalidateListener.initCacheListener(sparkSession.sparkContext, tiSession.getRegionManager)
// it's to late to inject
tiSession.injectCallBackFunc(CacheInvalidateListener.getInstance())

marsishandsome avatar Nov 13 '19 10:11 marsishandsome

/lifecycle frozen

shiyuhang0 avatar Apr 27 '22 09:04 shiyuhang0