diff --git a/dinky-core/src/main/java/org/dinky/explainer/Explainer.java b/dinky-core/src/main/java/org/dinky/explainer/Explainer.java index 7f08810ef6..32d5d655cf 100644 --- a/dinky-core/src/main/java/org/dinky/explainer/Explainer.java +++ b/dinky-core/src/main/java/org/dinky/explainer/Explainer.java @@ -24,6 +24,7 @@ import org.dinky.data.exception.DinkyException; import org.dinky.data.job.JobStatement; import org.dinky.data.job.JobStatementType; +import org.dinky.data.job.SqlCategory; import org.dinky.data.job.SqlType; import org.dinky.data.model.LineageRel; import org.dinky.data.result.ExplainResult; @@ -212,7 +213,7 @@ public List getLineage(String statement) { try { if (sqlType.equals(SqlType.INSERT)) { lineageRelList.addAll(executor.getLineage(sql)); - } else if (!sqlType.equals(SqlType.SELECT) && !sqlType.equals(SqlType.PRINT)) { + } else if (SqlCategory.DDL.equals(sqlType.getCategory())) { jobRunnerFactory.getJobRunner(item.getStatementType()).run(item); } } catch (Exception e) {