Consultas no ClickHouse CloudOs dados nesta tabela de sistema são mantidos localmente em cada nó do ClickHouse Cloud. Portanto, para obter uma visão completa de todos os dados, é necessário usar a função
clusterAllReplicas. Consulte aqui para mais detalhes.Descrição
utils/async_loader_graph.
Colunas
job(String) — Nome do job (pode não ser único).job_id(UInt64) — ID único do job.dependencies(Array(UInt64)) — Lista de IDs de jobs que devem ser concluídos antes deste job.dependencies_left(UInt64) — Número atual de dependências que ainda precisam ser concluídas.status(Enum8(‘PENDING’ = 0, ‘OK’ = 1, ‘FAILED’ = 2, ‘CANCELED’ = 3)) — Status atual de carga de um job: PENDING: o job de carga ainda não foi iniciado. OK: o job de carga foi executado com sucesso. FAILED: o job de carga foi executado e falhou. CANCELED: o job de carga não será executado devido à remoção ou à falha de uma dependência.is_executing(UInt8) — O job está sendo executado no momento por um worker.is_blocked(UInt8) — O job aguarda a conclusão de suas dependências.is_ready(UInt8) — O job está pronto para ser executado e aguarda um worker.elapsed(Float64) — Segundos decorridos desde o início da execução. Zero se o job ainda não foi iniciado. Tempo total de execução se o job já foi concluído.pool_id(UInt64) — ID do pool atualmente atribuído ao job.pool(String) — Nome do poolpool_id.priority(Int64) — Prioridade do poolpool_id.execution_pool_id(UInt64) — ID do pool em que o job é executado. Corresponde inicialmente ao pool atribuído antes do início da execução.execution_pool(String) — Nome do poolexecution_pool_id.execution_priority(Int64) — Prioridade do pool execution_pool_id.ready_seqno(Nullable(UInt64)) — não nulo para jobs prontos. O worker retira da fila de prontos do seu pool o próximo job a ser executado. Se houver vários jobs prontos, será escolhido o job com o menor valor deready_seqno.waiters(UInt64) — Número de threads aguardando este job.exception(Nullable(String)) — não nulo para jobs com falha e cancelados. Armazena a mensagem de erro gerada durante a execução da consulta ou o erro que levou ao cancelamento deste job, juntamente com a cadeia de falhas de dependência envolvendo os nomes dos jobs.schedule_time(DateTime64(6)) — Momento em que o job foi criado e agendado para execução (geralmente com todas as suas dependências).enqueue_time(Nullable(DateTime64(6))) — Momento em que o job ficou pronto e foi enfileirado na fila de prontos do seu pool. Nulo se o job ainda não estiver pronto.start_time(Nullable(DateTime64(6))) — Momento em que o worker retira o job da fila de prontos e inicia sua execução. Nulo se o job ainda não foi iniciado.finish_time(Nullable(DateTime64(6))) — Momento em que a execução do job é concluída. Nulo se o job ainda não foi concluído.
is_executing(UInt8) - O job está sendo executado no momento por um worker.is_blocked(UInt8) - O job aguarda a conclusão de suas dependências.is_ready(UInt8) - O job está pronto para ser executado e aguarda um worker.elapsed(Float64) - Segundos decorridos desde o início da execução. Zero se o job ainda não tiver sido iniciado. Tempo total de execução se o job já tiver sido concluído.
priority menor) são executados primeiro. Nenhum job com prioridade mais baixa é iniciado enquanto houver pelo menos um job de prioridade mais alta pronto ou em execução. A prioridade de um job pode ser elevada (mas não reduzida) ao priorizá-lo. Por exemplo, jobs de carregamento e inicialização de tabela serão priorizados se uma consulta de entrada exigir essa tabela. É possível priorizar um job durante sua execução, mas o job não é movido do seu execution_pool para o pool recém-atribuído. O job usa pool para criar novos jobs, a fim de evitar inversão de prioridade. Jobs já iniciados não sofrem preempção por jobs de prioridade mais alta e, depois de iniciados, sempre são executados até a conclusão.
-
pool_id(UInt64) - ID do pool atualmente atribuído ao job. -
pool(String) - Nome do poolpool_id. -
priority(Int64) - Prioridade do poolpool_id. -
execution_pool_id(UInt64) - ID do pool em que o job é executado. Inicialmente, é igual ao pool atribuído antes do início da execução. -
execution_pool(String) - Nome do poolexecution_pool_id. -
execution_priority(Int64) - Prioridade do poolexecution_pool_id. -
ready_seqno(Nullable(UInt64)) - Não nulo para jobs prontos. O worker extrai o próximo job a ser executado da fila de prontos do seu pool. Se houver vários jobs prontos, será escolhido o job com o menor valor deready_seqno. -
waiters(UInt64) - Número de threads esperando por esse job. -
exception(Nullable(String)) - Não nulo para jobs com falha e cancelados. Contém a mensagem de erro gerada durante a execução da consulta ou o erro que levou ao cancelamento desse job, juntamente com a cadeia de falha de dependência dos nomes dos jobs.
schedule_time(DateTime64) - Momento em que o job foi criado e agendado para execução (geralmente com todas as suas dependências).enqueue_time(Nullable(DateTime64)) - Momento em que o job ficou pronto e foi enfileirado na fila de prontos do seu pool. Nulo se o job ainda não estiver pronto.start_time(Nullable(DateTime64)) - Momento em que o worker remove o job da fila de prontos e inicia sua execução. Nulo se o job ainda não tiver sido iniciado.finish_time(Nullable(DateTime64)) - Momento em que a execução do job é concluída. Nulo se o job ainda não tiver sido concluído.