diff --git a/flow/connectors/external_metadata/store.go b/flow/connectors/external_metadata/store.go
index cefe7706e9..3be58019b8 100644
--- a/flow/connectors/external_metadata/store.go
+++ b/flow/connectors/external_metadata/store.go
@@ -124,7 +124,7 @@ func (p *PostgresMetadataStore) SetupMetadata() error {
 		CREATE TABLE IF NOT EXISTS `+p.QualifyTable(lastSyncStateTableName)+`(
 			job_name TEXT PRIMARY KEY NOT NULL,
 			last_offset BIGINT NOT NULL,
-			updated_at TIMESTAMP NOT NULL DEFAULT NOW(),
+			updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
 			sync_batch_id BIGINT NOT NULL,
 			normalize_batch_id BIGINT
 		)`)
@@ -137,9 +137,9 @@ func (p *PostgresMetadataStore) SetupMetadata() error {
 		CREATE TABLE IF NOT EXISTS `+p.QualifyTable(qrepTableName)+`(
 			job_name TEXT NOT NULL,
 			partition_id TEXT NOT NULL,
-			sync_partition TEXT NOT NULL,
-			sync_start_time TIMESTAMP NOT NULL,
-			sync_finish_time TIMESTAMP NOT NULL DEFAULT NOW()
+			sync_partition JSON NOT NULL,
+			sync_start_time TIMESTAMPTZ NOT NULL,
+			sync_finish_time TIMESTAMPTZ NOT NULL DEFAULT NOW()
 		)`)
 	if err != nil && !utils.IsUniqueError(err) {
 		p.logger.Error("failed to create qrep metadata table", slog.Any("error", err))