diff --git a/plugin/filter/dialect.go b/plugin/filter/dialect.go index a6e15fa98..89de912db 100644 --- a/plugin/filter/dialect.go +++ b/plugin/filter/dialect.go @@ -222,7 +222,7 @@ func (d *PostgreSQLDialect) GetBooleanCheck(path string) string { } func (d *PostgreSQLDialect) GetTimestampComparison(field string) string { - return fmt.Sprintf("EXTRACT(EPOCH FROM %s.%s)", d.GetTablePrefix(), field) + return fmt.Sprintf("EXTRACT(EPOCH FROM TO_TIMESTAMP(%s.%s))", d.GetTablePrefix(), field) } func (*PostgreSQLDialect) GetCurrentTimestamp() string {