Spark Job застревает в последних задачах, когда префикс запроса на BigTable - PullRequest
0 голосов
/ 08 января 2020

введите описание изображения здесь введите описание изображения здесь Моя работа Spark часто застревает в последней задаче запроса таблицы Google Cloud BigTable.

Query query = Query.create(tableName).prefix(prefixRowKey);
ServerStream<Row> rowStream = bigtableDataClient.readRows(query);

Найти под дампом потока, когда исполнитель находится в застрявшей фазе:

Дамп потока исполнителя

Задание (пользовательский интерфейс пряжи) застряло в последнем задании

...