Поток данных CoGroupByKey очень медленный - более 10000 элементов на ключ

Возможно, вы закрыли либо Connection, либо Statement, которые сделали ResultSet, что приведет к закрытию ResultSet.