stateful

1熱

2答えて

私は2つのマイクロサービスを持っています1）製品マイクロサービス2）チェックアウトマイクロサービスはどちらもスプリングブートプロジェクトです。 Checkout Microserviceでは、私が買い物したすべての製品を手に入れなければなりません。私のマイクロサービスは以前に何が起こったのかを知るためにはSTATEFULでなければなりません。 Kafka/RabbitMQのイベントソースを使用して

0熱

1答えて

方法

[Route("testApp/{Id}")] [HttpGet] public async Task<List<string>> testApp(Guid Id) { return await new Heavy().WorkOnDictionary(Id); } 私はステートフルなサービスを作成していると私はIReliableDicti

0熱

1答えて

エラー

私はこのようにステートフル畳み込みLSTMを実装する： # build CNN/LSTM and train it. # model = Sequential() # build CNN/LSTM and train it. model.add(TimeDistributed(Conv2D(16, (3, 3), padding='same'), input_shape=(210, 2

1熱

2答えて

Sparkストリーミングアプリケーションを状態の損失なくアップグレードまたは再起動するにはどうすればよいですか？

アプリケーションコードにupdateStateByKey()を使用していますが、このアプリケーションを再起動しても状態を保存します。これは、すべてのバッチのどこかに状態を保存することによって実行できますが、それには時間がかかることがあります。したがって、アプリケーションが停止したときに状態を保存できるソリューションがあるのだろうかと思います。また、現在の状態を失うことなくアプリケーションコー

4熱

1答えて

カスタムアロケータの同じ状態を複数のコンテナに渡すにはどうすればよいですか？

私は割り当てられたバイト数を追跡するいくつかのクラスの別のインスタンスへの参照で、アロケータを書いています。は、私がやろうとしていることの最小限の例です（hereから適応されています）。代わりに、今まで割り当てられたバイトを収集するいくつかのintを参照しました。この参照は、メインの内側に割り当てられますとCustomAllocatorに渡される必要があります。 #include <limi

0熱

1答えて

Spark StreamingでupdateStateByKey（）のようにmapWithState（）を使用できますか？

私はupdateStateByKey（）の代わりにmapWithState（）関数を使用して初期状態を読み込み、タイムアウトを使用しています。しかし、特定のキーの新しい値が消費されたかどうかに関係なく、状態ストア全体を更新する必要があります。これを行う方法はありますか？

1熱

1答えて

ERRORブロードキャストエラーのブロードキャスト例外

スパークストリーミングアプリケーションの実行中に次のエラーが発生しました。大規模なアプリケーションで複数のステートフル（mapWithState）ステートレス操作を実行しています。スパーク自体がハングし、私たちが見る唯一のエラーはアプリケーションログ自体ではなく、スパークログにあるため、エラーを特定することは困難です。エラーは、バッチ処理が4〜5分で、マイクロバッチ間隔が10秒の場合にのみ発生し

1熱

1答えて

メソッドが見つかりません「のIntPtr System.Fabric.SecurityCredentialExtension.ToNative

私は次のデモの例に従うことによって、私のASP.Netのコアにステートフルサービスファブリックを消費しようとしています。残念ながら https://docs.microsoft.com/en-us/azure/service-fabric/service-fabric-add-a-web-frontend を、私は、コードを実行すると、私は次のエラーで終わる午前： Method not found