taosdata/TDengine

java.sql.SQLException: ERROR (0x2318): java.util.concurrent.TimeoutException: ERROR (0x231e): failed to complete the task within the specified time

Open

#23.615 aberto em 9 de nov. de 2023

Ver no GitHub
 (5 comments) (0 reactions) (1 assignee)C (5.002 forks)batch import
help wantedquestion

Métricas do repositório

Stars
 (24.849 stars)
Métricas de merge de PR
 (Mesclagem média 1d 1h) (4 fundiu PRs em 30d)

Description

TDengine使用的3.2.0.0版本，驱动版本为3.2.7。 执行subscribe方法时不报错，但是执行poll方法时可能会报错。 消费者组中有两个消费者，报错的为其中固定的一个。执行poll方法时，可能会阻塞一段时间然后报错，也可能正常执行。 错误信息：Caused by: java.sql.SQLException: ERROR (0x2318): java.util.concurrent.TimeoutException: ERROR (0x231e): failed to complete the task:{"action":"poll","args":{"blocking_time":100,"req_id":2}} within the specified time : 60000,MILLISECONDS at com.taosdata.jdbc.TSDBError.createSQLException(TSDBError.java:87) at com.taosdata.jdbc.ws.Transport.send(Transport.java:90) at com.taosdata.jdbc.ws.tmq.WSConsumer.poll(WSConsumer.java:109) at com.taosdata.jdbc.tmq.TaosConsumer.poll(TaosConsumer.java:93) at com.uniorange.dcs.consumer.ConsumerHandler.execute(ConsumerHandler.java:101) 此错误只在集群模式下会有，单体模式下消费者组可以正常使用 尝试增大CONNECT_MESSAGE_TIMEOUT参数的值，但是没有什么效果

Guia do colaborador

Direção de pesquisa
Investigue o tratamento de tempo limite do transporte WebSocket no método poll do WSConsumer (com.taosdata.jdbc.ws.tmq.WSConsumer.poll). Concentre se nas diferenças entre o modo cluster e o modo único. Verifique o uso do parâmetro CONNECT MESSAGE TIMEOUT. Procure por possíveis problemas de bloqueio ou tempo limite no método Transport.send.
Pilha de tecnologia
java
Domain
backenddatabase
Tipo Issue
Bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
3-5 dias
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Precisa de investigação
Prerequisites
JavaGit
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
40