private void handleBeforeThrow(IOException exception) { if (ignoreCacheOnError && (currentDataSource == cacheReadDataSource || exception instanceof CacheDataSinkException)) { // Ignore the cache from now on. ignoreCache = true; } }