STATE_STORE_KEY_SCHEMA_NOT_COMPATIBLE エラー条件

SQLSTATE: 42000

指定されたキー スキーマが、演算子状態の既存のスキーマと一致しません。 既存のスキーマ=<storedKeySchema>; 指定のスキーマ=<newKeySchema>。 スキーマ検証なしでクエリを実行するには、spark.sql.streaming.stateStore.stateSchemaCheck を false に設定します。 スキーマ検証なしで実行すると、非決定論的な動作が行われる可能性があることに注意してください。

FIELDS_REORDERED

キー スキーマ フィールドの順序が変更されました。 キー スキーマ内のフィールドの並べ替えは許可されません。

FIELD_ADDED

キー スキーマに新しいフィールド <addedFields> 見つかりました。 キー スキーマへのフィールドの追加は許可されません。

FIELD_REMOVED

フィールド <removedFields> キー スキーマに含まれていない。 キー スキーマからフィールドを削除することはできません。

NULLABILITY_CHANGED

キー スキーマ内のフィールド <changedFields> の null 値の許容が変更されました。 キー フィールドの null 値の変更は許可されません。

TYPE_CHANGED

キー スキーマ内の <changedFields> フィールドの種類が変更されました。 キー フィールドの種類の変更は許可されていません。

UNKNOWN_INCOMPATIBILITY

キー スキーマが互換性のない方法で変更されました。

UNSAFE_KEY_ALIGNMENT_AFTER_SCALA_MIGRATION

Scala 2.12から2.13へのアップグレード(オペレーター: <operatorType>)によるオペレーターキーアライメント中にキースキーマの変更が検出されました。 <description> サポートされておらず、実行中のクエリが破損する可能性がある。 新しいチェックポイントの場所でクエリを再起動するか、Azure Databricksチームに連絡して支援を求めることを検討してください。