[
https://issues.apache.org/jira/browse/BAHIR-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683463#comment-17683463
]
ASF subversion and git services commented on BAHIR-321:
-------------------------------------------------------
Commit 724e17c4481fb12c1ab14608dd04b974d6f5e090 in bahir-flink's branch
refs/heads/master from Balazs Varga
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=724e17c ]
[BAHIR-321] Make KuduFilterInfo handle String literals
> Kudu lookup join fails with String literal in WHERE clause
> ----------------------------------------------------------
>
> Key: BAHIR-321
> URL: https://issues.apache.org/jira/browse/BAHIR-321
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
> Reporter: Balazs Varga
> Priority: Major
>
> When performing a (processing time) temporal table join with a Kudu table,
> and using a String literal in the WHERE condition:
> {code:java}
> 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';{code}
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
