Spring Boot JPA ManyToMany вызывает OutOfMemoryError

Question

У меня есть загрузочное приложение Spring, и я пытаюсь вставить mov ie, связанный со странами, но через несколько минут выдается исключение. Упрощение сущностей:

Mov ie:

public class Movie implements Serializable {

    ...

    @ManyToMany(cascade = {
            CascadeType.PERSIST,
            CascadeType.MERGE
    })
    @JoinTable(name = "movies_countries",
        joinColumns = @JoinColumn(name = "id_movie"),
        inverseJoinColumns = @JoinColumn(name = "id_country")
    )
    private Set<Country> countries = new HashSet<>();

    public Set<Country> getCountries() {
        return this.countries;
    }

    public void setCountries(Set<Country> countries) {
        this.countries = countries;
    }

    public void addCountry(Country country) {
        getCountries().add(country);
        country.getMovies().add(this); // Point where it gets blocked
    }
    ...
}

Страна:

public class Country implements Serializable {

    ...

    @ManyToMany(mappedBy = "countries")
    private Set<Movie> movies = new HashSet<>();

    public Set<Movie> getMovies() {
            return movies;
    }

    public void setMovies(Set<Movie> movies) {
        this.movies = movies;
    }

    ...

}

И метод который связывает mov ie со странами:

private void insertCountries(final List<String> countries, final EntityManager entityManager, final Movie movie) {
    for (String strCountry: countries) {
        Country country = this.getCountry(entityManager, strCountry);
        movie.addCountry(country);
    }
}

Исключение:

Exception in thread "Thread-6" java.lang.OutOfMemoryError: Java heap space
    at io.netty.buffer.PooledDirectByteBuf$1.newObject(PooledDirectByteBuf.java:35)
    at io.netty.buffer.PooledDirectByteBuf$1.newObject(PooledDirectByteBuf.java:32)
    at io.netty.util.Recycler.get(Recycler.java:158)
    at io.netty.buffer.PooledDirectByteBuf.newInstance(PooledDirectByteBuf.java:40)
    at io.netty.buffer.PoolArena$DirectArena.newByteBuf(PoolArena.java:786)
    at io.netty.buffer.PoolArena.allocate(PoolArena.java:145)
    at io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:332)
    at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:185)
    at io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:176)
    at io.netty.channel.nio.AbstractNioChannel.newDirectBuffer(AbstractNioChannel.java:448)
    at io.netty.channel.nio.AbstractNioByteChannel.filterOutboundMessage(AbstractNioByteChannel.java:275)
    at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:881)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1365)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:816)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:723)
    at io.netty.handler.logging.LoggingHandler.write(LoggingHandler.java:249)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:816)
    at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:723)
    at io.netty.channel.ChannelDuplexHandler.write(ChannelDuplexHandler.java:106)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
    at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
    at io.netty.channel.AbstractChannelHandlerContext.access$1700(AbstractChannelHandlerContext.java:38)
    at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1127)
    at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1174)
    at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1098)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:495)
2020-03-02 12:41:54,741 WARN  [http-nio-8090-exec-2] com.zaxxer.hikari.pool.PoolBase: HikariPool-1 - Failed to validate connection com.mysql.jdbc.JDBC4Connection@35e38de8 (No operations allowed after connection closed.). Possibly consider using a shorter maxLifetime value.

Чтобы попытаться, я попытался увеличить память с 1 до 2 Гб, но это все же происходит. Это происходит не во всех фильмах.

Есть предложения?

Answer 1

Многие-многие отношения сложны, не используйте с ними каскадную конфигурацию, каскад связан с сохранением сущностей, здесь у вас нет сущности, просто ассоциация, эта ассоциация управляется под прикрытием orm Мониторинг того, что происходит в базовом наборе, если вы посмотрите на реализацию, этот набор действительно является своего рода пакетом, который предназначен для обнаружения изменений в нем. Сохранение должно выполняться на стороне владельца: на стороне без аннотации mappedBy.

Answer 2

Я наконец получил его на работу. Я изменил Set на List и теперь он не стоит на линии country.getMovies().add(this);.

Я добавляю точное изменение: private Set<Country> countries = new HashSet<>(); на private List<Country> countries = new ArrayList<>();