Hey everyone. In flink(SQL) 1.15.3, is there a wa...
# troubleshooting
j
Hey everyone. In flink(SQL) 1.15.3, is there a way to force the broadcast of a table, similar to the new hints in 1.16? I have a table A with only 225 records, they are date ranges with an ID. Table B that i'm joining to it has 7mil+ records and a date. If the date of a record in table B falls between the date range of a record in table A then it'll receive the ID. This date range comparison is forcing the join operator to parallelism of 1. Or, is there a way to force these tables to partition on a date range somehow? Thanks