Kondisi kesalahan STREAMING_QUERY_EVOLUTION_ERROR

SQLSTATE: 42000

Kesalahan pada evolusi kueri streaming:

DUPLICATE_SOURCE_NAMES

Nama sumber streaming duplikat terdeteksi: <duplicateNames>. Setiap sumber streaming harus memiliki nama yang unik. Pastikan semua sumber memiliki nama yang berbeda menggunakan metode name().

INVALID_SINK_NAME

Nama sink streaming tidak valid: '<sinkName>'. Nama sink hanya boleh berisi ASCII huruf ('a'-'z', 'A'-'Z'), digit ('0'-'9'), dan garis bawah ('_') .

INVALID_SOURCE_NAME

Nama sumber streaming tidak valid: '<sourceName>'. Nama sumber hanya boleh berisi ASCII huruf ('a'-'z', 'A'-'Z'), digit ('0'-'9'), dan garis bawah ('_') . Gunakan backtick untuk mengutip nama dengan karakter khusus jika diperlukan.

SUMBER_BERDASARKAN_NAMA_MEMBUTUHKAN_PENEGAKAN

Tidak dapat menggunakan metode name() untuk memberi nama sumber streaming ketika spark.sql.streaming.queryEvolution.enableSourceEvolution dinonaktifkan. Harap aktifkan evolusi sumber dengan mengatur spark.sql.streaming.queryEvolution.enableSourceEvolution ke true, atau hapus panggilan name().

NAMED_SOURCES_REQUIRE_OFFSET_LOG_V2

Penerapan sumber streaming yang dinamai memerlukan format log offset V2 (OffsetMap), tetapi ditemukan V<version>. Format V2 menggunakan pasangan sourceId:offset yang mendukung evolusi sumber daya. Atur spark.sql.streaming.offsetLog.version ke 2, atau nonaktifkan penegakan sumber bernama dengan mengatur spark.sql.streaming.queryEvolution.enableSourceEvolution ke false

ID_SINK_DIULANG

Tidak dapat menggunakan kembali nama simpul '<sinkId>' di lokasi titik pemeriksaan <checkpointLocation>. Nama sink ini sebelumnya digunakan dan kemudian diganti dengan sink yang berbeda. Menggunakan kembali nama sink yang tidak aktif dapat menyebabkan masalah keakuratan data. Untuk menggunakan sink baru, tetapkan nama yang berbeda menggunakan metode name() pada DataStreamWriter (misalnya, .name("my_new_sink")).

SINK_PROVIDER_MISMATCH

Tidak dapat mengubah penyedia sink untuk sink '<sinkId>' di lokasi titik pemeriksaan <checkpointLocation>. Sink sebelumnya menggunakan penyedia '<previousProvider>' tetapi sekarang menggunakan '<currentProvider>'. Mengubah jenis sink sambil mempertahankan nama sink yang sama dapat menyebabkan masalah kebenaran data. Untuk menggunakan jenis sink baru, tetapkan nama yang berbeda menggunakan metode name() pada DataStreamWriter (misalnya, .name("my_new_sink")).

TOMBSTONE_SOURCE_NAME_REUSE

Tidak dapat menggunakan kembali nama sumber yang telah dihapus atau ditandai sebagai tidak digunakan: <sourceNames>. Nama sumber ini sebelumnya digunakan dan kemudian dihapus dari kueri streaming di lokasi titik pemeriksaan <checkpointLocation>. Menggunakan kembali nama sumber yang dikubur dapat menyebabkan masalah kebenaran data. Silakan gunakan nama sumber yang berbeda.

SINKS_STREAMING_TIDAK_BERNAMA_DENGAN_PENEGAKAN

Sink streaming harus diberi nama ketika spark.sql.streaming.queryEvolution.enableSinkEvolution diaktifkan. Gunakan metode name() pada DataStreamWriter untuk menetapkan nama ke sink streaming.

SUMBER_STREAMING_TANPA_NAMA_DENGAN_PENEGAKAN

Semua sumber streaming harus diberi nama saat spark.sql.streaming.queryEvolution.enableSourceEvolution diaktifkan. Sumber yang tidak disebutkan namanya ditemukan: <sourceInfo>. Gunakan metode name() untuk menetapkan nama ke semua sumber streaming.