diff --git a/ibis/backends/sql/compilers/flink.py b/ibis/backends/sql/compilers/flink.py index 95d54fd30385..2cbb7163a034 100644 --- a/ibis/backends/sql/compilers/flink.py +++ b/ibis/backends/sql/compilers/flink.py @@ -453,7 +453,7 @@ def visit_DayOfWeekName(self, op, *, arg): return lookup_table[index] def visit_TimestampNow(self, op): - return self.cast(self.v.current_timestamp, dt.timestamp) + return self.v.current_timestamp def visit_DateNow(self, op): return self.v.current_date