Aggregator

Aggregator에서 필수로 구현해야되는 start method 에서 보통 setContext에 들어 갈 자료형을 생성하는데 

이 때  aggregatorCall.getContext() == null 이 아닐 경우 Context를 꼭 clear 해 줘야 한다. 

Aggregator의 Context가 재사용 되면서 값이 꼬인다.   

public void start(FlowProcess flowProcess, AggregatorCall<HashMap<String, Long>> aggregatorCall) {

        if (aggregatorCall.getContext() == null) {

            aggregatorCall.setContext(new HashMap<String, Long>());

        } else {

            aggregatorCall.getContext().clear();

        }

    }