問題タブ [rocksdb]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-kafka - Kafka ストリーム - 低レベル プロセッサ API - RocksDB TimeToLive(TTL)
低レベルのプロセッサ API を試しているようなものです。プロセッサ API を使用して着信レコードのデータ集計を行い、集計されたレコードを RocksDB に書き込みます。
ただし、rocksdb に追加されたレコードを 24 時間のみアクティブにするために保持したいと考えています。24 時間後に記録を削除する必要があります。これは、ttl 設定を変更することで実行できます。ただし、これに関するヘルプが得られるドキュメントはあまりありません。
ttl 値を変更するにはどうすればよいですか? ttl 時間を 24 時間に設定するには、どの Java API を使用する必要がありますか?また、現在のデフォルトの ttl 設定時間は何ですか?
apache-flink - エンディアンの不一致により、Flink RocksDB 状態バックエンドを使用できません
私の Flink ジョブは、クエリ可能な状態を利用するために、kafka トピックから読み取り、データを RocksDB 状態バックエンドに保存します。ローカル マシンでジョブを実行し、状態を照会できます。しかし、クラスターにデプロイすると、次のエラーが発生します。
クラスタ レベルとジョブ レベルで rocksDB 状態バックエンドを設定しようとしました。ジョブ レベルで設定されている場合は、影付きの依存関係として提供しています。ホスト クラスタ マシンでもコードをコンパイルしてみました。すべてのケースで同じエラーが発生します。
このエラーを解決するにはどうすればよいですか?