Allays drop tables

gabotechs · gabotechs · commit 9e04891872b9 · 2025-11-18T13:57:34.000+01:00
diff --git a/benchmarks/cdk/bin/datafusion-bench.ts b/benchmarks/cdk/bin/datafusion-bench.ts
@@ -152,7 +152,10 @@ function createTablesSql (sf: number): string {
     "supplier",
   ]) {
     // language=SQL format=false
-    stmt += `CREATE EXTERNAL TABLE IF NOT EXISTS ${tbl} STORED AS PARQUET LOCATION 's3://datafusion-distributed-benchmarks/tpch_sf${sf}/${tbl}/';\n`
+    stmt += `
+    DROP TABLE IF EXISTS ${tbl};
+    CREATE EXTERNAL TABLE IF NOT EXISTS ${tbl} STORED AS PARQUET LOCATION 's3://datafusion-distributed-benchmarks/tpch_sf${sf}/${tbl}/';
+ `
   }
   return stmt
 }

Original file line number	Diff line number	Diff line change
`@@ -152,7 +152,10 @@ function createTablesSql (sf: number): string {`
`152`	`152`	`"supplier",`
`153`	`153`	`]) {`
`154`	`154`	`// language=SQL format=false`
`155`		- stmt += `CREATE EXTERNAL TABLE IF NOT EXISTS ${tbl} STORED AS PARQUET LOCATION 's3://datafusion-distributed-benchmarks/tpch_sf${sf}/${tbl}/';\n`
	`155`	+ stmt += `
	`156`	`+ DROP TABLE IF EXISTS ${tbl};`
	`157`	`+ CREATE EXTERNAL TABLE IF NOT EXISTS ${tbl} STORED AS PARQUET LOCATION 's3://datafusion-distributed-benchmarks/tpch_sf${sf}/${tbl}/';`
	`158`	+ `
`156`	`159`	`}`
`157`	`160`	`return stmt`
`158`	`161`	`}`