chore: revert flink compiler change

ibis-project · Oct 10, 2024 · 055da77 · 055da77
1 parent e877e0d
commit 055da77
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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