liaoxin01 commented on code in PR #48963:
URL: https://github.com/apache/doris/pull/48963#discussion_r1996529472
##########
fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java:
##########
@@ -4211,4 +4216,53 @@ public TFetchRunningQueriesResult
fetchRunningQueries(TFetchRunningQueriesReques
result.setRunningQueries(runningQueries);
return result;
}
+
+ @Override
+ public TFetchRoutineLoadJobResult
fetchRoutineLoadJob(TFetchRoutineLoadJobRequest request) {
+ TFetchRoutineLoadJobResult result = new TFetchRoutineLoadJobResult();
+
+ if (!Env.getCurrentEnv().isReady()) {
+ return result;
+ }
+
+ RoutineLoadManager routineLoadManager =
Env.getCurrentEnv().getRoutineLoadManager();
+ List<TRoutineLoadJob> jobInfos = Lists.newArrayList();
+ List<RoutineLoadJob> routineLoadJobs =
routineLoadManager.getAllRoutineLoadJobs();
+ for (RoutineLoadJob job : routineLoadJobs) {
+ TRoutineLoadJob jobInfo = new TRoutineLoadJob();
+ jobInfo.setJobId(job.getId());
+ jobInfo.setJobName(job.getName());
+ jobInfo.setCreateTime(job.getCreateTimestampString());
+ jobInfo.setPauseTime(job.getPauseTimestampString());
+ jobInfo.setEndTime(job.getEndTimestampString());
+ String dbName = "";
+ String tableName = "";
+ try {
+ dbName = job.getDbFullName();
+ tableName = job.getTableName();
+ } catch (MetaNotFoundException e) {
+ LOG.warn("Failed to get db or table name for routine load job:
{}", job.getId(), e);
+ }
+ jobInfo.setDbName(dbName);
+ jobInfo.setTableName(tableName);
+ jobInfo.setState(job.getState().name());
+
jobInfo.setCurrentTaskNum(String.valueOf(job.getSizeOfRoutineLoadTaskInfoList()));
+ jobInfo.setJobProperties(job.jobPropertiesToJsonString());
+
jobInfo.setDataSourceProperties(job.dataSourcePropertiesJsonToString());
+ jobInfo.setCustomProperties(job.customPropertiesJsonToString());
+ jobInfo.setStatistic(job.getStatistic());
+ jobInfo.setProgress(job.getProgress().toJsonString());
+ jobInfo.setLag(job.getLag());
+ jobInfo.setReasonOfStateChanged(job.getStateReason());
+ jobInfo.setErrorLogUrls(Joiner.on(",
").join(job.getErrorLogUrls()));
+ jobInfo.setUserName(job.getUserIdentity().getQualifiedUser());
+
jobInfo.setCurrentAbortTaskNum(job.getJobStatistic().currentAbortedTaskNum);
+ jobInfo.setIsAbnormalPause(job.isAbnormalPause());
+ jobInfos.add(jobInfo);
+ }
+ LOG.info("routine load job infos: {}", jobInfos);
Review Comment:
```suggestion
if (LOG.isDebugEnabled()) {
LOG.debug("routine load job infos: {}", jobInfos);
}
```
--
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...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
