检测到 Avro 编码的架构无效。
同时添加和删除列
在同一查询演变中添加了列<addedColsStr>
并删除了列系列<removedColsStr>
中的列<colFamilyName>
。 若要允许此架构演变,请将 spark.sql.streaming.join.schemaEvolution.disallowAddDrop 设置为 false,但请注意,这会丢弃累积状态。 如果尝试重命名列而不丢失累积状态,请考虑保留相同的查询并添加投影。
添加非可空字段
在架构演进后添加了非空字段:<nonNullableFields>
,在列族:<colFamilyName>
中。 请注意,新添加的字段必须可为 null 才能允许使用 Avro 编码进行架构演变,请考虑仅添加可为 null 的字段。
模式中的重复名称
检测到重复的名称:“<invalidName>
”。 请注意,使用 Avro 编码的字段名称必须全部是唯一的。
通用
请查看查询中使用的字段名称,以及抛出的以下 Avro 编码异常。
名称中的非法字符
检测到非法名称:“<invalidName>
”。 请注意,使用 Avro 编码的字段名称必须以字母或下划线开头,并且只能后跟字母数字字符或下划线。