This is an automated email from the ASF dual-hosted git repository. kharekartik pushed a commit to branch revert-16968-minion_tasks_ui_fix in repository https://gitbox.apache.org/repos/asf/pinot.git
commit ac5238726868320b0acdbea719982217a1d9a469 Author: Kartik Khare <[email protected]> AuthorDate: Thu Feb 26 16:29:16 2026 +0530 Revert "Task queue UI: surface debug tables (#16968)" This reverts commit cdaa68836803589363f75edc5997ab38b01a354f. --- .../src/main/resources/app/pages/TaskQueue.tsx | 28 ++-------------------- 1 file changed, 2 insertions(+), 26 deletions(-) diff --git a/pinot-controller/src/main/resources/app/pages/TaskQueue.tsx b/pinot-controller/src/main/resources/app/pages/TaskQueue.tsx index c5eafe93a4a..380e9ee87b6 100644 --- a/pinot-controller/src/main/resources/app/pages/TaskQueue.tsx +++ b/pinot-controller/src/main/resources/app/pages/TaskQueue.tsx @@ -18,7 +18,7 @@ */ import React, { useEffect, useState } from 'react'; -import { get } from 'lodash'; +import { get, map } from 'lodash'; import { TableData } from 'Models'; import { Grid, makeStyles } from '@material-ui/core'; import SimpleAccordion from '../components/SimpleAccordion'; @@ -66,33 +66,9 @@ const TaskQueue = (props) => { setFetching(true); const taskInfoRes = await PinotMethodUtils.getTaskInfo(taskType); const tablesResponse:any = await PinotMethodUtils.getTableData({ taskType }); - const responseTables = get(tablesResponse, 'tables', []); - const initialTables = Array.isArray(responseTables) - ? responseTables.filter((table): table is string => typeof table === 'string') - : []; - const tableSet = new Set<string>(initialTables); - - try { - const debugResponse:any = await PinotMethodUtils.getTaskTypeDebugData(taskType); - Object.values(debugResponse || {}).forEach((taskDebug: any) => { - (get(taskDebug, 'subtaskInfos', []) || []).forEach((subtask: any) => { - const taskConfig = get(subtask, 'taskConfig', {}); - const tableName = get(taskConfig, 'tableName') || get(taskConfig, 'configs.tableName'); - if (typeof tableName === 'string') { - tableSet.add(tableName); - } - }); - }); - } catch (error) { - // Debug endpoint might be disabled; ignore and fall back to configured tables only. - // eslint-disable-next-line no-console - console.warn(`Unable to retrieve adhoc task tables for ${taskType}:`, error); - } - setTaskInfo(taskInfoRes); setTables((prevState): TableData => { - const tableList = Array.from(tableSet).sort(); - const _records = tableList.map(table => [table]); + const _records = map(get(tablesResponse, 'tables', []), table => [table]); return { ...prevState, records: _records }; }); setFetching(false); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
