Skip to content
This repository was archived by the owner on May 13, 2025. It is now read-only.

Fixed: Datafusion error for graph query #273

Merged
merged 1 commit into from
Jul 18, 2024
Merged

Fixed: Datafusion error for graph query #273

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions src/pages/Stream/components/EventTimeLineGraph.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ const generateCountQuery = (
whereClause: string,
) => {
const range = compactTypeIntervalMap[compactType];
return `SELECT DATE_BIN('${range}', p_timestamp, '${startTime.toISOString()}') AS timestamp, COUNT(*) AS log_count FROM ${streamName} WHERE p_timestamp BETWEEN '${startTime.toISOString()}' AND '${endTime.toISOString()}' AND ${whereClause} GROUP BY timestamp ORDER BY timestamp`;
return `SELECT DATE_BIN('${range}', p_timestamp, '${startTime.toISOString()}') AS date_bin_timestamp, COUNT(*) AS log_count FROM ${streamName} WHERE p_timestamp BETWEEN '${startTime.toISOString()}' AND '${endTime.toISOString()}' AND ${whereClause} GROUP BY date_bin_timestamp ORDER BY date_bin_timestamp`;
};

const NoDataView = () => {
Expand All @@ -157,7 +157,7 @@ const NoDataView = () => {
};

type GraphRecord = {
timestamp: string;
date_bin_timestamp: string;
log_count: number;
};

Expand All @@ -179,7 +179,7 @@ const parseGraphData = (data: GraphRecord[] = [], avg: number, startTime: Date,
const allTimestamps = getAllIntervals(modifiedStartTime, modifiedEndTime, compactType);
const parsedData = allTimestamps.map((ts) => {
const countData = data.find((d) => {
return new Date(`${d.timestamp}Z`).toISOString() === ts.toISOString();
return new Date(`${d.date_bin_timestamp}Z`).toISOString() === ts.toISOString();
});

if (!countData || typeof countData !== 'object') {
Expand Down