Hi Ahmad, afaik that's not directly supported and would not work well with how Flink is designed now, since new joins would potentially require new network connections.
You can, however, execute ad-hoc SQL queries against an already running Flink cluster. Additionally, if your SQL is rather simple (filter/transform/join in static forms), you can use Calcite to execute SQL inside a UDF. So you'd send your SQL query through a broadcast to all operators, interpret and apply it that in your user code. I have built something similar in the past and could give more details. On Wed, Jan 13, 2021 at 4:54 AM Ahmad Alkilani <amk...@gmail.com> wrote: > Is it possible to dynamically, as the flink application is running, inject > new SQL to be executed against a stream? > > Thank you! > >> -- Arvid Heise | Senior Java Developer <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Toni) Cheng
