编写NiFi流处理服务时如何解决Java空指针异常？

咱们先定位问题根源：你的空指针异常大概率出在这一行代码上：

flowFile.getAttribute('filename').split('.')[0]+'_translated.json'

为什么会触发空指针？ #

从Kafka消费过来的FlowFile不一定自带filename属性，当你调用flowFile.getAttribute('filename')时，它会返回null（对应Python里的None），接着对None调用split('.')方法，就会直接触发Java空指针异常。

接下来给你几个可行的解决方案，按推荐程度排序：

方案1：给filename属性加非空判断，设置默认值 #

修改设置filename属性的逻辑，先检查原属性是否存在，不存在就用一个默认名称兜底：

original_filename = flowFile.getAttribute('filename')
# 处理原filename为空的情况
if original_filename is None:
    new_filename = 'kafka_data_translated.json'
else:
    # 这里可以再加一层判断，避免原filename没有"."的情况
    if '.' in original_filename:
        new_filename = original_filename.split('.')[0] + '_translated.json'
    else:
        new_filename = original_filename + '_translated.json'
flowFile = session.putAttribute(flowFile, "filename", new_filename)

方案2：提前给FlowFile注入filename属性 #

在ExecuteScript处理器之前，添加一个UpdateAttribute处理器，手动给FlowFile设置filename属性。比如可以设置为动态生成的名称：

filename=kafka_message_${uuid()}

这样后续脚本里就能安全获取到filename属性，不会出现空值。

额外排查优化建议 #

• 可以在脚本里加日志输出，方便排查属性是否存在：

  import org.apache.nifi.logging.ComponentLog
  log = ComponentLog.getLogger("ExecuteScript")
  # ...
  if (flowFile != None):
      original_filename = flowFile.getAttribute('filename')
      log.info("当前FlowFile的filename属性值: {}".format(original_filename))
      # 后续处理逻辑
  

  你可以在NiFi的日志里直接看到这个输出，快速确认问题所在。
• 你的ModJSON类目前只是原样转发输入流，如果后续不需要修改JSON内容，其实可以简化逻辑，直接使用默认的流处理，但如果是测试需求的话当前写法没问题。

最后提醒：在NiFi的ExecuteScript处理器中，Java对象的方法返回null时，在Python里对应None，一定要做好非空判断，不然很容易触发这类空指针异常。

内容的提问来源于stack exchange，提问作者hasherBaba