Вы должны написать свои паркетные файлы с меньшим размером блока. Значение по умолчанию - 128 Мб на блок, но его можно настроить, установив конфигурацию parquet.block.size
в записи.
Источник ParquetOuputFormat здесь , если вы хотите вникнуть в детали.
Размер блока - это минимальный объем данных, которые вы можете прочитать из файл паркета, который является логически читаемым (поскольку паркет столбчатый, вы не можете просто разделить по строке или что-то тривиальное, как это), поэтому вы не можете иметь больше потоков чтения, чем входные блоки.
С помощью этого кода let currentUser = this.authenticationService.currentUserValue;
вы назначаете «функцию», а не результат.
Так что просто оцените функцию, чтобы получить возвращенный объект, замените на:
let currentUser = this.authenticationService.currentUserValue();
Вы определили currentUserValue
как функцию, а не свойство, поэтому вы должны вызвать ее, чтобы получить User
данные. Вы не звоните this.authenticationService.currentUserValue
Нужно выполнить:
let currentUser = this.authenticationService.currentUserValue();