klsince commented on code in PR #8551:
URL: https://github.com/apache/pinot/pull/8551#discussion_r851568448
##########
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotTaskRestletResource.java:
##########
@@ -149,6 +149,28 @@ public Map<String, TaskState> getTaskStatesByTable(
return _pinotHelixTaskResourceManager.getTaskStatesByTable(taskType,
tableNameWithType);
}
+ @GET
+ @Path("/tasks/{taskType}/{tableNameWithType}/metadata")
+ @ApiOperation("Get task metadata for the given task type and table")
+ public String getTaskMetadataByTable(
+ @ApiParam(value = "Task type", required = true) @PathParam("taskType")
String taskType,
+ @ApiParam(value = "Table name with type", required = true)
@PathParam("tableNameWithType")
+ String tableNameWithType) {
+ return _pinotHelixTaskResourceManager.getTaskMetadataByTable(taskType,
tableNameWithType);
+ }
+
+ @DELETE
Review Comment:
Helix task framework is not aware of the task metadata here, e.g.
RealtimToOfflineTask keeps a timestamp as watermark in a ZNode under
`/Propertystore/MINION_TASK_METADATA/` to manage its progress.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
