From 15b9be2ffaaa8dcd1a5e505444225bac70f4eceb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 30 Jan 2024 21:28:34 +0000 Subject: [PATCH] timestamptz, use json --- flow/connectors/external_metadata/store.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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))