Regression fix

Author: mieciu

platform/ingest/ast.go

@@ -53,7 +53,7 @@ func (ct CreateTableStatement) ToSQL() string {
 	var b strings.Builder
 
 	if ct.Cluster != "" {
-		b.WriteString(fmt.Sprintf(`CREATE TABLE IF NOT EXISTS "%s" ON CLUSTER "%s"`+" \n(\n\n", ct.Name, ct.Cluster))
+		b.WriteString(fmt.Sprintf(`CREATE TABLE IF NOT EXISTS "%s" ON CLUSTER "%s"`+" \n", ct.Name, ct.Cluster))
 	} else {
 		b.WriteString(fmt.Sprintf(`CREATE TABLE IF NOT EXISTS "%s"`, ct.Name))
 	}

platform/ingest/processor.go

@@ -991,6 +991,9 @@ func (ip *IngestProcessor) executeStatements(ctx context.Context, queries []stri
 
 		err := ip.execute(ctx, q)
 		if err != nil {
+			if strings.Contains(q, "CREATE") { // always log table creation failures
+				logger.Error().Err(err).Msgf("Error executing DDL: %s", q)
+			}
 			count := ip.errorLogCounter.Add(1)
 
 			// Limit the number of error logs to avoid flooding the logs.