This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 14a53cd051e Revert "Task queue UI: surface debug tables (#16968)"
(#17773)
14a53cd051e is described below
commit 14a53cd051e3bc88fa23d593ff8a25e06ea3bc68
Author: Kartik Khare <[email protected]>
AuthorDate: Thu Feb 26 23:41:20 2026 +0530
Revert "Task queue UI: surface debug tables (#16968)" (#17773)
---
.../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]
