это точно нельзя или новый инстанс (пер партицию - хватит) или блокировки (зато пер экзекутор)
сериалайзеры (T => InternalRow) могут быть не тредсейфны по результату еще т.е. все InternalRow в резульатате будут одинаковые и заполнены последним обращением к сериалайзеру (это конечно смешно, т.е. сериалайзер ретернит пойнтер на буфер мутабельный)
Я кстати не первый раз слышу про использование эластика как “dwh”, но вот не понимаю какие при этом у эластика ограничения и преимущества перед mpp dbms. Можешь кратко поделиться?