Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

IllegalState during event handling of state machine #19

Open
lauritzthamsen opened this issue Jul 10, 2014 · 0 comments
Open

IllegalState during event handling of state machine #19

lauritzthamsen opened this issue Jul 10, 2014 · 0 comments
Labels
bug

Comments

@lauritzthamsen
Copy link
Member

Sometimes threads die unexpectedly during the execution of jobs. In particular, running all three test cases of the IntegrationTest class currently fails sometimes with the following output. The test case does not fail with this problem on every run and not yet once when executing a single test case. It didn't fail with this problem on the CI yet, mostly on my machine.

Seems to be a problem related to the event system and state machine transitions.

2014-07-10 14:31:23,452 |  INFO [Thread-19] (LocalIntegrationTest.java:423) - Submit: Job: 3 layered - point2point + point2point connection - run 1/1
2014-07-10 14:31:23,454 |  INFO [Thread-20] (LocalIntegrationTest.java:423) - Submit: Job: 2 layered - point2point connection - run 1/1
2014-07-10 14:31:23,461 |  INFO [pool-1-thread-1] (WorkloadManager.java:141) - TOPOLOGY 'Job: 3 layered - point2point + point2point connection' SUBMITTED
2014-07-10 14:31:23,461 |  INFO [pool-1-thread-1] (TopologyController.java:96) - ASSEMBLE TOPOLOGY 'Job: 3 layered - point2point + point2point connection'
2014-07-10 14:31:23,463 |  INFO [Thread-21] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TOPOLOGY_STATE_PARALLELIZED
2014-07-10 14:31:23,463 |  INFO [Thread-21] (TopologyController.java:304) - CHANGE STATE OF TOPOLOGY 'Job: 3 layered - point2point + point2point connection' [2bcc0f31-df39-480d-9458-66667f68f6a5] FROM TOPOLOGY_STATE_CREATED TO TOPOLOGY_STATE_PARALLELIZED  [TOPOLOGY_TRANSITION_PARALLELIZE]
2014-07-10 14:31:23,464 |  INFO [Thread-21] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TOPOLOGY_STATE_SCHEDULED
2014-07-10 14:31:23,464 |  INFO [Thread-21] (TopologyController.java:304) - CHANGE STATE OF TOPOLOGY 'Job: 3 layered - point2point + point2point connection' [2bcc0f31-df39-480d-9458-66667f68f6a5] FROM TOPOLOGY_STATE_PARALLELIZED TO TOPOLOGY_STATE_SCHEDULED  [TOPOLOGY_TRANSITION_SCHEDULE]
2014-07-10 14:31:23,470 |  INFO [pool-4-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Sink-0 [d96a6791-d1b5-47c3-8e5f-7b7c59106756] ON EXECUTION UNIT (0) ON MACHINE [dab02f2f-6c5e-47de-b5fd-d7ca93f2589b]
2014-07-10 14:31:23,470 |  INFO [FSM-Sink-0-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,471 |  INFO [FSM-Sink-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [d96a6791-d1b5-47c3-8e5f-7b7c59106756] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,472 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Sink]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = d96a6791-d1b5-47c3-8e5f-7b7c59106756,  name = Sink },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 30e6c492-401c-4ec7-9097-cbfe57163e7c,  name = Middle }]],  outputGates = [] } }
2014-07-10 14:31:23,472 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,481 |  INFO [pool-7-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Sink-1 [0b3b1d7d-edce-448a-9e3d-1f6daaa0deac] ON EXECUTION UNIT (0) ON MACHINE [d511f745-09c1-477c-a15e-9dbc4fe33819]
2014-07-10 14:31:23,481 |  INFO [FSM-Sink-1-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,482 |  INFO [FSM-Sink-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [0b3b1d7d-edce-448a-9e3d-1f6daaa0deac] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,483 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Sink]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = 0b3b1d7d-edce-448a-9e3d-1f6daaa0deac,  name = Sink },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = e4fdc2c8-dda9-4102-9da6-b5f9ae83efde,  name = Middle }]],  outputGates = [] } }
2014-07-10 14:31:23,484 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,491 |  INFO [pool-4-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Middle-1 [30e6c492-401c-4ec7-9097-cbfe57163e7c] ON EXECUTION UNIT (1) ON MACHINE [dab02f2f-6c5e-47de-b5fd-d7ca93f2589b]
2014-07-10 14:31:23,493 |  INFO [TaskDriver-Middle-1-EventDispatcher] (TaskDataProducer.java:393) - OUTPUT CONNECTION FROM Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] TO TASK Sink [d96a6791-d1b5-47c3-8e5f-7b7c59106756] IS ESTABLISHED
2014-07-10 14:31:23,493 |  INFO [FSM-Middle-1-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,494 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Middle]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 30e6c492-401c-4ec7-9097-cbfe57163e7c,  name = Middle },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 69526009-8518-438c-86e6-cf00d751e18a,  name = Source }]],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = d96a6791-d1b5-47c3-8e5f-7b7c59106756,  name = Sink }]] } }
2014-07-10 14:31:23,494 |  INFO [TaskDriver-Sink-0-EventDispatcher] (TaskDataConsumer.java:551) - INPUT CONNECTION FROM Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] TO TASK Sink [d96a6791-d1b5-47c3-8e5f-7b7c59106756] IS ESTABLISHED
2014-07-10 14:31:23,494 |  INFO [FSM-Middle-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,497 |  INFO [FSM-Sink-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [d96a6791-d1b5-47c3-8e5f-7b7c59106756] FROM TASK_STATE_OUTPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,499 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,500 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,504 |  INFO [pool-7-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Middle-0 [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] ON EXECUTION UNIT (1) ON MACHINE [d511f745-09c1-477c-a15e-9dbc4fe33819]
2014-07-10 14:31:23,506 |  INFO [TaskDriver-Middle-0-EventDispatcher] (TaskDataProducer.java:393) - OUTPUT CONNECTION FROM Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] TO TASK Sink [0b3b1d7d-edce-448a-9e3d-1f6daaa0deac] IS ESTABLISHED
2014-07-10 14:31:23,506 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Middle]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = e4fdc2c8-dda9-4102-9da6-b5f9ae83efde,  name = Middle },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = 6ac103d9-0483-4a17-8fe2-14859a9834df,  name = Source }]],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = 0b3b1d7d-edce-448a-9e3d-1f6daaa0deac,  name = Sink }]] } }
2014-07-10 14:31:23,506 |  INFO [TaskDriver-Sink-1-EventDispatcher] (TaskDataConsumer.java:551) - INPUT CONNECTION FROM Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] TO TASK Sink [0b3b1d7d-edce-448a-9e3d-1f6daaa0deac] IS ESTABLISHED
2014-07-10 14:31:23,506 |  INFO [FSM-Middle-0-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,509 |  INFO [FSM-Middle-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,510 |  INFO [FSM-Sink-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [0b3b1d7d-edce-448a-9e3d-1f6daaa0deac] FROM TASK_STATE_OUTPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,511 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,512 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,516 |  INFO [pool-4-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Source-1 [69526009-8518-438c-86e6-cf00d751e18a] ON EXECUTION UNIT (2) ON MACHINE [dab02f2f-6c5e-47de-b5fd-d7ca93f2589b]
2014-07-10 14:31:23,516 |  INFO [FSM-Source-1-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_INPUTS_CONNECTED
2014-07-10 14:31:23,517 |  INFO [FSM-Source-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Source [69526009-8518-438c-86e6-cf00d751e18a] FROM TASK_STATE_CREATED TO TASK_STATE_INPUTS_CONNECTED  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,518 |  INFO [TaskDriver-Source-1-EventDispatcher] (TaskDataProducer.java:393) - OUTPUT CONNECTION FROM Source [69526009-8518-438c-86e6-cf00d751e18a] TO TASK Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] IS ESTABLISHED
2014-07-10 14:31:23,518 |  INFO [TaskDriver-Middle-1-EventDispatcher] (TaskDataConsumer.java:551) - INPUT CONNECTION FROM Source [69526009-8518-438c-86e6-cf00d751e18a] TO TASK Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] IS ESTABLISHED
2014-07-10 14:31:23,519 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Source]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 69526009-8518-438c-86e6-cf00d751e18a,  name = Source },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 30e6c492-401c-4ec7-9097-cbfe57163e7c,  name = Middle }]] } }
2014-07-10 14:31:23,520 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,523 |  INFO [FSM-Middle-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Middle [30e6c492-401c-4ec7-9097-cbfe57163e7c] FROM TASK_STATE_OUTPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,524 |  INFO [FSM-Source-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Source [69526009-8518-438c-86e6-cf00d751e18a] FROM TASK_STATE_INPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,526 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,526 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,533 |  INFO [pool-7-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Source-0 [6ac103d9-0483-4a17-8fe2-14859a9834df] ON EXECUTION UNIT (2) ON MACHINE [d511f745-09c1-477c-a15e-9dbc4fe33819]
2014-07-10 14:31:23,534 |  INFO [FSM-Source-0-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_INPUTS_CONNECTED
2014-07-10 14:31:23,534 |  INFO [FSM-Source-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Source [6ac103d9-0483-4a17-8fe2-14859a9834df] FROM TASK_STATE_CREATED TO TASK_STATE_INPUTS_CONNECTED  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,535 |  INFO [TaskDriver-Source-0-EventDispatcher] (TaskDataProducer.java:393) - OUTPUT CONNECTION FROM Source [6ac103d9-0483-4a17-8fe2-14859a9834df] TO TASK Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] IS ESTABLISHED
2014-07-10 14:31:23,535 |  INFO [TaskDriver-Middle-0-EventDispatcher] (TaskDataConsumer.java:551) - INPUT CONNECTION FROM Source [6ac103d9-0483-4a17-8fe2-14859a9834df] TO TASK Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] IS ESTABLISHED
2014-07-10 14:31:23,536 |  INFO [pool-1-thread-1] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Source]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = 6ac103d9-0483-4a17-8fe2-14859a9834df,  name = Source },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = e4fdc2c8-dda9-4102-9da6-b5f9ae83efde,  name = Middle }]] } }
2014-07-10 14:31:23,537 |  INFO [FSM-Middle-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Middle [e4fdc2c8-dda9-4102-9da6-b5f9ae83efde] FROM TASK_STATE_OUTPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_INPUTS_CONNECTED]
2014-07-10 14:31:23,537 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,537 |  INFO [FSM-Source-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Source [6ac103d9-0483-4a17-8fe2-14859a9834df] FROM TASK_STATE_INPUTS_CONNECTED TO TASK_STATE_READY  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,539 |  INFO [pool-1-thread-2] (WorkloadManager.java:141) - TOPOLOGY 'Job: 2 layered - point2point connection' SUBMITTED
2014-07-10 14:31:23,539 | ERROR [Thread-21] (EventDispatcher.java:326) - 
java.lang.IllegalStateException
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:383)
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:379)
    at de.tuberlin.aura.core.common.statemachine.StateMachine$FiniteStateMachine$3.handleEvent(StateMachine.java:551)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.dispatch(EventDispatcher.java:324)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.access$300(EventDispatcher.java:23)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher$1.run(EventDispatcher.java:91)
    at java.lang.Thread.run(Thread.java:745)
