Skip to content

Commit eecc664

Browse files
committed
Join condition fix
1 parent 3f229c1 commit eecc664

File tree

1 file changed

+13
-15
lines changed

1 file changed

+13
-15
lines changed

src/pages/Correlation/components/SaveCorrelationModal.tsx

+13-15
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ const SaveCorrelationModal = () => {
4343

4444
const streamNames = Object.keys(fields);
4545

46-
const joins = correlationCondition.split('=');
46+
const joins = correlationCondition.split('=').map((part) => part.replace(/"/g, '').trim());
4747

4848
useEffect(() => {
4949
const timeRangeOptions = makeTimeRangeOptions({ selected: null, current: timeRange });
@@ -101,18 +101,16 @@ const SaveCorrelationModal = () => {
101101
tableName: streamNames[1],
102102
},
103103
],
104-
joinConfig: {
105-
joinConditions: [
106-
{
107-
tableName: streamNames[0],
108-
field: joins[0].split('.')[1].trim(),
109-
},
110-
{
111-
tableName: streamNames[1],
112-
field: joins[1].split('.')[1].trim(),
113-
},
114-
],
115-
},
104+
joinConditions: [
105+
{
106+
tableName: streamNames[0],
107+
field: joins[0].split('.').slice(1).join('.').trim(),
108+
},
109+
{
110+
tableName: streamNames[1],
111+
field: joins[1].split('.').slice(1).join('.').trim(),
112+
},
113+
],
116114
filter: null,
117115
startTime: formObject?.selectedTimeRangeOption.time_filter?.from,
118116
endTime: formObject?.selectedTimeRangeOption.time_filter?.to,
@@ -141,11 +139,11 @@ const SaveCorrelationModal = () => {
141139
joinConditions: [
142140
{
143141
tableName: streamNames[0],
144-
field: joins[0].split('.')[1].trim(),
142+
field: joins[0].split('.').slice(1).join('.').trim(),
145143
},
146144
{
147145
tableName: streamNames[1],
148-
field: joins[1].split('.')[1].trim(),
146+
field: joins[1].split('.').slice(1).join('.').trim(),
149147
},
150148
],
151149
},

0 commit comments

Comments
 (0)