Trogdor: Fix /coordinator/tasks parameters to accept long values (apa…

…che#5905) Reviewers: Colin McCabe <[email protected]>
gf53520 · Nov 13, 2018 · d00938f · d00938f
1 parent e08d721
commit d00938f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java b/tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java
@@ -98,10 +98,10 @@ public Empty destroyTask(@DefaultValue("") @QueryParam("taskId") String taskId)
     @GET
     @Path("/tasks")
     public TasksResponse tasks(@QueryParam("taskId") List<String> taskId,
-            @DefaultValue("0") @QueryParam("firstStartMs") int firstStartMs,
-            @DefaultValue("0") @QueryParam("lastStartMs") int lastStartMs,
-            @DefaultValue("0") @QueryParam("firstEndMs") int firstEndMs,
-            @DefaultValue("0") @QueryParam("lastEndMs") int lastEndMs) throws Throwable {
+            @DefaultValue("0") @QueryParam("firstStartMs") long firstStartMs,
+            @DefaultValue("0") @QueryParam("lastStartMs") long lastStartMs,
+            @DefaultValue("0") @QueryParam("firstEndMs") long firstEndMs,
+            @DefaultValue("0") @QueryParam("lastEndMs") long lastEndMs) throws Throwable {
         return coordinator().tasks(new TasksRequest(taskId, firstStartMs, lastStartMs, firstEndMs, lastEndMs));
     }