Ververica Runtime (VVR) の Realtime Compute for Apache Flink 向け新エンジンバージョンである VVR 8.0.5 が、2024年1月4日にリリースされました。本リリースは、Apache Flink 1.17.2 を基盤とするエンタープライズレベルの Flink エンジンであり、コネクタの更新、パフォーマンス向上、およびバグ修正を含みます。
重要
本バージョンはカナリアリリースとして段階的に展開されます。ご利用の Flink 完全管理環境で新機能がまだ利用できない場合、アカウントへのアップグレードは完了していません。早期アップグレードをご希望の場合は、チケットを送信してください。展開状況の確認については、Realtime Compute for Apache Flink コンソールのホームページに掲載される最新のお知らせをご確認ください。
概要
VVR 8.0.5 では、複数のコネクタに対する更新が提供され、Apache Flink 1.17.2 から継承された不具合（Apache Flink コミュニティによる修正を含む）が解消されています。また、エンジン固有の安定性向上も実施されています。
カナリアリリースの展開が完了次第、デプロイメントを本バージョンへアップグレードしてください。手順については、「デプロイメントのエンジンバージョンのアップグレード」をご参照ください。
特徴
| 特徴 | 変更内容 | 関連ドキュメント |
|---|---|---|
| MySQL CDC：開始オフセットまたはタイムスタンプの指定 | MySQL Change Data Capture (CDC) ソーステーブルからの読み取りにおいて、開始オフセットまたはタイムスタンプを指定できるようになりました。これにより、読み取り位置を直接特定でき、データ読み取り速度が向上します。 | MySQL コネクタ |
| MongoDB コネクタ：ソーステーブルのスキーマ同期および自動カラム追加 | MongoDB コネクタをソーステーブルに使用する場合、CREATE TABLE AS 文または CREATE DATABASE AS 文により、ソーステーブルから結果テーブルへスキーマ変更が同期され、カラムが自動的に追加されます。 | CREATE TABLE AS 文、CREATE DATABASE AS 文 |
| MongoDB コネクタ：ディメンションテーブル対応 | MongoDB コネクタをディメンションテーブルとして使用可能となり、結合クエリが可能になりました。 | MongoDB コネクタ（パブリックプレビュー） |
| MongoDB カタログ対応 | MongoDB カタログを使用してメタデータを登録することで、コレクションのスキーマを自動的に推論できます。これにより、SQL で MongoDB ソーステーブルを作成する際に DDL 文を記述する必要がなくなります。 | MongoDB カタログの管理（パブリックプレビュー） |
| JDBC コネクタ：JSONB および UUID 型のサポート | JDBC コネクタが、JSONB および UUID 拡張型のデータをサポートするようになりました。 | JDBC コネクタ |
| Hologres コネクタ：SSL 暗号化通信 | データの読み取りおよび書き込みにおいて、より安全な通信を実現するため、SSL 暗号化通信が採用されました。 | Hologres コネクタ |
| Hologres コネクタ：バルクロードモード | バルクロードモードでデータを書き込むことで、Hologres 結果テーブルへの書き込みワークロードが大幅に削減されます。 | Hologres コネクタ |
| Hologres コネクタ：バッチ処理時の重複排除 | sdkMode を jdbc または jdbc_fixed に設定した場合、バッチデータ処理時に重複排除が可能になります。これにより、データ整合性およびデータベースパフォーマンスが向上し、ネットワークオーバーヘッドが低減します。 | Hologres コネクタ |
Hologres コネクタ：jdbcBinlogSlotName パラメーターの削除 | Hologres V2.1 以降では、jdbcBinlogSlotName パラメーターの設定は不要となりました。本パラメーターは、JDBC モードにおけるバイナリログソーステーブルのスロット名を指定するものでした。 | Hologres コネクタHologres コネクタを使用した Hologres データのリアルタイム利用 |
| 新規 PolarDB for Oracle 1.0 コネクタ | PolarDB for Oracle 1.0 コネクタが利用可能になりました。本コネクタを使用して、PolarDB for PostgreSQL（Oracle 互換）へデータを書き込めます。 | PolarDB for Oracle 1.0 コネクタ |
| StarRocks コネクタ：JSON 型のサポート | StarRocks 結果テーブルが、JSON 型のデータをサポートするようになりました。 | 該当なし |
ApsaraMQ for RocketMQ：partitionField パラメーター | ApsaraMQ for RocketMQ 結果テーブルで partitionField パラメーターを設定することにより、特定のフィールドをパーティションキー列として指定できます。ハッシュ値が同一のデータは、同一パーティションへ書き込まれます。 | ApsaraMQ for RocketMQ コネクタ |
| Elasticsearch コネクタ：V8.X 対応 | Elasticsearch コネクタが、Elasticsearch V8.X の結果テーブルへの書き込みをサポートするようになりました。 | Elasticsearch コネクタ |
Elasticsearch コネクタ：ignoreKeywordSuffix パラメーター | Elasticsearch コネクタをディメンションテーブルに使用する場合、ignoreKeywordSuffix を true に設定すると、TEXT データの型のフィールドに対して .keyword サフィックスが無視されます。 | Elasticsearch コネクタ |
| MySQL コネクタ：NULL 値の処理 | MySQL 結果テーブルへの更新時における NULL 値を、無視できるようになりました。 | MySQL コネクタ |