Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
When performing a (processing time) temporal table join with a Kudu table, and using a String literal in the WHERE condition:
SELECT d.sensor_id, k.sensor_type, d.`value` FROM datagen AS d JOIN `kudu`.`default_database`.`default.sensors` FOR SYSTEM_TIME AS OF d.proctime as k ON k.sensor_id = d.sensor_id WHERE sensor_type = 'pressure';
We get the following error:
Caused by: java.lang.ClassCastException: org.apache.flink.table.data.binary.BinaryStringData cannot be cast to java.lang.String at org.apache.flink.connectors.kudu.connector.KuduFilterInfo.predicateComparator(KuduFilterInfo.java:68)
This is because in KuduFilterInfo it tries to cast the literal, which is a BinaryStringData, to a String.
Attachments
Issue Links
- links to