2014-07-10 14:31:23,541 |  INFO [pool-1-thread-2] (TopologyController.java:96) - ASSEMBLE TOPOLOGY 'Job: 2 layered - point2point connection'
2014-07-10 14:31:23,543 | ERROR [Thread-21] (NIOServerCnxnFactory.java:44) - Thread Thread[Thread-21,5,main] died
java.lang.IllegalStateException
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:383)
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:379)
    at de.tuberlin.aura.core.common.statemachine.StateMachine$FiniteStateMachine$3.handleEvent(StateMachine.java:551)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.dispatch(EventDispatcher.java:324)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.access$300(EventDispatcher.java:23)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher$1.run(EventDispatcher.java:91)
    at java.lang.Thread.run(Thread.java:745)
2014-07-10 14:31:23,543 | ERROR [Thread-21] (NIOServerCnxnFactory.java:44) - Thread Thread[Thread-21,5,main] died
java.lang.IllegalStateException
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:383)
    at de.tuberlin.aura.workloadmanager.TopologyController$10.stateAction(TopologyController.java:379)
    at de.tuberlin.aura.core.common.statemachine.StateMachine$FiniteStateMachine$3.handleEvent(StateMachine.java:551)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.dispatch(EventDispatcher.java:324)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher.access$300(EventDispatcher.java:23)
    at de.tuberlin.aura.core.common.eventsystem.EventDispatcher$1.run(EventDispatcher.java:91)
    at java.lang.Thread.run(Thread.java:745)
