From c485a9274cee3f3dd066e47b2d9723189a098580 Mon Sep 17 00:00:00 2001
From: Deepyaman Datta <deepyaman.datta@utexas.edu>
Date: Wed, 13 Sep 2023 23:16:57 -0600
Subject: [PATCH] fix(flink): translate `ops.RandomScalar` to `rand`

---
 ibis/backends/flink/registry.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ibis/backends/flink/registry.py b/ibis/backends/flink/registry.py
index 7fe220337f2f..db7f55ab8a54 100644
--- a/ibis/backends/flink/registry.py
+++ b/ibis/backends/flink/registry.py
@@ -195,6 +195,7 @@ def _floor_divide(translator: ExprTranslator, op: ops.Node) -> str:
     {
         # Unary operations
         ops.NullIfZero: _nullifzero,
+        ops.RandomScalar: lambda *_: "rand()",
         ops.Degrees: unary("degrees"),
         ops.Radians: unary("radians"),
         # Unary aggregates