Realtime Compute for Apache Flink：30 November 2025

Fitur AI

Fungsi AI baru ditambahkan untuk pemrosesan teks dalam Flink SQL:

• Klasifikasi teks: Mengklasifikasikan teks berdasarkan kategori yang telah ditentukan dan mengembalikan skor kepercayaan. Fungsi ini cocok untuk kategorisasi tiket dan pelabelan konten.

• Analisis sentimen: Menganalisis sentimen teks dan mengembalikan skor kuantitatif dengan label positif, negatif, atau netral. Fungsi ini cocok untuk analisis komentar dan pemantauan opini publik.

• Ekstraksi informasi: Mengekstraksi data, seperti nama dan nomor telepon, dari teks tak terstruktur menggunakan skema JSON dan menghasilkan data dalam format terstruktur.

• Ringkasan teks: Menghasilkan ringkasan dari teks panjang. Anda dapat menetapkan panjang maksimum untuk ringkasan tersebut.

• Vektorisasi teks: Membuat representasi vektor berdimensi tinggi dari teks. Vektor ini memungkinkan perhitungan kemiripan dan pengambilan semantik.

• Terjemahan teks: Menerjemahkan teks antar lebih dari 10 bahasa dan secara otomatis mendeteksi bahasa sumber.

• Penyembunyian data: Secara otomatis menyembunyikan informasi sensitif, seperti nomor telepon dan nomor KTP, dalam teks.

Ingesti Data

• Kompatibilitas: Selaras dengan Apache Flink CDC 3.5.

• PostgreSQL CDC (pratinjau publik): Mendukung sumber PostgreSQL.

• MongoDB: Mendukung sumber MongoDB.

Konektor

• Kafka:

  • Format Canal-JSON kini mendukung penguraian event indeks database sumber. Anda juga dapat mengambil kunci dan nilai asli sebagai metadata.

  • Mendukung Protocol Buffers v3 (proto3).

• Hologres:

  • Lookup join tabel dimensi mendukung filter pushdown.

  • Stream Copy mendukung format BinaryRow.

  • Mendukung konfigurasi strategi konflik kunci primer untuk operasi INSERT.

• JDBC (PostgreSQL): Menambahkan opsi ignore delete untuk mengabaikan event penghapusan dari tabel sumber.

• Paimon:

  • Mendukung pembaruan lintas partisi.

  • Mendukung awalan username untuk memudahkan pelacakan pekerjaan.

• Redis: Meningkatkan dukungan untuk instans kluster dan penulisan batch.

Katalog

• Katalog PostgreSQL: Memperkenalkan katalog PostgreSQL untuk mengelola metadata PostgreSQL.

• Katalog StarRocks: Mendukung perlakuan kolom kunci primer yang nullable di StarRocks sebagai non-nullable.

• Katalog MaxCompute: Mendukung pemetaan database ke proyek atau skema MaxCompute.

Fitur Inti

1. Kloning namespace: Salin namespace ke ruang kerja lain. Fitur ini cocok untuk migrasi kluster dan pengujian dual-run.

2. Perubahan layanan pemantauan: Ubah layanan pemantauan untuk ruang kerja Anda secara manual di konsol.

3. Kontrol akses:

   • Konfigurasikan titik izin 'disabled'.

   • Tetapkan izin granular untuk integrasi Git.

4. Arsip log: Arsipkan log ke SLS melalui RAM, bukan melalui Pasangan Kunci Akses, untuk meningkatkan keamanan.

Pengalaman Pengguna

• O&M: Halaman O&M kini menampilkan status dan hasil pembaruan dinamis serta tuning otomatis.

• Tag penagihan: Di ruang kerja dengan penagihan hibrida, resource secara otomatis diberi tag subscription atau pay-as-you-go untuk mempermudah penagihan terpisah.

• Pencarian resource: Cari resource berdasarkan ruang kerja, ID ruang kerja, atau namespace.