not sure why exists is uint8 instead of bool, but ok

flow/connectors/clickhouse/cdc.go

@@ -2,6 +2,7 @@ package connclickhouse
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"log/slog"
 	"strings"
@@ -28,7 +29,7 @@ func (c *ClickHouseConnector) getRawTableName(flowJobName string) string {
 
 func (c *ClickHouseConnector) checkIfTableExists(ctx context.Context, databaseName string, tableIdentifier string) (bool, error) {
 	// TODO escape
-	var existsC chproto.ColBool
+	var existsC chproto.ColUInt8
 	if err := c.query(ctx, ch.Query{
 		Body: fmt.Sprintf(checkIfTableExistsSQL, "'"+databaseName+"'", "'"+tableIdentifier+"'"),
 		Result: chproto.Results{
@@ -38,12 +39,15 @@ func (c *ClickHouseConnector) checkIfTableExists(ctx context.Context, databaseNa
 			if block.Rows != 1 {
 				return fmt.Errorf("[clickhouse] checkIfTableExists: expected 1 row, got %d", block.Rows)
 			}
+			if block.Info.Overflows {
+				return errors.New("[clickhouse] checkIfTableExists: expected 1 row, got block with overflow")
+			}
 			return nil
 		},
 	}); err != nil {
 		return false, fmt.Errorf("error while reading result row: %w", err)
 	}
-	return existsC[0], nil
+	return existsC[0] != 0, nil
 }
 
 func (c *ClickHouseConnector) CreateRawTable(ctx context.Context, req *protos.CreateRawTableInput) (*protos.CreateRawTableOutput, error) {