You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2018/11/13 16:35:23 UTC
[kafka] branch trunk updated: Trogdor: Fix /coordinator/tasks
parameters to accept long values (#5905)
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 <st...@outlook.com>
AuthorDate: Tue Nov 13 16:35:03 2018 +0000
Trogdor: Fix /coordinator/tasks parameters to accept long values (#5905)
Reviewers: Colin McCabe <cm...@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));
}