ch: set alter_sync to 1 (#2999)

serprex · web-flow · commit 791a9cb3f1ae · 2025-06-03T16:22:26.000+05:30
diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
@@ -236,6 +236,8 @@ func Connect(ctx context.Context, env map[string]string, config *protos.Clickhou
 		"select_sequential_consistency": uint64(1),
 		// broken downstream views should not interrupt ingestion
 		"ignore_materialized_views_with_dropped_target_table": true,
+		// avoid "there is no metadata of table ..."
+		"alter_sync": uint64(1),
 	}
 	if maxInsertThreads, err := internal.PeerDBClickHouseMaxInsertThreads(ctx, env); err != nil {
 		return nil, fmt.Errorf("failed to load max_insert_threads config: %w", err)

Original file line number	Diff line number	Diff line change
`@@ -236,6 +236,8 @@ func Connect(ctx context.Context, env map[string]string, config *protos.Clickhou`
`236`	`236`	`"select_sequential_consistency": uint64(1),`
`237`	`237`	`// broken downstream views should not interrupt ingestion`
`238`	`238`	`"ignore_materialized_views_with_dropped_target_table": true,`
	`239`	`+ // avoid "there is no metadata of table ..."`
	`240`	`+ "alter_sync": uint64(1),`
`239`	`241`	`}`
`240`	`242`	`if maxInsertThreads, err := internal.PeerDBClickHouseMaxInsertThreads(ctx, env); err != nil {`
`241`	`243`	`return nil, fmt.Errorf("failed to load max_insert_threads config: %w", err)`