問題タブ [ignite]

エンティティのフィールドをアノテーションを介して SQL クエリ フィールドの名前にマップする方法はあります@QuerySqlField(name="")が、XML ファイルで定義する方法が見つかりませんでした。たとえば、私はSQLを持っています:Select NAME_, VAL_ from PropertyEntityしかし、フィールドPropertyEntityがnameありますvalue

キャッシュ タイプのメタデータ設定は見つかりましたが、マッピングが見つかりません。

UPD: keyFields プロパティが CacheTypeMetadata に見つかりました。多分それは私が探しているものだと思います

自動永続化を使用してキャッシュを作成し、Mysql データベースに接続しました。起動時に 100 万行がそのノードに取り込まれます。ノードは PARTITIONED モードです

SQL クエリを使用してそのキャッシュからデータを取得しようとすると、常に空の配列が返されます。「CacheTypeMetadata」を使用してキャッシュのインデックスを作成しました。

私が見逃したこと、または間違ったことを誰かが指摘してください。チュートリアルに従っていますが、クエリが正常に機能しない理由がわかりません。

前もって感謝します！

キャッシュ：

DataLoaderMd5Key:

データローダーMd5:

CacheConfigMd5:

クエリ:

Apache ignite で Datagrid Cache を構成しました。クエリ フィールドは を使用して設定されますCacheTypeMetada。しかし、SQL を使用してキャッシュから値を取得できません。

に構成されたクエリ フィールドを変更すると、@QueryIndexType (index = true) クエリは結果を返します。

私の質問は、 CacheTypeMetadata を使用して構成された Cache への SQL クエリ検索を実行するために不足している構成はありますか?

ありがとうございました。

私のコードスニペットを提供します。

CacheConfiguration<TestKey, Test> testCacheCfg = new CacheConfiguration<>(TEST_CACHE);

クエリ フィールドは、CacheTypeMetadata を使用して構成されます。

呼び出されたクエリ:

Apache Igniteでフォールト トレランスを試しています。

私が理解できないのは、失敗したジョブを任意のノードで再試行する方法です。私の仕事は、プロセスビルダーを介してシステムプロセスとしてサードパーティツールを呼び出して計算を行うユースケースがあります。場合によってはツールが失敗することがありますが、ほとんどの場合、以前に失敗したノードを含め、任意のノードでジョブを再試行しても問題ありません。

現時点では、Ignite は以前にこのジョブを持っていなかった別のノードにジョブを再ルーティングしているようです。そのため、しばらくするとすべてのノードがなくなり、タスクは失敗します。

私が探しているのは、任意のノードでジョブを再試行する方法です。

これが私の問題を実証するためのテストです。

これが私のランダムに失敗する仕事です：

以下がタスクです。

テストコード:

ご覧のとおり、常にフェイルオーバーする必要があります。失敗の確率 != 1 なので、ある時点でタスクが正常に終了することを期待しています。

0.5 の確率しきい値と合計 3 つのノードでは、これはほとんど起こりません。のような例外が発生しclass org.apache.ignite.cluster.ClusterTopologyException: Failed to failover a job to another node (failover SPI returned null)ます。いくつかのデバッグの後、これは最終的にノードを使い果たしたためであることがわかりました。全部なくなりました。

これを処理するために自分で書くことができることを理解していFailoverSpiます。

しかし、これはちょうどいいとは思えません。

まず、これを行うのはやり過ぎのようです。
しかし、SPI は一種のグローバルなものです。ジョブごとに、再試行するかフェイルオーバーするかを決定したいと思います。これは、たとえば、呼び出しているサードパーティ ツールの終了コードに依存する場合があります。そのため、グローバル SPI を介したフェイルオーバーの構成は正しくありません。

Apache Ignite ノードを含むクラスターを使用していますが、どうにかしてバイザー GUI バージョンを使用することは可能ですか? Gridgain Gui バージョンを実行すると、Gridgain ノードを ignite ノードで使用すると例外が発生します。エンタープライズ版で有料版ということは理解していますが、試用期間中の可能性を知りたいです。Ignite の代わりに gridgain を使用してシステムを再構築する必要がありますか、それともアダプターなどがありますか?

特定のユースケースで Apache Ignite を評価しています。Ignite 内のキャッシュに 50 GB のデータをロードしようとしています。私はCSV形式のデータを持っています。現在、Java プログラム内のデータを Java Bean の形式で読み取り、Ignite のストリーマー API を使用してキャッシュに Bean を追加しています。別のアプローチ/オプションを探しています。

1. Ignite には、並列化された方法 (CSV の読み取りとキャッシュへの書き込みの両方) で CSV ファイルのデータを一括ロードするために使用できる、すぐに使用できる機能はありますか?
2. Java のクライアント プログラムでストリーマー API を使用してデータをロードしているときに、約 600MB のデータが追加されるとストリーマー オブジェクトが閉じられ、クライアント ノードがクラッシュし、続いて他のノードがクラッシュします。500MB のデータを処理している間、データの読み込みは正常に機能しました。各サーバーで 3 つの物理ノード クラスターと 2 つの Ignite ノード インスタンスを使用しています。

どんな提案も役に立ちます。

GC はメモリとリソースを解放する可能性があります。キャッシュにヒットしたときにオブジェクトを再利用可能にする方法は? Ignite with Spark をデプロイしたいのですが、マルチノード間でオブジェクトを保持することに混乱しています。誰かが私にそれを説明できますか？