Skip to content

Commit 38bc4ff

Browse files
authored
fix column lineage query (#2881)
Signed-off-by: sophiely <ly.sophie200@gmail.com>
1 parent 915aff3 commit 38bc4ff

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

api/src/main/java/marquez/db/ColumnLineageDao.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -187,22 +187,22 @@ SELECT DISTINCT ON (cl.output_dataset_field_uuid, cl.input_dataset_field_uuid) c
187187
dataset_fields_view AS (
188188
SELECT
189189
d.namespace_name AS namespace_name,
190-
d.name AS dataset_name,
190+
d.dataset_name AS dataset_name,
191191
df.name AS field_name,
192192
df.type,
193193
df.uuid
194194
FROM dataset_fields df
195195
INNER JOIN (
196-
SELECT uuid, namespace_name, name
197-
FROM datasets_view
198-
WHERE current_version_uuid IN (
196+
SELECT DISTINCT dataset_uuid, namespace_name, dataset_name
197+
FROM dataset_versions
198+
WHERE uuid IN (
199199
SELECT DISTINCT output_dataset_version_uuid
200200
FROM selected_column_lineage
201201
UNION
202202
SELECT DISTINCT input_dataset_version_uuid
203203
FROM selected_column_lineage
204204
)
205-
) d ON d.uuid = df.dataset_uuid
205+
) d ON d.dataset_uuid = df.dataset_uuid
206206
)
207207
SELECT
208208
output_fields.namespace_name,

0 commit comments

Comments
 (0)