Hi All! We hit a the following problem with SQL and trying to understand if there is a valid workaround.
We have 2 tables: *Kafka* timestamp (ROWTIME) item quantity *Hive* item price So we basically have incoming (ts, id, quantity) and we want to join it with the hive table to get the total price (price * quantity) got the current item. After this we want to create window aggregate on quantity*price windowed on timestamp (event time attribute). In any way we formulate this query we hit the following error: org.apache.flink.table.api.TableException: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before. I understand that the problem is that we cannot join with the Hive table and still maintain the watermark/even time column. But why is this? In datastream world I would just simply assign Max watermark to my enrichment input and join outputs will get the ts of the input record. Can I achieve something similar in SQL/Table api? Thank you! Gyula
