Как отключить кэширование сеанса L1 с помощью Spring Data JPA + Hibernate + PostgresQL ⇐ JAVA

[Anonymous]

У меня есть следующий репозиторий Spring Data JPA

Код: Выделить всё

public interface FooRepository extends JpaRepository {

@QueryHints(
value = {
@QueryHint(name = HINT_FETCH_SIZE, value = "1000"),
@QueryHint(name = HINT_CACHEABLE, value = "false"),
@QueryHint(name = HINT_FLUSH_MODE, value = "ALWAYS"),
@QueryHint(name = HINT_CACHE_MODE, value = "IGNORE"),
@QueryHint(name = HINT_READONLY, value = "true")
})
Stream findAll();
}

вызывается в следующем методе следующим образом:

Код: Выделить всё

@Transactional
public void doSomething() {
AtomicInteger counter = new AtomicInteger();

try(Stream stream = fooRepository.findAll()) {
stream.forEach(foo -> {
int i = counter.incrementAndGet();
logger.info(() -> "" + i);
});
}
}

При запуске этого кода с миллионами объектов Foo именно этот код выдает ошибку OutOfMemoryError. Глядя на дамп кучи после его сбоя, я вижу очень большое количество MutableEntityEntry, Foo и EntityEntryContext$ManagedEntityImpl. У всех троих одинаковое количество. Кроме того, количество EntityKey ровно в два раза больше. Например, у меня есть 40 КБ каждого из первых 3 и 80 КБ EntityKey в дампе кучи.
Чтобы это работало, я безуспешно пытался вручную сбросить, очистить и соберите мусор следующим образом

Код: Выделить всё

@Transactional // org.springframework.transaction.annotation.Transactional
public void doSomething() {
entityManager.joinTransaction(); // properly injected through Spring DI
AtomicInteger counter = new AtomicInteger();

try(Stream stream = fooRepository.findAll()) {
stream.forEach(foo -> {
int i = counter.incrementAndGet();
if (i % 100 == 0) {
fooRepository.flush();
entityManager.clear();
System.gc();
logger.info(() -> "flush, clear, gc");
}
logger.info(() -> "" + i);
});
}

Поскольку в моем коде не содержится никаких ссылок на какие-либо объекты foo, передаваемые в потоковом режиме и просматривающие объекты в дампе кучи после возникновения ошибки, я подозреваю, что проблема в в кеше сеанса L1 из Hibernate, даже если есть QueryHint, деактивирующий кеш (насколько я понимаю). Такое ощущение, что только HINT_FETCH_SIZE работает в заданных QueryHints в моем методе, и я понятия не имею, почему.
К вашему сведению, я не использую Spring Boot в все в моем проекте. Итак, у меня есть следующие bean-компоненты в SpringConfiguration для настройки Spring Data JPA:

Код: Выделить всё

@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory()
throws MalformedURLException {
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
vendorAdapter.setDatabase(Database.POSTGRESQL);
vendorAdapter.setGenerateDdl(false);

LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
factory.setJpaVendorAdapter(vendorAdapter);
factory.setPackagesToScan(getClass().getPackage().getName());
factory.setDataSource(dataSource());
Properties jpaProperties = new Properties();
jpaProperties.setProperty(
"hibernate.physical_naming_strategy",
"my.domain.hibernate.SnakeCasePhysicalNamingStrategy");
jpaProperties.setProperty("hibernate.dialect", "org.hibernate.dialect.PostgreSQL10Dialect");
factory.setJpaProperties(jpaProperties);

return factory;
}

@Bean
public EntityManager entityManager() throws MalformedURLException {
return entityManagerFactory().getObject().createEntityManager();
}

@Bean
public PlatformTransactionManager transactionManager() throws MalformedURLException {
JpaTransactionManager txManager = new JpaTransactionManager();
txManager.setEntityManagerFactory(entityManagerFactory().getObject());

return txManager;
}

Вот версии каждого

• Spring 5.2.13.RELEASE
• Spring Data JPA 2.3.7.RELEASE
• Hibernate 5.4.28.Final
• PostgreSQL 13.1 (на Alpine с использованием Докер)

Подробнее здесь: https://stackoverflow.com/questions/662 ... ostgressql