Apache NiFi-NullPointerException在自定义处理器上设置多个线程

我目前正在处理NiFi流程，该流程需要实现自定义处理器，才能在csv记录上应用转换。

我在执行的一些基准测试中注意到了这种现象：如果仅将一个线程分配给每个自定义处理器，则一切运行良好。由于java.lang.NullPointerException，为自定义处理器分配更多线程会导致处理会话失败。

由于无法用单个线程重现该错误，因此我在考虑处理流文件时遇到的一些问题，或者我不知道的NiFi某些方面。

通过访问流文件属性来执行处理。流文件的内容从不读取，添加一些属性后将返回输出流文件。以下是处理器代码相关部分的摘要：

@Override
public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {

    //  Will hold all the processed attributes
    Map<String, String> processedAttributes = new HashMap<>();
    FlowFile flowfile = session.get();
    ...
    //  Adds the attributes to the flowfile
    flowfile = session.putAllAttributes(flowfile, processedAttributes);
    session.transfer(flowfile, PROCESSED);
    }

我在m4.4xlarge的Amazon ec2实例上运行NiFi 0.7。由于我正在寻求高性能（没有），因此我正在寻找一种增加线程数的安全方法。任何建议都非常感谢。

先感谢您。