请问下多个表关联,这种flink sql如何优化呢,直接关联优点跑不动RuntimeExecutionMode.STREAMING 模式
select date_format(a.create_time, 'yyyy-MM-dd HH:mm:ss') as create_time, b.vehicle_code, a.item_name, a.item_value, c.item_value as vehicle_score, d.current_fault, e.history_fault, f.late_mileage, g.fault_level_event_count, h.current_fault_subsystem, i.history_fault_subsystem from fault_record_subsystem a join mtr_vehicle_use b on a.vehicle_id = b.vehicle_id join fault_record_vehicle c on a.vehicle_id = c.vehicle_id join fault_record_current_count d on a.vehicle_id = d.vehicle_id join fault_record_history_count e on a.vehicle_id = e.vehicle_id join vehicle_usage_score f on a.vehicle_id = f.vehicle_id join fault_record_level_event_count g on a.vehicle_id = g.vehicle_id join fault_record_current_count_subsystem h on a.vehicle_id = h.vehicle_id and a.item_name = h.item_name join fault_record_history_count_subsystem i on a.vehicle_id = i.vehicle_id and a.item_name = i.item_name