diff --git a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ExecutorServlet.java b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ExecutorServlet.java
index eeb6f9f..beeab4a 100644
--- a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ExecutorServlet.java
+++ b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ExecutorServlet.java
@@ -867,7 +867,9 @@ public class ExecutorServlet extends LoginAbstractAzkabanServlet {
nodeObj.put("endTime", node.getEndTime());
nodeObj.put("updateTime", node.getUpdateTime());
nodeObj.put("type", node.getType());
- nodeObj.put("condition", node.getCondition());
+ if (node.getCondition() != null) {
+ nodeObj.put("condition", node.getCondition());
+ }
nodeObj.put("nestedId", node.getNestedId());
nodeObj.put("attempt", node.getAttempt());
diff --git a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
index 4a89efa..6a6ae41 100644
--- a/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
+++ b/azkaban-web-server/src/main/java/azkaban/webapp/servlet/ProjectManagerServlet.java
@@ -801,7 +801,9 @@ public class ProjectManagerServlet extends LoginAbstractAzkabanServlet {
final HashMap<String, Object> nodeObj = new HashMap<>();
nodeObj.put("id", node.getId());
nodeObj.put("type", node.getType());
- nodeObj.put("condition", node.getCondition());
+ if (node.getCondition() != null) {
+ nodeObj.put("condition", node.getCondition());
+ }
if (node.getEmbeddedFlowId() != null) {
nodeObj.put("flowId", node.getEmbeddedFlowId());
fillFlowInfo(project, node.getEmbeddedFlowId(), nodeObj);