2016-08-26 9 views
1

AmazonのJavaベースのHelloWorldWorkflowDistributedの例から始めましたが、私たちが望むものを達成するために少しずつ追加しています。私は2番目のアクティビティワーカーを追加しましたが、2つのアクティビティはお互いのタスクを受け取り、タスクは達成されていません。誰かが、2人以上の別個の作業者を呼び出すワークフローの完全な作業例に誰かを指摘できますか?
など。 BarActivities.getNameが実行されているコンソールに次のエラーが表示されます。逆の場合も同様です。Amazon SWF:間違ったタスクを受け取ったJavaアクティビティワーカー

Aug 26, 2016 2:15:24 PM com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller execute 
SEVERE: Failure processing activity task with taskId=10, workflowGenerationId=id_for_107, activity={Name: FooActivities.getAddress,Version: 1.0.7}, activityInstanceId=1 
com.amazonaws.services.simpleworkflow.flow.ActivityFailureException: Unknown activity type: {Name: FooActivities.getAddress,Version: 1.0.7} : null 
    at com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller.execute(SynchronousActivityTaskPoller.java:194) 
    at com.amazonaws.services.simpleworkflow.flow.worker.ActivityTaskPoller$2.run(ActivityTaskPoller.java:92) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 

答えて

0

アクティビティ作業者がタスクリストを使用してポーリングを行います。私はあなたがその活動のために別の仕事リストを使わずに新しい労働者を加えたと信じています。両方のワーカーが同じタスクリストを共有しているため、「未知のアクティビティタイプ」例外の結果となる、サポートしていないアクティビティのタスクを受け取ることがあります。解決策は、各作業者ごとに異なるタスクリストを使用することです。

+1

ああ、それは今動作しています。ありがとうございました。私はすでにそれを試していたと思っていて、何の仕事も受けていないかのように失敗しましたが、何かが間違っていたはずです。 – MartinThurn

関連する問題