diff --git a/server/adaptors/integrations/__data__/repository/amazon_vpc_flow/assets/create_table_vpc_schema-1.0.0.sql b/server/adaptors/integrations/__data__/repository/amazon_vpc_flow/assets/create_table_vpc_schema-1.0.0.sql
index 96bceab39e..baa4c146e4 100644
--- a/server/adaptors/integrations/__data__/repository/amazon_vpc_flow/assets/create_table_vpc_schema-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/amazon_vpc_flow/assets/create_table_vpc_schema-1.0.0.sql
@@ -1,35 +1,21 @@
 CREATE EXTERNAL TABLE IF NOT EXISTS {table_name} (
     version int,
-    account_id string,
-    interface_id string,
-    srcaddr string,
-    dstaddr string,
-    srcport int,
-    dstport int,
+    accountId string,
+    interfaceId string,
+    srcAddr string,
+    dstAddr string,
+    srcPort int,
+    dstPort int,
     protocol bigint,
     packets bigint,
     bytes bigint,
     start bigint,
     `end` bigint,
     action string,
-    log_status string,
-    vpc_id string,
-    subnet_id string,
-    instance_id string,
-    tcp_flags int,
-    type string,
-    pkt_srcaddr string,
-    pkt_dstaddr string,
-    region string,
-    az_id string,
-    sublocation_type string,
-    sublocation_id string,
-    pkt_src_aws_service string,
-    pkt_dst_aws_service string,
-    flow_direction string,
-    traffic_path int
+    logStatus string
 )
-USING parquet
+ROW FORMAT DELIMITED
+FIELDS TERMINATED BY ' '
 OPTIONS (
   recursiveFileLookup='true'
 )