Spring Batch Custom ItemReader IllegalArgumentException

Question

I'm trying to implement a Spring Batch custom ItemReader and am having issues with an IllegalArgumentException.

The exception trace is here;

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'reader' defined in class path resource [com/chrisbeech/batch/JobConfig.class]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: [Assertion failed] - this argument is required; it must not be null
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1583) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:545) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:751) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:861) ~[spring-context-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:541) ~[spring-context-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:761) ~[spring-boot-1.4.1.RELEASE.jar:1.4.1.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:371) ~[spring-boot-1.4.1.RELEASE.jar:1.4.1.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~    [spring-boot-1.4.1.RELEASE.jar:1.4.1.RELEASE]
at com.chrisbeech.batch.Application.main(Application.java:37) [classes/:na]
Caused by: java.lang.IllegalArgumentException: [Assertion failed] - this argument is required; it must not be null
at org.springframework.util.Assert.notNull(Assert.java:115) ~[spring-core-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.util.Assert.notNull(Assert.java:126) ~[spring-core-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.batch.item.adapter.AbstractMethodInvokingDelegator.afterPropertiesSet(AbstractMethodInvokingDelegator.java:135) ~[spring-batch-infrastructure-3.0.7.RELEASE.jar:3.0.7.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1642) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1579) ~[spring-beans-4.3.3.RELEASE.jar:4.3.3.RELEASE]
... 13 common frames omitted

I have also attached my custom ItemReader...

package com.chrisbeech.batch.step;

import java.util.ArrayList;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ParseException;
import org.springframework.batch.item.UnexpectedInputException;
import org.springframework.batch.item.adapter.ItemReaderAdapter;
import org.springframework.stereotype.Component;
import com.chrisbeech.batch.mongodb.collections.Client;

@Component
public class Reader extends ItemReaderAdapter<Client> {

private static final Logger log = LoggerFactory.getLogger(Reader.class);

private int nextClientIndex;
private List<Client> clients;

public Reader(){
    populate();
}

// populate in memory array
private void populate(){

    clients = new ArrayList<Client>();

    Client beryl = new Client();
    beryl.setFirstName("Beryl");
    beryl.setLastName("A");
    clients.add(beryl);

    Client frank = new Client();
    beryl.setFirstName("Frank");
    beryl.setLastName("A");
    clients.add(frank);

    Client paul = new Client();
    beryl.setFirstName("Paul");
    beryl.setLastName("A");
    clients.add(paul);

    Client judith = new Client();
    beryl.setFirstName("Judith");
    beryl.setLastName("A");
    clients.add(judith);

    Client lizzy = new Client();
    beryl.setFirstName("Lizzy");
    beryl.setLastName("A");
    clients.add(lizzy);

    nextClientIndex = 0;
}

// read the people
public Client read() throws Exception, UnexpectedInputException, ParseException {
    Client nextClient = null;

    if(nextClientIndex < clients.size()){
        nextClient = clients.get(nextClientIndex);
        nextClientIndex++;
        log.info("### Reading in " + nextClientIndex + " : " + nextClient);
    }

    return nextClient;
}   

}

...Batch job config...

package com.chrisbeech.batch;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.JobRegistry;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.data.MongoItemWriter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.chrisbeech.batch.config.InfrastructureConfiguration;
import com.chrisbeech.batch.mongodb.collections.Client;
import com.chrisbeech.batch.step.ClientProcessor;
import com.chrisbeech.batch.step.Reader;

@Configuration
@EnableBatchProcessing
public class JobConfig {

private static final Logger log = LoggerFactory.getLogger(JobConfig.class);

@Autowired
private JobBuilderFactory jobBuilderFactory;

@Autowired
private StepBuilderFactory stepBuilderFactory;

@Autowired
public JobLauncher jobLauncher;

@Autowired
public JobRegistry jobRegistry;

@Autowired
public InfrastructureConfiguration infrastructureConfiguration;

// define the reader (which is custom)
@Bean
public ItemReader<Client> reader(){
    return new Reader();
}

// define the processor
@Bean
public ItemProcessor<Client, Client> processor(){
    return new ClientProcessor();
}

// define the writer
@Bean
public ItemWriter<Client> writer() {
        MongoItemWriter<Client> writer = new MongoItemWriter<Client>();
        try {
            writer.setTemplate(infrastructureConfiguration.mongoTemplate());

        } catch (Exception e) {
            log.error(e.toString());
        }
        writer.setCollection("Clients");
    return writer;
}


// create the step
@Bean
public Step step(){
    return stepBuilderFactory.get("step")
            .<Client, Client> chunk(1)
            .reader(reader())
            .processor(processor())
            .writer(writer())
            .build();
}

// create the job
@Bean
public Job springBatchJob(){

    return jobBuilderFactory.get("spring-batch-test")
            .incrementer(new RunIdIncrementer())
            .flow(step())
            .end()
            .build();
}
}

...and POM...

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>com.chrisbeech.batch</groupId>
<artifactId>spring-batch-test</artifactId>
<version>0.1.0</version>

<properties>
    <java.version>1.8</java.version>
    <oracle.driver.version>11.2.0</oracle.driver.version>
    <junit.version>3.8.1</junit.version>
</properties>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.1.RELEASE</version>
    <relativePath></relativePath>
</parent>

<dependencies>
    <!-- spring boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-batch</artifactId>
    </dependency>  
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>        
    </dependency>       
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>

    <!-- ORACLE database driver -->
    <dependency>
        <groupId>com.oracle</groupId>
        <artifactId>ojdbc6</artifactId>
        <version>${oracle.driver.version}</version>
    </dependency>

    <!-- JUnit framework -->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>${junit.version}</version>
        <scope>test</scope>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <artifactId>maven-compiler-plugin</artifactId>
        </plugin>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>
</project>

Any help would be greatly appreciated!

Bic

Onkar · Accepted Answer · 2016-11-09 16:10:11Z

1

I solved this by cleaning maven repository This can be caused by a dirty classpath with different versions of Spring libraries all over the place. Cleanup it and align it to the one and same Spring version with the correct versioned dependencies

answered Nov 9, 2016 at 16:10

Onkar

6791 gold badge8 silver badges26 bronze badges

Sign up to request clarification or add additional context in comments.

3 Comments

bicster Over a year ago

How did you clean your maven repository?

Onkar Over a year ago

docs.spring.io/spring-android/docs/2.0.0.M3/reference/html/… or Google

bicster Over a year ago

I ran a mvn dependency:purge-local-repository followed by a mvn clean install and then ran again using mvn sprint-boot:run and I get the same exception :-(

Collectives™ on Stack Overflow

Spring Batch Custom ItemReader IllegalArgumentException

1 Answer 1

3 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

3 Comments

Your Answer

Sign up or log in

Post as a guest

Related