feat(pyflink): fix type mapping from BINARY to VARBINARY

Author: ted0928

ibis/backends/sql/dialects.py

@@ -222,6 +222,8 @@ class Generator(Hive.Generator):
         TYPE_MAPPING = Hive.Generator.TYPE_MAPPING.copy() | {
             sge.DataType.Type.TIME: "TIME",
             sge.DataType.Type.STRUCT: "ROW",
+            sge.DataType.Type.BINARY: "VARBINARY",
+            sge.DataType.Type.VARBINARY: "VARBINARY",
         }
 
         TRANSFORMS = Hive.Generator.TRANSFORMS.copy() | {

ibis/backends/tests/test_binary.py

@@ -16,7 +16,7 @@
     "trino": "varbinary",
     "postgres": "bytea",
     "risingwave": "bytea",
-    "flink": "BINARY(1) NOT NULL",
+    "flink": "BYTES NOT NULL",
     "databricks": "binary",
     "athena": "varbinary",
 }