bug(flink): unit is ignored when str cast to timestamp

ted0928 · ted0928 · commit 0bcf16f56f24 · 2025-04-28T16:30:24.000+08:00
diff --git a/ibis/backends/sql/compilers/flink.py b/ibis/backends/sql/compilers/flink.py
@@ -423,6 +423,8 @@ def visit_Cast(self, op, *, arg, to):
                     self.f.convert_tz(self.cast(arg, dt.string), "UTC+0", tz)
                 )
             else:
+                if to.unit == dt.TimestampUnit.SECOND:
+                    return self.f.to_timestamp(arg)
                 return self.f.to_timestamp(arg, "yyyy-MM-dd HH:mm:ss.SSS")
         elif to.is_json():
             return arg

Original file line number	Diff line number	Diff line change
`@@ -423,6 +423,8 @@ def visit_Cast(self, op, *, arg, to):`
`423`	`423`	`self.f.convert_tz(self.cast(arg, dt.string), "UTC+0", tz)`
`424`	`424`	`)`
`425`	`425`	`else:`
	`426`	`+ if to.unit == dt.TimestampUnit.SECOND:`
	`427`	`+ return self.f.to_timestamp(arg)`
`426`	`428`	`return self.f.to_timestamp(arg, "yyyy-MM-dd HH:mm:ss.SSS")`
`427`	`429`	`elif to.is_json():`
`428`	`430`	`return arg`