diff --git a/ibis/backends/sql/compilers/flink.py b/ibis/backends/sql/compilers/flink.py index 1b313f924932..72fa6fad0dd8 100644 --- a/ibis/backends/sql/compilers/flink.py +++ b/ibis/backends/sql/compilers/flink.py @@ -328,6 +328,10 @@ def visit_TryCast(self, op, *, arg, to): ) return sge.TryCast(this=arg, to=type_mapper.from_ibis(to)) + def visit_Divide(self, op, *, left, right): + dtype = op.dtype + return self.cast(left, dtype) / self.cast(right, dtype) + def visit_FloorDivide(self, op, *, left, right): return self.f.floor(sge.paren(left) / sge.paren(right))