NiFi 1.23.2升级后字符串类型默认值为null报错问题咨询

问题原因 #

是的，这次报错确实是因为新版本的类型校验更严格。NiFi 1.23.2升级后，依赖的Avro版本大概率进行了更新，而Avro规范本身明确要求：string类型字段的默认值必须是字符串类型，null并不属于string的合法默认值范畴。旧版本NiFi/Avro可能未严格执行该规范，新版本补上了这一校验逻辑，导致原有Schema触发报错。

快速规避方案（除修改源数据外） #

• 修改Schema为联合类型：将原Schema中的type:"string"改为联合类型["string", "null"]，示例Schema如下：

  {"name":"myKey","type":["string", "null"],"default":null}
  

  这样Avro会将字段识别为可接受字符串或null的类型，null作为默认值就符合规范了，无需改动源数据。

• 用UpdateRecord预处理数据：在Split Record处理器之前添加UpdateRecord，通过Record Path表达式将null值替换为合法字符串。比如配置Record Path为/myKey，值设置为ifElse(isNull(/myKey), "", /myKey)，把所有null的myKey字段替换为空字符串，确保后续Split Record反序列化时符合类型要求。

• 检查Reader的宽松模式配置：如果使用的是AvroReader，查看是否有类似"Allow Default Value Mismatch"的参数（部分NiFi版本的Record Reader提供宽松校验选项），开启后可临时绕过类型校验，但不推荐长期使用，建议优先前两种方案从根源解决问题。

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