[
https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868895#comment-17868895
]
Sagar Rao edited comment on KAFKA-8115 at 7/26/24 8:52 AM:
-----------------------------------------------------------
Failed again in
[this|https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16628/5/#showFailuresLink]
build.
{code:java}
java.util.concurrent.TimeoutException:
testTaskRequestWithOldStartMsGetsUpdated() timed out after 240 seconds at
java.base/java.util.ArrayList.forEach(ArrayList.java:1596) at
java.base/java.util.ArrayList.forEach(ArrayList.java:1596) Suppressed:
java.lang.InterruptedException at
java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1765)
at
java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475)
at
java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:780)
at
org.apache.kafka.trogdor.coordinator.TaskManager.waitForShutdown(TaskManager.java:686)
at
org.apache.kafka.trogdor.coordinator.Coordinator.waitForShutdown(Coordinator.java:131)
at
org.apache.kafka.trogdor.common.MiniTrogdorCluster.close(MiniTrogdorCluster.java:288)
at
org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated(CoordinatorTest.java:594)
at java.base/java.lang.reflect.Method.invoke(Method.java:580) ... 2 more
{code}
was (Author: sagarrao):
Failed again in
[this|https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16628/5/#showFailuresLink]
build.
```
java.util.concurrent.TimeoutException:
testTaskRequestWithOldStartMsGetsUpdated() timed out after 240 seconds at
java.base/java.util.ArrayList.forEach(ArrayList.java:1596) at
java.base/java.util.ArrayList.forEach(ArrayList.java:1596) Suppressed:
java.lang.InterruptedException at
java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1765)
at
java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475)
at
java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:780)
at
org.apache.kafka.trogdor.coordinator.TaskManager.waitForShutdown(TaskManager.java:686)
at
org.apache.kafka.trogdor.coordinator.Coordinator.waitForShutdown(Coordinator.java:131)
at
org.apache.kafka.trogdor.common.MiniTrogdorCluster.close(MiniTrogdorCluster.java:288)
at
org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated(CoordinatorTest.java:594)
at java.base/java.lang.reflect.Method.invoke(Method.java:580) ... 2 more
```
> Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated
> -------------------------------------------------------------------
>
> Key: KAFKA-8115
> URL: https://issues.apache.org/jira/browse/KAFKA-8115
> Project: Kafka
> Issue Type: Bug
> Components: core, unit tests
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Assignee: Greg Harris
> Priority: Critical
> Labels: flaky-test
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/3254/testReport/junit/org.apache.kafka.trogdor.coordinator/CoordinatorTest/testTaskRequestWithOldStartMsGetsUpdated/]
> {quote}org.junit.runners.model.TestTimedOutException: test timed out after
> 120000 milliseconds at [email protected]/jdk.internal.misc.Unsafe.park(Native
> Method) at
> [email protected]/java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234)
> at
> [email protected]/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123)
> at
> [email protected]/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
> at
> [email protected]/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
> at
> app//org.apache.kafka.trogdor.rest.JsonRestServer.waitForShutdown(JsonRestServer.java:157)
> at app//org.apache.kafka.trogdor.agent.Agent.waitForShutdown(Agent.java:123)
> at
> app//org.apache.kafka.trogdor.common.MiniTrogdorCluster.close(MiniTrogdorCluster.java:285)
> at
> app//org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated(CoordinatorTest.java:596)
> at
> [email protected]/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method) at
> [email protected]/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> [email protected]/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at [email protected]/java.lang.reflect.Method.invoke(Method.java:566) at
> app//org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> at
> app//org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> app//org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> at
> app//org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> app//org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
> at
> app//org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
> at [email protected]/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at [email protected]/java.lang.Thread.run(Thread.java:834){quote}
> STDOUT
> {quote}[2019-03-15 09:23:41,364] INFO Creating MiniTrogdorCluster with
> agents: node02 and coordinator: node01
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:135) [2019-03-15
> 09:23:41,595] INFO Logging initialized @13340ms to
> org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)
> [2019-03-15 09:23:41,752] INFO Starting REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:89) [2019-03-15 09:23:41,912]
> INFO Registered resource
> org.apache.kafka.trogdor.agent.AgentRestResource@3fa38ceb
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:23:42,178]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:23:42,360] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:23:42,362] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:23:42,370] INFO node0 Scavenging every 660000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:23:44,412] INFO Started
> o.e.j.s.ServletContextHandler@335a5293\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:23:44,473] INFO Started
> ServerConnector@79a93bf1\{HTTP/1.1,[http/1.1]}{0.0.0.0:33477}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:23:44,474]
> INFO Started @16219ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:23:44,475] INFO REST server listening at [http://127.0.1.1:33477/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:23:44,484]
> INFO Starting REST server (org.apache.kafka.trogdor.rest.JsonRestServer:89)
> [2019-03-15 09:23:44,485] INFO Registered resource
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource@2e06ee92
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:23:44,486]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:23:44,536] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:23:44,537] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:23:44,537] INFO node0 Scavenging every 600000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:23:44,901] INFO Started
> o.e.j.s.ServletContextHandler@742ebd90\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:23:44,912] INFO Started
> ServerConnector@1fcfcaee\{HTTP/1.1,[http/1.1]}{0.0.0.0:33468}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:23:44,913]
> INFO Started @16658ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:23:44,914] INFO REST server listening at [http://127.0.1.1:33468/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:23:44,952]
> INFO Created TaskManager for agent(s) on: node01, node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:144) [2019-03-15
> 09:23:44,959] DEBUG Sending POST with input
> \{"id":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to [http://localhost:33468/coordinator/task/create]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:45,471] TRACE Scheduling
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@5b39f9b3 for 1 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:45,472] INFO Created a new task foo with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},
> scheduled to start 1 ms from now.
> (org.apache.kafka.trogdor.coordinator.TaskManager:366) [2019-03-15
> 09:23:45,584] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks/foo]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:45,624] INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000] "POST
> /coordinator/task/create HTTP/1.1" 200 2 356
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:45,672]
> TRACE Invoking
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@5b39f9b3 at 2
> (org.apache.kafka.common.utils.MockScheduler:105) [2019-03-15 09:23:45,673]
> INFO Running task foo on node(s): node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:400) [2019-03-15
> 09:23:45,675] INFO node02: scheduling worker foo_0 to start.
> (org.apache.kafka.trogdor.coordinator.NodeManager:297) [2019-03-15
> 09:23:45,676] DEBUG Sending GET with input null to
> [http://127.0.0.1:33477/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:45,693]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000] "GET /coordinator/tasks/foo
> HTTP/1.1" 200 123 57 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:45,699] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:45,761] INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 41 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:45,795] INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000]
> "GET /agent/status HTTP/1.1" 200 19 55
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:45,795]
> TRACE node02: got heartbeat status \{"serverStartMs":0}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:23:45,801] DEBUG Sending POST with input
> \{"workerId":0,"taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to [http://127.0.0.1:33477/agent/worker/create]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:45,799]
> INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:45,806] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:45,806] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:45,829] INFO node02: Created worker foo_0 with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}
> (org.apache.kafka.trogdor.agent.WorkerManager:402) [2019-03-15 09:23:45,836]
> INFO foo: Activating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:40) [2019-03-15 09:23:45,839]
> INFO node02: Worker foo_0 is now RUNNING. Scheduled to stop in 10 ms.
> (org.apache.kafka.trogdor.agent.WorkerManager:431) [2019-03-15 09:23:45,839]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000] "POST /agent/worker/create
> HTTP/1.1" 200 2 37 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:45,851] TRACE Scheduling
> org.apache.kafka.trogdor.agent.WorkerManager$StopWorker@7ae7edae for 9 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:45,907] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:45,916] INFO 127.0.0.1 - - [15/Mar/2019:09:23:45 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 7 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:45,924] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:45,925] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:45,925] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:45,941] DEBUG Sending GET with input null to
> [http://127.0.0.1:8888/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:45,943]
> INFO GET [http://127.0.0.1:8888/agent/status:] error: Connection refused
> (Connection refused) (org.apache.kafka.trogdor.rest.JsonRestServer:281)
> [2019-03-15 09:23:45,943] ERROR node01: failed to get agent status:
> ConnectException Connection refused (Connection refused)
> (org.apache.kafka.trogdor.coordinator.NodeManager:196) [2019-03-15
> 09:23:46,026] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,031] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,033] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,034] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,034] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,135] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,140] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,141] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,142] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,142] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,243] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,247] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,249] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,250] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,250] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,352] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,356] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,357] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,358] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,358] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,459] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,464] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,468] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,469] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,469] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,570] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,574] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,575] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,576] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,577] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,676] DEBUG Sending GET with input null to
> [http://127.0.0.1:33477/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:46,680]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET /agent/status HTTP/1.1"
> 200 192 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:46,681] TRACE node02: got heartbeat status
> \{"serverStartMs":0,"workers":{"0":{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:23:46,682] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,688] INFO node02: worker state changed from
> \{"state":"RECEIVING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.coordinator.NodeManager:252) [2019-03-15
> 09:23:46,691] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 162 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,692] DEBUG Task foo: Updating worker state for 0 on
> node02 from
> \{"state":"RECEIVING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}.
> (org.apache.kafka.trogdor.coordinator.TaskManager:563) [2019-03-15
> 09:23:46,693] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:46,694] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:46,694] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:46,795] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,801] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 159 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:46,803] DEBUG Sending GET with input null to
> [http://localhost:33477/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:46,809]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET /agent/status HTTP/1.1"
> 200 192 4 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:46,810] DEBUG Sending GET with input null to
> [http://localhost:33468/coordinator/tasks/non-existent-foo]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:46,824] DEBUG Uncaught exception in REST call:
> (org.apache.kafka.trogdor.rest.RestExceptionMapper:36)
> javax.ws.rs.NotFoundException: No task with ID "non-existent-foo" exists. at
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource.tasks(CoordinatorRestResource.java:135)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method) at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566) at
> org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:76)
> at
> org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:148)
> at
> org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:191)
> at
> org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$TypeOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:243)
> at
> org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:103)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:493)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:415)
> at
> org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:104)
> at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:277)
> at org.glassfish.jersey.internal.Errors$1.call(Errors.java:272) at
> org.glassfish.jersey.internal.Errors$1.call(Errors.java:268) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:316) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:298) at
> org.glassfish.jersey.internal.Errors.process(Errors.java:268) at
> org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:289)
> at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:256)
> at
> org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:703)
> at
> org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:416)
> at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:370)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:389)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:342)
> at
> org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:229)
> at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:867) at
> org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542) at
> org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:255)
> at
> org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1588)
> at
> org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:255)
> at
> org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1345)
> at
> org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:203)
> at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:480)
> at
> org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1557)
> at
> org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:201)
> at
> org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1247)
> at
> org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:144)
> at
> org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:126)
> at
> org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:174)
> at
> org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:132)
> at org.eclipse.jetty.server.Server.handle(Server.java:502) at
> org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:364) at
> org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:260)
> at
> org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:305)
> at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103) at
> org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:118) at
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:333)
> at
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:310)
> at
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:168)
> at
> org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:126)
> at
> org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:366)
> at
> org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:765)
> at
> org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:683)
> at java.base/java.lang.Thread.run(Thread.java:834) [2019-03-15 09:23:46,854]
> INFO Closing MiniTrogdorCluster.
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:277) [2019-03-15
> 09:23:46,856] INFO 127.0.0.1 - - [15/Mar/2019:09:23:46 +0000] "GET
> /coordinator/tasks/non-existent-foo HTTP/1.1" 404 69 45
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:46,857]
> INFO Shutting down TaskManager.
> (org.apache.kafka.trogdor.coordinator.TaskManager:695) [2019-03-15
> 09:23:46,886] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:23:46,892]
> INFO node02: Shutting down WorkerManager.
> (org.apache.kafka.trogdor.agent.WorkerManager:648) [2019-03-15 09:23:46,892]
> INFO Stopping REST server (org.apache.kafka.trogdor.rest.JsonRestServer:137)
> [2019-03-15 09:23:46,903] INFO node02: Destroying all workers.
> (org.apache.kafka.trogdor.agent.WorkerManager:675) [2019-03-15 09:23:46,903]
> INFO node02: Stopping running worker foo_0.
> (org.apache.kafka.trogdor.agent.WorkerManager:569) [2019-03-15 09:23:46,909]
> INFO Stopped ServerConnector@1fcfcaee\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:23:46,912]
> INFO foo: Deactivating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:47) [2019-03-15 09:23:46,920]
> INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
> [2019-03-15 09:23:46,932] INFO node02: destroying worker foo_0 with error
> (org.apache.kafka.trogdor.agent.WorkerManager:516) [2019-03-15 09:23:46,938]
> INFO node02: Waiting for shutdownManager quiescence...
> (org.apache.kafka.trogdor.agent.WorkerManager:651) [2019-03-15 09:23:46,939]
> INFO node02: Waiting for workerCleanupExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:655) [2019-03-15 09:23:46,939]
> INFO node02: Waiting for stateChangeExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:657) [2019-03-15 09:23:46,939]
> INFO node02: Shutting down shutdownExecutor.
> (org.apache.kafka.trogdor.agent.WorkerManager:659) [2019-03-15 09:23:46,939]
> INFO Stopped ServerConnector@79a93bf1\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:23:46,954]
> INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
> [2019-03-15 09:23:46,998] INFO Stopped
> o.e.j.s.ServletContextHandler@335a5293\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:23:47,004] INFO Stopped
> o.e.j.s.ServletContextHandler@742ebd90\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:23:47,012] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140) [2019-03-15 09:23:47,019]
> INFO REST server stopped (org.apache.kafka.trogdor.rest.JsonRestServer:140)
> [2019-03-15 09:23:47,027] INFO Creating MiniTrogdorCluster with agents:
> node01, node02 and coordinator: node01
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:135) [2019-03-15
> 09:23:47,028] INFO Starting REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:89) [2019-03-15 09:23:47,029]
> INFO Registered resource
> org.apache.kafka.trogdor.agent.AgentRestResource@351085f7
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:23:47,030]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:23:47,084] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:23:47,084] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:23:47,085] INFO node0 Scavenging every 660000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:23:47,292] INFO Started
> o.e.j.s.ServletContextHandler@43466c8e\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:23:47,296] INFO Started
> ServerConnector@658cfca9\{HTTP/1.1,[http/1.1]}{0.0.0.0:41062}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:23:47,297]
> INFO Started @19041ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:23:47,297] INFO REST server listening at [http://127.0.1.1:41062/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:23:47,297]
> INFO Starting REST server (org.apache.kafka.trogdor.rest.JsonRestServer:89)
> [2019-03-15 09:23:47,298] INFO Registered resource
> org.apache.kafka.trogdor.agent.AgentRestResource@72bf6cef
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:23:47,298]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:23:47,304] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:23:47,305] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:23:47,305] INFO node0 Scavenging every 600000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:23:47,472] INFO Started
> o.e.j.s.ServletContextHandler@58aa975e\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:23:47,474] INFO Started
> ServerConnector@6c1978a5\{HTTP/1.1,[http/1.1]}{0.0.0.0:35161}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:23:47,475]
> INFO Started @19219ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:23:47,475] INFO REST server listening at [http://127.0.1.1:35161/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:23:47,475]
> INFO Starting REST server (org.apache.kafka.trogdor.rest.JsonRestServer:89)
> [2019-03-15 09:23:47,476] INFO Registered resource
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource@fa46412
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:23:47,477]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:23:47,512] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:23:47,512] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:23:47,513] INFO node0 Scavenging every 600000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:23:47,719] INFO Started
> o.e.j.s.ServletContextHandler@65cc8f98\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:23:47,725] INFO Started
> ServerConnector@1bb30d40\{HTTP/1.1,[http/1.1]}{0.0.0.0:46695}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:23:47,725]
> INFO Started @19470ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:23:47,725] INFO REST server listening at [http://127.0.1.1:46695/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:23:47,743]
> INFO Created TaskManager for agent(s) on: node01, node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:144) [2019-03-15
> 09:23:47,744] DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:47,847] INFO 127.0.0.1 - - [15/Mar/2019:09:23:47 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 2 94 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:47,848] DEBUG Sending GET with input null to
> [http://localhost:41062/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:47,929]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:47 +0000] "GET /agent/status HTTP/1.1"
> 200 19 72 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:47,930] DEBUG Sending GET with input null to
> [http://localhost:35161/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,012]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:47 +0000] "GET /agent/status HTTP/1.1"
> 200 19 79 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:48,014] DEBUG Sending DELETE with input null to
> [http://localhost:46695/coordinator/tasks?taskId=foo]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,020] INFO Can't destroy task foo: no such task found.
> (org.apache.kafka.trogdor.coordinator.TaskManager:512) [2019-03-15
> 09:23:48,022] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "DELETE
> /coordinator/tasks?taskId=foo HTTP/1.1" 200 2 7
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,022]
> DEBUG Sending POST with input
> \{"id":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12}}
> to [http://localhost:46695/coordinator/task/create]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,025] TRACE Scheduling
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@19cd20f9 for 2 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:48,025] INFO Created a new task foo with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},
> scheduled to start 2 ms from now.
> (org.apache.kafka.trogdor.coordinator.TaskManager:366) [2019-03-15
> 09:23:48,026] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "POST
> /coordinator/task/create HTTP/1.1" 200 2 3
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,028]
> DEBUG Sending POST with input
> \{"id":"bar","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":20,"durationMs":20}}
> to [http://localhost:46695/coordinator/task/create]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,035] TRACE Scheduling
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@170addb0 for 20 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:48,036] INFO Created a new task bar with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":20,"durationMs":20},
> scheduled to start 20 ms from now.
> (org.apache.kafka.trogdor.coordinator.TaskManager:366) [2019-03-15
> 09:23:48,037] DEBUG Sending DELETE with input null to
> [http://localhost:46695/coordinator/tasks?taskId=bar]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,037] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "POST
> /coordinator/task/create HTTP/1.1" 200 2 5
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,039]
> INFO Destroying task bar.
> (org.apache.kafka.trogdor.coordinator.TaskManager:515) [2019-03-15
> 09:23:48,056] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "DELETE
> /coordinator/tasks?taskId=bar HTTP/1.1" 200 2 15
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,058]
> DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,063] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 141 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,063] DEBUG Sending GET with input null to
> [http://localhost:41062/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,089]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET /agent/status HTTP/1.1"
> 200 19 25 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:48,089] DEBUG Sending GET with input null to
> [http://localhost:35161/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,109]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET /agent/status HTTP/1.1"
> 200 19 19 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:23:48,112] TRACE Invoking
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@19cd20f9 at 10
> (org.apache.kafka.common.utils.MockScheduler:105) [2019-03-15 09:23:48,113]
> INFO Running task foo on node(s): node01, node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:400) [2019-03-15
> 09:23:48,113] INFO node02: scheduling worker foo_1 to start.
> (org.apache.kafka.trogdor.coordinator.NodeManager:297) [2019-03-15
> 09:23:48,113] DEBUG Sending GET with input null to
> [http://127.0.0.1:35161/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,116]
> INFO node01: scheduling worker foo_0 to start.
> (org.apache.kafka.trogdor.coordinator.NodeManager:297) [2019-03-15
> 09:23:48,118] DEBUG Sending GET with input null to
> [http://127.0.0.1:41062/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,119]
> DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,133] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /agent/status HTTP/1.1" 200 19 11
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,134]
> TRACE node02: got heartbeat status \{"serverStartMs":0}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:23:48,133] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 195 14 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,148] DEBUG Sending POST with input
> \{"workerId":1,"taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12}}
> to [http://127.0.0.1:35161/agent/worker/create]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,133]
> TRACE node01: got heartbeat status \{"serverStartMs":0}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:23:48,148] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /agent/status HTTP/1.1" 200 19 28
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,134]
> INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:48,156] INFO node02: Created worker foo_1 with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12}
> (org.apache.kafka.trogdor.agent.WorkerManager:402) [2019-03-15 09:23:48,156]
> INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:48,156] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:48,149] DEBUG Sending POST with input
> \{"workerId":0,"taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12}}
> to [http://127.0.0.1:41062/agent/worker/create]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:23:48,156]
> INFO foo: Activating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:40) [2019-03-15 09:23:48,223]
> INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "POST /agent/worker/create
> HTTP/1.1" 200 2 73 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,224] INFO node02: Worker foo_1 is now RUNNING. Scheduled
> to stop in 12 ms. (org.apache.kafka.trogdor.agent.WorkerManager:431)
> [2019-03-15 09:23:48,224] TRACE Scheduling
> org.apache.kafka.trogdor.agent.WorkerManager$StopWorker@2476f9ef for 4 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:48,246] INFO node01: Created worker foo_0 with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12}
> (org.apache.kafka.trogdor.agent.WorkerManager:402) [2019-03-15 09:23:48,254]
> INFO foo: Activating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:40) [2019-03-15 09:23:48,254]
> INFO node01: Worker foo_0 is now RUNNING. Scheduled to stop in 12 ms.
> (org.apache.kafka.trogdor.agent.WorkerManager:431) [2019-03-15 09:23:48,255]
> TRACE Scheduling
> org.apache.kafka.trogdor.agent.WorkerManager$StopWorker@621eb217 for 4 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:23:48,261] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "POST
> /agent/worker/create HTTP/1.1" 200 2 39
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:23:48,321]
> DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,329] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 195 7 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,330] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:48,331] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:48,331] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:48,431] DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,439] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 195 7 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,440] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:48,441] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:48,441] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:48,541] DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,549] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 195 7 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,550] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:23:48,550] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:23:48,550] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"active","node02":"active"}},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":\{"node01":"receiving","node02":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:23:48,651] DEBUG Sending GET with input null to
> [http://localhost:46695/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:23:48,662] INFO 127.0.0.1 - - [15/Mar/2019:09:23:48 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 195 6 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:23:48,663] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":2,"durationMs":12},"startedMs":10,"status":{"node01":"active","node02":
> ...[truncated 346606 chars]... Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:05,901] INFO 127.0.0.1 - - [15/Mar/2019:09:26:05 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 158 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:05,901] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:05,902] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:05,902] INFO Invalid state for task foo: expected
> \{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,002] DEBUG Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,005] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 158 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,005] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:06,005] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:06,006] INFO Invalid state for task foo: expected
> \{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,106] DEBUG Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,109] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 158 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,111] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:06,111] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:06,111] INFO Invalid state for task foo: expected
> \{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,192] DEBUG Sending GET with input null to
> [http://127.0.0.1:8888/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:06,193]
> INFO GET [http://127.0.0.1:8888/agent/status:] error: Connection refused
> (Connection refused) (org.apache.kafka.trogdor.rest.JsonRestServer:281)
> [2019-03-15 09:26:06,193] ERROR node01: failed to get agent status:
> ConnectException Connection refused (Connection refused)
> (org.apache.kafka.trogdor.coordinator.NodeManager:196) [2019-03-15
> 09:26:06,212] DEBUG Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,214] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 158 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,215] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:06,215] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:06,215] INFO Invalid state for task foo: expected
> \{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,315] DEBUG Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,318] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 158 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,319] INFO EXPECTED TASKS:
> \{"foo":{"id":"foo","taskState":{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:06,319] INFO ACTUAL TASKS :
> \{"foo":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:06,319] INFO Invalid state for task foo: expected
> \{"state":"DONE","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"cancelled":false,"status":"done"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,320] DEBUG Sending GET with input null to
> [http://127.0.0.1:33887/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:06,329]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET /agent/status HTTP/1.1"
> 200 197 7 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:26:06,329] TRACE node02: got heartbeat status
> \{"serverStartMs":0,"workers":{"0":{"state":"DONE","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"status":"done"}}}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:26:06,329] INFO node02: worker state changed from
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> to
> \{"state":"DONE","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"status":"done"}
> (org.apache.kafka.trogdor.coordinator.NodeManager:252) [2019-03-15
> 09:26:06,329] DEBUG Task foo: Updating worker state for 0 on node02 from
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"status":"active"}
> to
> \{"state":"DONE","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":2},"startedMs":2,"doneMs":5,"status":"done"}.
> (org.apache.kafka.trogdor.coordinator.TaskManager:563) [2019-03-15
> 09:26:06,329] INFO node02: Worker foo finished with status '"done"'
> (org.apache.kafka.trogdor.coordinator.TaskManager:587) [2019-03-15
> 09:26:06,329] INFO node02: Task foo is now complete on node02 with error:
> (none) (org.apache.kafka.trogdor.coordinator.TaskManager:598) [2019-03-15
> 09:26:06,419] DEBUG Sending GET with input null to
> [http://localhost:39105/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,422] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 182 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,423] INFO Closing MiniTrogdorCluster.
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:277) [2019-03-15
> 09:26:06,423] INFO Shutting down TaskManager.
> (org.apache.kafka.trogdor.coordinator.TaskManager:695) [2019-03-15
> 09:26:06,423] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:26:06,424]
> INFO Stopping REST server (org.apache.kafka.trogdor.rest.JsonRestServer:137)
> [2019-03-15 09:26:06,425] INFO Stopped
> ServerConnector@4e96ef63\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:06,440]
> INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
> [2019-03-15 09:26:06,441] INFO Stopped
> o.e.j.s.ServletContextHandler@750b28b2\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:06,442] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140) [2019-03-15 09:26:06,443]
> INFO node02: Shutting down WorkerManager.
> (org.apache.kafka.trogdor.agent.WorkerManager:648) [2019-03-15 09:26:06,443]
> INFO node02: Destroying all workers.
> (org.apache.kafka.trogdor.agent.WorkerManager:675) [2019-03-15 09:26:06,444]
> INFO node02: destroying worker foo_0 with error
> (org.apache.kafka.trogdor.agent.WorkerManager:578) [2019-03-15 09:26:06,444]
> INFO node02: Waiting for shutdownManager quiescence...
> (org.apache.kafka.trogdor.agent.WorkerManager:651) [2019-03-15 09:26:06,444]
> INFO node02: Waiting for workerCleanupExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:655) [2019-03-15 09:26:06,444]
> INFO Stopped ServerConnector@538e4944\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:06,452]
> INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
> [2019-03-15 09:26:06,454] INFO Stopped
> o.e.j.s.ServletContextHandler@2b100b0\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:06,455] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140) [2019-03-15 09:26:06,456]
> INFO node02: Waiting for stateChangeExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:657) [2019-03-15 09:26:06,456]
> INFO node02: Shutting down shutdownExecutor.
> (org.apache.kafka.trogdor.agent.WorkerManager:659) [2019-03-15 09:26:06,460]
> INFO Creating MiniTrogdorCluster with agents: node02 and coordinator: node01
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:135) [2019-03-15
> 09:26:06,460] INFO Starting REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:89) [2019-03-15 09:26:06,460]
> INFO Registered resource
> org.apache.kafka.trogdor.agent.AgentRestResource@71c34250
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:26:06,461]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:26:06,508] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:26:06,508] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:26:06,509] INFO node0 Scavenging every 660000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:26:06,600] INFO Started
> o.e.j.s.ServletContextHandler@6c85d064\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:26:06,617] INFO Started
> ServerConnector@6a7d40d2\{HTTP/1.1,[http/1.1]}{0.0.0.0:37168}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:26:06,617]
> INFO Started @158362ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:26:06,618] INFO REST server listening at [http://127.0.1.1:37168/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:26:06,618]
> INFO Starting REST server (org.apache.kafka.trogdor.rest.JsonRestServer:89)
> [2019-03-15 09:26:06,619] INFO Registered resource
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource@149c2a46
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:26:06,619]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:26:06,668] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:26:06,668] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:26:06,668] INFO node0 Scavenging every 660000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:26:06,771] INFO Started
> o.e.j.s.ServletContextHandler@25bf1e09\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:26:06,780] INFO Started
> ServerConnector@ac53d60\{HTTP/1.1,[http/1.1]}{0.0.0.0:45996}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:26:06,780]
> INFO Started @158525ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:26:06,780] INFO REST server listening at [http://127.0.1.1:45996/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:26:06,795]
> INFO Created TaskManager for agent(s) on: node01, node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:144) [2019-03-15
> 09:26:06,796] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,845] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 2 29 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,845] DEBUG Sending POST with input
> \{"id":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to [http://localhost:45996/coordinator/task/create]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,848] TRACE Scheduling
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@46b03bf6 for 1 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:26:06,849] INFO Created a new task foo with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},
> scheduled to start 1 ms from now.
> (org.apache.kafka.trogdor.coordinator.TaskManager:366) [2019-03-15
> 09:26:06,850] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "POST
> /coordinator/task/create HTTP/1.1" 200 2 4
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:26:06,852]
> DEBUG Sending POST with input
> \{"id":"bar","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1}}
> to [http://localhost:45996/coordinator/task/create]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,858] TRACE Scheduling
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@4877cd50 for 3 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:26:06,858] INFO Created a new task bar with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},
> scheduled to start 3 ms from now.
> (org.apache.kafka.trogdor.coordinator.TaskManager:366) [2019-03-15
> 09:26:06,859] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "POST
> /coordinator/task/create HTTP/1.1" 200 2 3
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:26:06,860]
> DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,866] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 270 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,868] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=10&lastStartMs=0&firstEndMs=10&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,872] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=10&lastStartMs=0&firstEndMs=10&lastEndMs=0
> HTTP/1.1" 200 2 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,876] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?taskId=foo&taskId=baz&firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,878] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?taskId=foo&taskId=baz&firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 141 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,887] TRACE Invoking
> org.apache.kafka.trogdor.coordinator.TaskManager$RunTask@46b03bf6 at 2
> (org.apache.kafka.common.utils.MockScheduler:105) [2019-03-15 09:26:06,888]
> INFO Running task foo on node(s): node02
> (org.apache.kafka.trogdor.coordinator.TaskManager:400) [2019-03-15
> 09:26:06,888] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:06,888] INFO node02: scheduling worker foo_0 to start.
> (org.apache.kafka.trogdor.coordinator.NodeManager:297) [2019-03-15
> 09:26:06,888] DEBUG Sending GET with input null to
> [http://127.0.0.1:37168/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:06,898]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 8 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:06,900] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000]
> "GET /agent/status HTTP/1.1" 200 19 9
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:26:06,900]
> TRACE node02: got heartbeat status \{"serverStartMs":0}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:26:06,901] DEBUG Sending POST with input
> \{"workerId":0,"taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to [http://127.0.0.1:37168/agent/worker/create]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:06,900]
> INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:06,902] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:06,902] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:06,908] INFO node02: Created worker foo_0 with spec
> \{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}
> (org.apache.kafka.trogdor.agent.WorkerManager:402) [2019-03-15 09:26:06,917]
> INFO foo: Activating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:40) [2019-03-15 09:26:06,917]
> INFO node02: Worker foo_0 is now RUNNING. Scheduled to stop in 10 ms.
> (org.apache.kafka.trogdor.agent.WorkerManager:431) [2019-03-15 09:26:06,917]
> TRACE Scheduling
> org.apache.kafka.trogdor.agent.WorkerManager$StopWorker@7e4a1640 for 9 ms
> from now. (org.apache.kafka.common.utils.MockScheduler:117) [2019-03-15
> 09:26:06,920] INFO 127.0.0.1 - - [15/Mar/2019:09:26:06 +0000] "POST
> /agent/worker/create HTTP/1.1" 200 2 19
> (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15 09:26:07,002]
> DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,008] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 5 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,009] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,009] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,009] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,109] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,112] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,113] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,113] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,113] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,213] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,216] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,216] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,216] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,217] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,317] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,320] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,320] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,320] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,320] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,421] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,424] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 1 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,424] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,424] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,424] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,524] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,527] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,527] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,527] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,528] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,628] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,633] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 4 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,633] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,633] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,634] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,734] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,737] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,737] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,737] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,737] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,784] DEBUG Sending GET with input null to
> [http://127.0.0.1:8888/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:07,785]
> INFO GET [http://127.0.0.1:8888/agent/status:] error: Connection refused
> (Connection refused) (org.apache.kafka.trogdor.rest.JsonRestServer:281)
> [2019-03-15 09:26:07,785] ERROR node01: failed to get agent status:
> ConnectException Connection refused (Connection refused)
> (org.apache.kafka.trogdor.coordinator.NodeManager:196) [2019-03-15
> 09:26:07,838] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,841] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 291 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,841] INFO EXPECTED TASKS:
> \{"bar":{"id":"bar","taskState":{"state":"PENDING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null}},"foo":\{"id":"foo","taskState":{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},"workerState":\{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:163) [2019-03-15
> 09:26:07,841] INFO ACTUAL TASKS :
> \{"bar":{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":3,"durationMs":1},"status":null},"foo":\{"spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}}
> (org.apache.kafka.trogdor.common.ExpectedTasks:164) [2019-03-15
> 09:26:07,841] INFO Invalid state for task foo: expected
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"},
> got
> \{"state":"RUNNING","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"receiving"}
> (org.apache.kafka.trogdor.common.ExpectedTasks:165) [2019-03-15
> 09:26:07,889] DEBUG Sending GET with input null to
> [http://127.0.0.1:37168/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:07,892]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET /agent/status HTTP/1.1"
> 200 192 3 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:26:07,892] TRACE node02: got heartbeat status
> \{"serverStartMs":0,"workers":{"0":{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}}}
> (org.apache.kafka.trogdor.coordinator.NodeManager:205) [2019-03-15
> 09:26:07,892] INFO node02: worker state changed from
> \{"state":"RECEIVING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}
> (org.apache.kafka.trogdor.coordinator.NodeManager:252) [2019-03-15
> 09:26:07,893] DEBUG Task foo: Updating worker state for 0 on node02 from
> \{"state":"RECEIVING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10}}
> to
> \{"state":"RUNNING","taskId":"foo","spec":{"class":"org.apache.kafka.trogdor.task.NoOpTaskSpec","startMs":1,"durationMs":10},"startedMs":2,"status":"active"}.
> (org.apache.kafka.trogdor.coordinator.TaskManager:563) [2019-03-15
> 09:26:07,942] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,945] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=0&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 288 1 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,945] DEBUG Sending GET with input null to
> [http://localhost:37168/agent/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:07,947]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET /agent/status HTTP/1.1"
> 200 192 1 (org.apache.kafka.trogdor.rest.JsonRestServer:60) [2019-03-15
> 09:26:07,947] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=1&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,950] INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=1&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 159 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,950] DEBUG Sending GET with input null to
> [http://localhost:45996/coordinator/tasks?firstStartMs=3&lastStartMs=0&firstEndMs=0&lastEndMs=0]
> (org.apache.kafka.trogdor.coordinator.CoordinatorClient:193) [2019-03-15
> 09:26:07,952] INFO Closing MiniTrogdorCluster.
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:277) [2019-03-15
> 09:26:07,952] INFO Shutting down TaskManager.
> (org.apache.kafka.trogdor.coordinator.TaskManager:695) [2019-03-15
> 09:26:07,952] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:26:07,952]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:07 +0000] "GET
> /coordinator/tasks?firstStartMs=3&lastStartMs=0&firstEndMs=0&lastEndMs=0
> HTTP/1.1" 200 2 2 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:07,953] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:26:07,954]
> INFO node02: Shutting down WorkerManager.
> (org.apache.kafka.trogdor.agent.WorkerManager:648) [2019-03-15 09:26:07,954]
> INFO node02: Destroying all workers.
> (org.apache.kafka.trogdor.agent.WorkerManager:675) [2019-03-15 09:26:07,954]
> INFO node02: Stopping running worker foo_0.
> (org.apache.kafka.trogdor.agent.WorkerManager:569) [2019-03-15 09:26:07,955]
> INFO Stopped ServerConnector@6a7d40d2\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:07,955]
> INFO node02: Waiting for shutdownManager quiescence...
> (org.apache.kafka.trogdor.agent.WorkerManager:651) [2019-03-15 09:26:07,956]
> INFO Stopped ServerConnector@ac53d60\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:07,956]
> INFO foo: Deactivating NoOpTask.
> (org.apache.kafka.trogdor.task.NoOpTaskWorker:47) [2019-03-15 09:26:07,963]
> INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
> [2019-03-15 09:26:07,964] INFO node0 Stopped scavenging
> (org.eclipse.jetty.server.session:167) [2019-03-15 09:26:07,968] INFO node02:
> destroying worker foo_0 with error
> (org.apache.kafka.trogdor.agent.WorkerManager:516) [2019-03-15 09:26:07,983]
> INFO Stopped o.e.j.s.ServletContextHandler@25bf1e09\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:07,988] INFO node02: Waiting for workerCleanupExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:655) [2019-03-15 09:26:07,988]
> INFO node02: Waiting for stateChangeExecutor to terminate...
> (org.apache.kafka.trogdor.agent.WorkerManager:657) [2019-03-15 09:26:07,997]
> INFO Stopped o.e.j.s.ServletContextHandler@6c85d064\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:07,998] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140) [2019-03-15 09:26:07,998]
> INFO node02: Shutting down shutdownExecutor.
> (org.apache.kafka.trogdor.agent.WorkerManager:659) [2019-03-15 09:26:08,003]
> INFO REST server stopped (org.apache.kafka.trogdor.rest.JsonRestServer:140)
> [2019-03-15 09:26:08,009] INFO Creating MiniTrogdorCluster with agents: and
> coordinator: node01 (org.apache.kafka.trogdor.common.MiniTrogdorCluster:135)
> [2019-03-15 09:26:08,010] INFO Starting REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:89) [2019-03-15 09:26:08,010]
> INFO Registered resource
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource@69042100
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:26:08,011]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:26:08,022] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:26:08,023] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:26:08,023] INFO node0 Scavenging every 600000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:26:08,153] INFO Started
> o.e.j.s.ServletContextHandler@7dd0793a\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:26:08,162] INFO Started
> ServerConnector@6f2a69c3\{HTTP/1.1,[http/1.1]}{0.0.0.0:46030}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:26:08,163]
> INFO Started @159908ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:26:08,163] INFO REST server listening at [http://127.0.1.1:46030/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:26:08,179]
> INFO Created TaskManager for agent(s) on: node01
> (org.apache.kafka.trogdor.coordinator.TaskManager:144) [2019-03-15
> 09:26:08,180] DEBUG Sending GET with input null to
> [http://localhost:46030/coordinator/status]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:08,186]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:08 +0000] "GET /coordinator/status
> HTTP/1.1" 200 31 4 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:08,195] INFO Closing MiniTrogdorCluster.
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:277) [2019-03-15
> 09:26:08,209] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:26:08,211]
> INFO Stopped ServerConnector@6f2a69c3\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:08,212]
> INFO Shutting down TaskManager.
> (org.apache.kafka.trogdor.coordinator.TaskManager:695) [2019-03-15
> 09:26:08,213] INFO node0 Stopped scavenging
> (org.eclipse.jetty.server.session:167) [2019-03-15 09:26:08,215] INFO Stopped
> o.e.j.s.ServletContextHandler@7dd0793a\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:08,216] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140) [2019-03-15 09:26:08,225]
> INFO Creating MiniTrogdorCluster with agents: and coordinator: node01
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:135) [2019-03-15
> 09:26:08,226] INFO Starting REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:89) [2019-03-15 09:26:08,228]
> INFO Registered resource
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource@5baa2d2d
> (org.apache.kafka.trogdor.rest.JsonRestServer:94) [2019-03-15 09:26:08,230]
> INFO jetty-9.4.14.v20181114; built: 2018-11-14T21:20:31.478Z; git:
> c4550056e785fb5665914545889f21dc136ad9e6; jvm 11.0.1+13-LTS
> (org.eclipse.jetty.server.Server:370) [2019-03-15 09:26:08,234] INFO
> DefaultSessionIdManager workerName=node0
> (org.eclipse.jetty.server.session:365) [2019-03-15 09:26:08,234] INFO No
> SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)
> [2019-03-15 09:26:08,235] INFO node0 Scavenging every 600000ms
> (org.eclipse.jetty.server.session:149) [2019-03-15 09:26:08,310] INFO Started
> o.e.j.s.ServletContextHandler@3c3abc1f\{/,null,AVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:855) [2019-03-15
> 09:26:08,336] INFO Started
> ServerConnector@6a7dcfa7\{HTTP/1.1,[http/1.1]}{0.0.0.0:42585}
> (org.eclipse.jetty.server.AbstractConnector:292) [2019-03-15 09:26:08,336]
> INFO Started @160081ms (org.eclipse.jetty.server.Server:407) [2019-03-15
> 09:26:08,336] INFO REST server listening at [http://127.0.1.1:42585/]
> (org.apache.kafka.trogdor.rest.JsonRestServer:123) [2019-03-15 09:26:08,337]
> INFO Created TaskManager for agent(s) on: node01
> (org.apache.kafka.trogdor.coordinator.TaskManager:144) [2019-03-15
> 09:26:08,338] DEBUG Sending GET with input null to
> [http://localhost:42585/coordinator/uptime]
> (org.apache.kafka.trogdor.rest.JsonRestServer:193) [2019-03-15 09:26:08,380]
> INFO 127.0.0.1 - - [15/Mar/2019:09:26:08 +0000] "GET /coordinator/uptime
> HTTP/1.1" 200 33 36 (org.apache.kafka.trogdor.rest.JsonRestServer:60)
> [2019-03-15 09:26:08,381] INFO Closing MiniTrogdorCluster.
> (org.apache.kafka.trogdor.common.MiniTrogdorCluster:277) [2019-03-15
> 09:26:08,383] INFO Stopping REST server
> (org.apache.kafka.trogdor.rest.JsonRestServer:137) [2019-03-15 09:26:08,384]
> INFO Stopped ServerConnector@6a7dcfa7\{HTTP/1.1,[http/1.1]}{0.0.0.0:0}
> (org.eclipse.jetty.server.AbstractConnector:341) [2019-03-15 09:26:08,388]
> INFO Shutting down TaskManager.
> (org.apache.kafka.trogdor.coordinator.TaskManager:695) [2019-03-15
> 09:26:08,391] INFO node0 Stopped scavenging
> (org.eclipse.jetty.server.session:167) [2019-03-15 09:26:08,402] INFO Stopped
> o.e.j.s.ServletContextHandler@3c3abc1f\{/,null,UNAVAILABLE}
> (org.eclipse.jetty.server.handler.ContextHandler:1045) [2019-03-15
> 09:26:08,406] INFO REST server stopped
> (org.apache.kafka.trogdor.rest.JsonRestServer:140){quote}
> STDERR
> {quote}Mar 15, 2019 9:23:43 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:44 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:23:47 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:47 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:47 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:23:49 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:49 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:49 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:23:53 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:53 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:23:57 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:57 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:23:57 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:24:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:24:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:00 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:01 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:01 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:01 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:02 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:02 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:03 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:04 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:06 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.agent.AgentRestResource registered in SERVER runtime
> does not implement any provider interfaces applicable in the SERVER runtime.
> Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.agent.AgentRestResource will be ignored. Mar 15,
> 2019 9:26:06 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:08 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be ignored.
> Mar 15, 2019 9:26:08 AM org.glassfish.jersey.internal.inject.Providers
> checkProviderRuntime WARNING: A provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource registered in
> SERVER runtime does not implement any provider interfaces applicable in the
> SERVER runtime. Due to constraint configuration problems the provider
> org.apache.kafka.trogdor.coordinator.CoordinatorRestResource will be
> ignored.{quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
