kryo.KryoException을 사용하여 kryo.KryoException에 spark.serializer를 설정합니다. orghibernate.LazyInitializationException

Question

Dao 메서드를 사용하여 (엔터티가 반환 된 후 세션이 닫힌 상태에서) hibernate3을 사용하여 db에서 일부 엔터티를 가져 와서 모든 실행자에 대해 브로드 캐스트합니다. . spark.serializer를 org.apache.spark.serializer.KryoSerializer로 설정 한 후, exception throw : KryoException org.hibernate.LazyInitializationException ... 세션이나 세션이 닫히지 않았습니다. 엔티티를 열심히 직렬화해야 어떻게 db에서 모든 값을 얻을 수 있습니까? 고마워요!

Answer 1

나는 javaSerilizer로 hibernate 엔티티를 등록하고 문제를 우회한다;