Skip to content

Commit

Permalink
Use separate action for /tasks/scheduler/jobDetails API (apache#13054)
Browse files Browse the repository at this point in the history
Created new Action GET_SCHEDULER_JOB_DETAILS  under the Table actions for the endpoint /tasks/scheduler/jobDetails as its fetching table level information and the existing action puts this endpoint under Cluster actions.
  • Loading branch information
shounakmk219 authored May 2, 2024
1 parent 076cd40 commit 21bc241
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -553,9 +553,9 @@ public List<JobKey> getCronSchedulerJobKeys()

@GET
@Path("/tasks/scheduler/jobDetails")
@Authorize(targetType = TargetType.CLUSTER, action = Actions.Cluster.GET_SCHEDULER_INFO)
@Authorize(targetType = TargetType.TABLE, action = Actions.Table.GET_SCHEDULER_JOB_DETAILS)
@Produces(MediaType.APPLICATION_JSON)
@ApiOperation("Fetch cron scheduler job keys")
@ApiOperation("Fetch job details for table tasks")
public Map<String, Object> getCronSchedulerJobDetails(
@ApiParam(value = "Table name (with type suffix)", required = true) @QueryParam("tableName") String tableName,
@ApiParam(value = "Task type") @QueryParam("taskType") String taskType, @Context HttpHeaders headers)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,7 @@ public static class Table {
public static final String GET_TABLE_CONFIGS = "GetTableConfigs";
public static final String GET_TABLE_LEADER = "GetTableLeader";
public static final String GET_TIME_BOUNDARY = "GetTimeBoundary";
public static final String GET_SCHEDULER_JOB_DETAILS = "GetSchedulerJobDetails";
public static final String PAUSE_CONSUMPTION = "PauseConsumption";
public static final String QUERY = "Query";
public static final String REBALANCE_TABLE = "RebalanceTable";
Expand Down

0 comments on commit 21bc241

Please sign in to comment.