diff --git a/modules/ballerina-core/src/main/java/org/ballerinalang/model/DataTableJSONDataSource.java b/modules/ballerina-core/src/main/java/org/ballerinalang/model/DataTableJSONDataSource.java
index 0e52bda20f7d..2f023a187448 100644
--- a/modules/ballerina-core/src/main/java/org/ballerinalang/model/DataTableJSONDataSource.java
+++ b/modules/ballerina-core/src/main/java/org/ballerinalang/model/DataTableJSONDataSource.java
@@ -54,6 +54,7 @@ public void serialize(JsonGenerator gen) throws IOException {
         while (this.df.next()) {
             this.objGen.transform(this.df).serialize(gen, null);
         }
+        gen.writeEndArray();
         this.df.close();
     }