Uploaded image for project: 'Bahir (Retired)'
  1. Bahir (Retired)
  2. BAHIR-321

Kudu lookup join fails with String literal in WHERE clause

    XMLWordPrintableJSON

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

          Activity

            People

              Unassigned Unassigned
              bvarga Balazs Varga
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: