diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java index 470e4239a74..b77bf025d4b 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/LineageRepository.java @@ -257,6 +257,7 @@ public class LineageRepository { } private String processColumnLineage(HashMap lineageMap) { + if (lineageMap.get("columns") != null) { StringBuilder str = new StringBuilder(); Collection collection = (Collection) lineageMap.get("columns"); @@ -268,9 +269,9 @@ public class LineageRepository { str.append(colLineage.get("toColumn")); str.append(";"); } - // remove the last ; - return str.toString().substring(0, str.toString().length() - 1); } + // remove the last ; + return str.toString().substring(0, str.toString().length() - 1); } return ""; }