[jira] [Commented] (BAHIR-321) Kudu lookup join fails with String literal in WHERE clause

2023-02-06 Thread ASF subversion and git services (Jira) 


[ 
https://issues.apache.org/jira/browse/BAHIR-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684593#comment-17684593
 ] 

ASF subversion and git services commented on BAHIR-321:
---

Commit 724e17c4481fb12c1ab14608dd04b974d6f5e090 in bahir-flink's branch 
refs/heads/BAHIR-308 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.Stringat 
> 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)

[jira] [Commented] (BAHIR-321) Kudu lookup join fails with String literal in WHERE clause

2023-02-02 Thread ASF subversion and git services (Jira) 


[ 
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.Stringat 
> 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)

[jira] [Commented] (BAHIR-321) Kudu lookup join fails with String literal in WHERE clause

2023-01-03 Thread Balazs Varga (Jira) 


[ 
https://issues.apache.org/jira/browse/BAHIR-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654109#comment-17654109
 ] 

Balazs Varga commented on BAHIR-321:


I have a proposed solution:

https://github.com/apache/bahir-flink/pull/161

> 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.Stringat 
> 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)