diff --git a/engine/src/main/java/com/arcadedb/query/sql/executor/CreateEdgeExecutionPlanner.java b/engine/src/main/java/com/arcadedb/query/sql/executor/CreateEdgeExecutionPlanner.java
index bc0858bbb..40c6e878b 100644
--- a/engine/src/main/java/com/arcadedb/query/sql/executor/CreateEdgeExecutionPlanner.java
+++ b/engine/src/main/java/com/arcadedb/query/sql/executor/CreateEdgeExecutionPlanner.java
@@ -53,9 +53,11 @@ public CreateEdgeExecutionPlanner(final CreateEdgeStatement statement) {
     this.ifNotExists = statement.ifNotExists();
     this.body = statement.getBody() == null ? null : statement.getBody().copy();
 
-    final JsonArray jsonArray = statement.getBody().getJsonArrayContent();
-    if (jsonArray != null && jsonArray.items.size() != 1)
-      throw new CommandSQLParsingException("Expected one entry in the json array as content");
+    if (statement.getBody() != null) {
+      final JsonArray jsonArray = statement.getBody().getJsonArrayContent();
+      if (jsonArray != null && jsonArray.items.size() != 1)
+        throw new CommandSQLParsingException("Expected one entry in the json array as content");
+    }
   }
 
   public InsertExecutionPlan createExecutionPlan(final CommandContext context, final boolean enableProfiling) {