2014-07-10 14:31:23,545 |  INFO [Thread-28] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TOPOLOGY_STATE_PARALLELIZED
2014-07-10 14:31:23,547 |  INFO [Thread-28] (TopologyController.java:304) - CHANGE STATE OF TOPOLOGY 'Job: 2 layered - point2point connection' [ab5f70fc-6046-4dae-a84f-5956e7173f84] FROM TOPOLOGY_STATE_CREATED TO TOPOLOGY_STATE_PARALLELIZED  [TOPOLOGY_TRANSITION_PARALLELIZE]
2014-07-10 14:31:23,548 |  INFO [Thread-28] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TOPOLOGY_STATE_SCHEDULED
2014-07-10 14:31:23,548 |  INFO [Thread-28] (TopologyController.java:304) - CHANGE STATE OF TOPOLOGY 'Job: 2 layered - point2point connection' [ab5f70fc-6046-4dae-a84f-5956e7173f84] FROM TOPOLOGY_STATE_PARALLELIZED TO TOPOLOGY_STATE_SCHEDULED  [TOPOLOGY_TRANSITION_SCHEDULE]
2014-07-10 14:31:23,553 |  INFO [pool-4-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Sink-1 [0cc56dd6-bde4-46a6-b681-71677f0f350b] ON EXECUTION UNIT (3) ON MACHINE [dab02f2f-6c5e-47de-b5fd-d7ca93f2589b]
2014-07-10 14:31:23,553 |  INFO [FSM-Sink-1-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,553 |  INFO [FSM-Sink-1-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [0cc56dd6-bde4-46a6-b681-71677f0f350b] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,554 |  INFO [pool-1-thread-2] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Sink]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 0cc56dd6-bde4-46a6-b681-71677f0f350b,  name = Sink },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = f294dab8-b39f-4f02-8dce-a0b761b195a8,  name = Source }]],  outputGates = [] } }
2014-07-10 14:31:23,555 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,562 |  INFO [pool-7-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Sink-0 [db77ca68-ae7a-4c99-9968-7d586071c6a7] ON EXECUTION UNIT (3) ON MACHINE [d511f745-09c1-477c-a15e-9dbc4fe33819]
2014-07-10 14:31:23,562 |  INFO [FSM-Sink-0-EventDispatcher] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TASK_STATE_OUTPUTS_CONNECTED
2014-07-10 14:31:23,563 |  INFO [FSM-Sink-0-EventDispatcher] (TaskDriver.java:391) - CHANGE STATE OF TASK Sink [db77ca68-ae7a-4c99-9968-7d586071c6a7] FROM TASK_STATE_CREATED TO TASK_STATE_OUTPUTS_CONNECTED  [TASK_TRANSITION_OUTPUTS_CONNECTED]
2014-07-10 14:31:23,564 |  INFO [pool-1-thread-2] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Sink]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = db77ca68-ae7a-4c99-9968-7d586071c6a7,  name = Sink },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = fc5e321e-114a-4613-9d02-e4a78034e8c3,  name = Source }]],  outputGates = [] } }
2014-07-10 14:31:23,564 |  INFO [TopologyControllerEventDispatcher] (EventDispatcher.java:331) - no listener registered for event CONTROL_EVENT_REMOTE_TASK_STATE_UPDATE
2014-07-10 14:31:23,571 |  INFO [pool-4-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Source-1 [f294dab8-b39f-4f02-8dce-a0b761b195a8] ON EXECUTION UNIT (0) ON MACHINE [dab02f2f-6c5e-47de-b5fd-d7ca93f2589b]
2014-07-10 14:31:23,573 |  INFO [pool-1-thread-2] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Source]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = f294dab8-b39f-4f02-8dce-a0b761b195a8,  name = Source },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = dab02f2f-6c5e-47de-b5fd-d7ca93f2589b,  netAddress = /141.23.109.200:55425,  controlAddress = /141.23.109.200:55426, HardwareDescriptor = { uid = 6ea8d352-2350-4bd1-8950-b9c533e6e6e7,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = 69f4ede3-d04a-4471-9e62-525989e6bdd2,  sizeOfHDD = 250140434432 } } },  uid = 0cc56dd6-bde4-46a6-b681-71677f0f350b,  name = Sink }]] } }
2014-07-10 14:31:23,581 |  INFO [pool-7-thread-1] (TaskExecutionManager.java:106) - EXECUTE TASK Source-0 [fc5e321e-114a-4613-9d02-e4a78034e8c3] ON EXECUTION UNIT (0) ON MACHINE [d511f745-09c1-477c-a15e-9dbc4fe33819]
2014-07-10 14:31:23,582 |  INFO [pool-1-thread-2] (TopologyDeployer.java:86) - TASK DEPLOYMENT DESCRIPTOR [Source]: DeploymentDescriptor = { nodeDescriptor = AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = fc5e321e-114a-4613-9d02-e4a78034e8c3,  name = Source },  nodeBindingDescriptor = NodeBindingDescriptor = { inputGates = [],  outputGates = [[AbstractNodeDescriptor = { machine = MachineDescriptor = { uid = d511f745-09c1-477c-a15e-9dbc4fe33819,  netAddress = /141.23.109.200:55430,  controlAddress = /141.23.109.200:55431, HardwareDescriptor = { uid = 8e0159a6-fb1b-492c-9005-2113a7b8432a,  cpuCores = 4,  sizeOfRAM = 1908932608, HDDDescriptor = { uid = f182db85-a1e9-4182-9796-d2655f14eb1d,  sizeOfHDD = 250140434432 } } },  uid = db77ca68-ae7a-4c99-9968-7d586071c6a7,  name = Sink }]] } }
2014-07-10 14:31:23,584 |  INFO [Thread-28] (EventDispatcher.java:331) - no listener registered for event FSM_STATE_EVENT_TOPOLOGY_STATE_DEPLOYED
2014-07-10 14:31:23,584 |  INFO [Thread-28] (TopologyController.java:304) - CHANGE STATE OF TOPOLOGY 'Job: 2 layered - point2point connection' [ab5f70fc-6046-4dae-a84f-5956e7173f84] FROM TOPOLOGY_STATE_SCHEDULED TO TOPOLOGY_STATE_DEPLOYED  [TOPOLOGY_TRANSITION_DEPLOY]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@lauritzthamsen