kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated: Trogdor: Fix /coordinator/tasks parameters to accept long values (#5905)
Date Tue, 13 Nov 2018 16:35:23 GMT
This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new d00938f  Trogdor: Fix /coordinator/tasks parameters to accept long values (#5905)
d00938f is described below

commit d00938fdf862b70923528ceff87ed0fc081b13d1
Author: Stanislav Kozlovski <stanislav_kozlovski@outlook.com>
AuthorDate: Tue Nov 13 16:35:03 2018 +0000

    Trogdor: Fix /coordinator/tasks parameters to accept long values (#5905)
    
    Reviewers: Colin McCabe <cmccabe@apache.org>
---
 .../apache/kafka/trogdor/coordinator/CoordinatorRestResource.java | 8 ++++----
 1 file changed, 4 insertions(+), 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
index 9163720..c0e7fc9 100644
--- 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 class CoordinatorRestResource {
     @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));
     }
 


Mime
View raw message