좋은 강의 감사합니다. 질문이 있습니다.

네

이 부분은 스프링 배치 자체의 문제라기 보다는 트랜잭션 관련 이슈라고 볼 수 있습니다.

JpaPagingItemReader 에 보시면 아래와 같은 구분이 있습니다.

if (transacted) {
   tx = entityManager.getTransaction();
   tx.begin();
   
   entityManager.flush();
   entityManager.clear();
}//end if

즉 entityManager 를 통해 새로운 트랜잭션을 얻어 오고 있습니다

기본적으로 스프링 배치는 chunk  단위로 트랜잭션이 생성되고 종료됩니다.

그렇기 때문에 위의 구문이 시작되기 전에 이미 chunk 처리 과정에서 트랜잭션은 시작되었다고 볼 수 있습니다.

근데 JpaPagingItemReader 에서는 별도의 트랜잭션 설정을 하고 있습니다.

이것 자체가 문제가 될 것은 없습니다.

트랜잭션은 중첩되어 실행될 수 있기 때문입니다.

그렇다면 위의 오류가 나는 것은 어떤 원인일까요?

트랜잭션은 예외나 오류가 발생하면 롤백 처리를 하게 됩니다. 그래서 chunk 에서 시작했던  트랜잭션을 롤백할려고 시도합니다. 

근데 skip 정책에 의해서 해당 예외를 무시하고 롤백이 아닌 다음 과정으로 진행할려고 합니다.

진행 중에 다음 구문을 만나게 됩니다.\

바로 tx.begin() 입니다.  tx.begin() 안으로 들어가 보면 이런 구문이 나옵니다.

@Override
public void begin() {
   if ( !session.isOpen() ) {
      throw new IllegalStateException( "Cannot begin Transaction on closed Session/EntityManager" );
   }

   if ( transactionDriverControl == null ) {
      transactionDriverControl = transactionCoordinator.getTransactionDriverControl();
   }

   // per-JPA
   if ( isActive() ) {
      if ( jpaCompliance.isJpaTransactionComplianceEnabled()
            || !transactionCoordinator.getTransactionCoordinatorBuilder().isJta() ) {
         throw new IllegalStateException( "Transaction already active" );
      }
      else {
         return;
      }
   }

   LOG.debug( "begin" );

   this.transactionDriverControl.begin();
}

위에서 isActive() 가 나옵니다.

isActive() 가 참이면 new IllegalStateException( "Transaction already active" ) 예외가 발생합니다.

isActive() 안으로 들어가 보겠습니다.

@Override
   public boolean isActive() {
      // old behavior considered TransactionStatus#MARKED_ROLLBACK as active
//    return isActive( jpaCompliance.isJpaTransactionComplianceEnabled() ? false : true );
      return isActive( true );
   }

여기서 아래 isMarkedForRollbackConsideredActive 파라미터에 true 값을 전달하고 있습니다.

@Override
public boolean isActive(boolean isMarkedForRollbackConsideredActive) {
   if ( transactionDriverControl == null ) {
      if ( session.isOpen() ) {
         transactionDriverControl = transactionCoordinator.getTransactionDriverControl();
      }
      else {
         return false;
      }
   }
   return transactionDriverControl.isActive( isMarkedForRollbackConsideredActive );
}

다시 transactionDriverControl.isActive( isMarkedForRollbackConsideredActive ) 로 다시 들어가 보면 

default boolean isActive(boolean isMarkedRollbackConsideredActive) {
   final TransactionStatus status = getStatus();
   return TransactionStatus.ACTIVE == status
         || ( isMarkedRollbackConsideredActive && TransactionStatus.MARKED_ROLLBACK == status );
}

가 나옵니다.

런타임에서  실행한 디버깅 모드인데 DB 에서 예외가 발생한 이후입니다.

TransactionStatus 의 상태를 확인하고  isMarkedRollbackConsideredActive  및 TransactionStatus.MARKED_ROLLBACK == status  의 상태를 체크하는데 해석해보면 현재 트랜잭션이 롤백으로 사용되도록 마킹되어 있음을 확인할 수 있습니다.

즉 현재 트랜잭션의 상태는 롤백으로 마킹되어 있다는 의미고 이것은 현재 트랜잭션은  커밋이나 다른 용도로 사용할 수 없음을 의미합니다.

skip() 으로 예외를 무시하고 넘어 갔지만 현재 활성화된 트랜잭션이 롤백용으로 마킹된 트랜잭션이라면  롤백처리 외 다른 트랜잭션 설정을 할 수 없다는 예외를 발생한 것입니다.

일단 여기에 대한 해결책은 JpaPagingItemReader 에서 tx.begin() 을 실행하지 않도록 해야 하는데 API 옵션 중에서 transacted 을 false 로 할 수 있는데 그렇데 되면 

if (transacted) {  // fasle 이면 실행되지 않는다 기본은 true

   tx = entityManager.getTransaction();
   tx.begin();
   
   entityManager.flush();
   entityManager.clear();

}

위의 구문이 실행되지 않기 때문에 해당 이슈는 발생하지 않지만 Jpa 는 트랜잭션 안에서 영속성이 적용되기 떄문에 연관된 객체를 가지고 올 때 Lazy loading 시  no session 의 에러를 만나게 됩니다.

아니면 연관객체의 Fetch  모드를 Eager 로 변경해서 사용해야 합니다.

다른 해결책으로는 JpaPagingItemReader 를 똑같이 복사한 새로운 커스텀 클래스를 만들고 위의 구문을

if (transacted) 
   entityManager.clear();
}

와 같이 만드는 것입니다.  즉 오류가 나는  트랜잭션 설정을 제외합니다.

근데 이 부분은 충분한 검증을 해야 하기 때문에 실무에 적용하기가 조심스럽습니다.

일단 제 판단으로는 skip() 에 의한 예외를 처리하면서 위의 오류를 해결하는 것은 Jpa 기반이 아닌 Jdbc 기반 ItemReader 을 사용하는 것입니다.

다른 해결책이 있는지 좀 더 분석이나 여러 자료들을 참고해 봐야 할 것 같습니다.

쿼츠로 자동실행 crontab으로 1분마다 되도록 해놨습니다.. 혹시 봐주실수 있다면 DB만 생성해주시고 실행해주시면 감사하겠습니다 ㅠㅠ