Если вы используете ExecuteSQL и выбираете все узлы, то один и тот же запрос выполняется на всех узлах.
Если вы хотите использовать поведение, подобное sqoop, вам нужно использовать процессоры, такие как GenerateTableFetch, только на основном узле, а затем использовать соединение с балансировкой нагрузки, подключенное к ExecuteSQL, чтобы запросы выборки распределялись по кластеру.