Good evening all, We are working on a project where a few queries that are joining based on dates from table A are between dates from table B. Something like:
SELECT A.ID, B.NAME FROM A, B WHERE A.DATE BETWEEN B.START_DATE AND B.END_DATE; Both A and B are topics in Kafka with 5 partitions. Doing a simple test of selecting * on each one will yield tasks with a parallelism of 5, which tells me we have parallelism working in flink. BUT, when we attempt the query I pasted above, the BETWEEN clause doesn't parallelize. I'd like to get your expert opinion on this and get your help on how to force this to parallelize. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io <kpatter...@carrera.io> <http://us.linkedin.com/in/jasonpolitis>
