Exceptions on Reason: 'timeout' and 'null'

Aperta

#585 aperta il 26/6/2023 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà: 4/5
Tempo stimato: 3-5 giorni
Idoneità per principianti: 25/100

Tipo di issue: Bug
Chiarezza: Da chiarire
Stato di attività: Ferma
Stack tecnologico: java
Ambito: api

Direzione di ricerca

Inizia dai punti di ingresso dello stack trace in AbstractRestClient.toInfluxException e AbstractWriteClient, quindi segui il modo in cui writeTimeout e la gestione dei retry producono le motivazioni registrate nei log. Usa la configurazione indicata con InfluxDB 2.7.1, client 6.7.0, JDK 8 e Linux per riprodurre il carico di scrittura di lunga durata. Il lavoro è completo quando la causa dei risultati timeout e null è confermata e sono disponibili una correzione convalidata o una risoluzione documentata.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

Hi there,
There are some ‘timeout’ errors as follows when I run a Java Spring program with influxdb-client-java. Could someone tell me how to fix these errors? Thanks a lot.

Steps to reproduce:
List the minimal actions needed to reproduce the behavior.

setup InfluxDB version 2.7.1 on cloud VM;
setup a Java Spring program with Influxdb-client-java version 6.7.0;
setup the influx.writeTimeout = 15S;
write a lot of data to InfluxDB with this program;
run this program for at last a week, there are some 'timeout' and 'null' erros:

Expected behavior:
There are no 'timeout' or 'null' errors.

Actual behavior:
there are some 'timeout' and 'null' erros:

error logs

2023-06-24 17:00:15,715 WARN  [RxNewThreadScheduler-1] com.influxdb.client.write.events.WriteRetriableErrorEvent: The retriable error occurred during writing of data. Reason: 'timeout'. Retry in: 18.225s.
2023-06-24 17:00:44,143 WARN  [RxNewThreadScheduler-463230] com.influxdb.client.write.events.WriteRetriableErrorEvent: The retriable error occurred during writing of data. Reason: 'timeout'. Retry in: 37.234s.
2023-06-24 17:01:21,714 WARN  [RxNewThreadScheduler-463231] com.influxdb.client.write.events.WriteRetriableErrorEvent: The retriable error occurred during writing of data. Reason: 'null'. Retry in: 50.281s.
2023-06-24 17:02:12,110 WARN  [RxNewThreadScheduler-463232] com.influxdb.client.write.events.WriteRetriableErrorEvent: The retriable error occurred during writing of data. Reason: 'null'. Retry in: 85.256s.
2023-06-24 17:03:05,626 ERROR [RxNewThreadScheduler-463229] com.influxdb.client.write.events.WriteErrorEvent: The error occurred during writing of data
com.influxdb.exceptions.InfluxException: Max retry time exceeded.
	at com.influxdb.internal.AbstractRestClient.toInfluxException(AbstractRestClient.java:102)
	at com.influxdb.client.internal.AbstractWriteClient.lambda$new$8(AbstractWriteClient.java:174)
	at io.reactivex.rxjava3.internal.subscribers.LambdaSubscriber.onNext(LambdaSubscriber.java:65)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoFinally$DoFinallySubscriber.onNext(FlowableDoFinally.java:85)
	at io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain(FlowableConcatMapMaybe.java:238)
	at io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.innerSuccess(FlowableConcatMapMaybe.java:119)
	at io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber$ConcatMapMaybeObserver.onSuccess(FlowableConcatMapMaybe.java:276)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorNext$OnErrorNextMaybeObserver$NextMaybeObserver.onSuccess(MaybeOnErrorNext.java:122)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeJust.subscribeActual(MaybeJust.java:36)
	at io.reactivex.rxjava3.core.Maybe.subscribe(Maybe.java:5375)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorNext$OnErrorNextMaybeObserver.onError(MaybeOnErrorNext.java:97)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybePeek$MaybePeekObserver.onErrorInner(MaybePeek.java:147)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybePeek$MaybePeekObserver.onError(MaybePeek.java:134)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeMap$MapMaybeObserver.onError(MaybeMap.java:95)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutMaybe$TimeoutFallbackMaybeObserver.onError(MaybeTimeoutMaybe.java:195)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeError.subscribeActual(MaybeError.java:35)
	at io.reactivex.rxjava3.core.Maybe.subscribe(Maybe.java:5375)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutMaybe$TimeoutMainMaybeObserver.otherComplete(MaybeTimeoutMaybe.java:133)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutMaybe$TimeoutOtherMaybeObserver.onSuccess(MaybeTimeoutMaybe.java:158)
	at io.reactivex.rxjava3.internal.operators.maybe.MaybeTimer$TimerDisposable.run(MaybeTimer.java:58)
	at io.reactivex.rxjava3.core.Scheduler$DisposeTask.run(Scheduler.java:644)
	at io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable.run(ScheduledRunnable.java:65)
	at io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable.call(ScheduledRunnable.java:56)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.util.concurrent.TimeoutException: Max retry time exceeded.
	at com.influxdb.client.internal.AbstractWriteClient$ToWritePointsMaybe.apply(AbstractWriteClient.java:501)
	at com.influxdb.client.internal.AbstractWriteClient$ToWritePointsMaybe.apply(AbstractWriteClient.java:432)
	at io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe$ConcatMapMaybeSubscriber.drain(FlowableConcatMapMaybe.java:219)
	at io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber.onNext(ConcatMapXMainSubscriber.java:106)
	at com.influxdb.client.internal.flowable.BackpressureBatchesBufferStrategy$OnBackpressureBufferStrategySubscriber.drain(BackpressureBatchesBufferStrategy.java:238)
	at com.influxdb.client.internal.flowable.BackpressureBatchesBufferStrategy$OnBackpressureBufferStrategySubscriber.onNext(BackpressureBatchesBufferStrategy.java:149)
	at com.influxdb.client.internal.flowable.BackpressureBatchesBufferStrategy$OnBackpressureBufferStrategySubscriber.onNext(BackpressureBatchesBufferStrategy.java:54)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.tryEmitScalar(FlowableFlatMap.java:232)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.onNext(FlowableFlatMap.java:150)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFilter$FilterSubscriber.tryOnNext(FlowableFilter.java:75)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFilter$FilterSubscriber.onNext(FlowableFilter.java:53)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.tryEmit(FlowableFlatMap.java:270)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onNext(FlowableFlatMap.java:627)
	at io.reactivex.rxjava3.internal.operators.flowable.FlowableMap$MapSubscriber.onNext(FlowableMap.java:69)
	at io.reactivex.rxjava3.subscribers.SerializedSubscriber.onNext(SerializedSubscriber.java:103)
	at com.influxdb.client.internal.flowable.FlowableBufferTimedFlushable$BufferExactBoundedSubscriber.accept(FlowableBufferTimedFlushable.java:227)
	at com.influxdb.client.internal.flowable.FlowableBufferTimedFlushable$BufferExactBoundedSubscriber.accept(FlowableBufferTimedFlushable.java:85)
	at io.reactivex.rxjava3.internal.subscribers.QueueDrainSubscriber.fastPathOrderedEmitMax(QueueDrainSubscriber.java:107)
	at com.influxdb.client.internal.flowable.FlowableBufferTimedFlushable$BufferExactBoundedSubscriber.run(FlowableBufferTimedFlushable.java:281)
	at io.reactivex.rxjava3.core.Scheduler$Worker$PeriodicTask.run(Scheduler.java:543)
	... 8 common frames omitted

Specifications:

Client Version: Influxdb-client-java 6.7.0
InfluxDB Version: 2.7.1
JDK Version: JDK 8
Platform: Linux

Lingua principale: Java
Stelle: 477
Fork: 129
Metriche di merge delle PR: Nessuna PR unita negli ultimi 30g

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Come iniziare

Leggi tutta la issue e poi la guida ai contributi del progetto.
Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
Fai un fork del repository e lavora su un branch.
Apri una pull request che faccia riferimento al numero della issue.

Altre issue di influxdata/influxdb-client-java

mTLS Support (Client Certificates) Aperta

Difficoltà 4/5 3-5 giorni Idoneità per principianti 52/100

influxdata/influxdb-client-java#947 · Aperta il 6/8/2026
influxdb-spring 7.4.0 is not compatible with Spring Boot 4.x (Actuator package changes) Aperta

Difficoltà 4/5 3-5 giorni Idoneità per principianti 45/100

influxdata/influxdb-client-java#849 · 4 commenti · Aperta il 29/12/2025
Question : logs or throwing exceptions ? Aperta

Difficoltà 5/5 Più di una settimana Idoneità per principianti 25/100

influxdata/influxdb-client-java#847 · Aperta il 4/11/2025
InfluxQLQuery show series has no result end parse Aperta

Difficoltà 3/5 1-2 giorni Idoneità per principianti 35/100

influxdata/influxdb-client-java#830 · 1 commento · Aperta il 17/7/2025
InfluxQLQueryApi.queryJson should not transform all values to String Aperta

Difficoltà 3/5 1-2 giorni Idoneità per principianti 38/100

influxdata/influxdb-client-java#820 · Aperta il 3/2/2025

Tutte le issue di influxdata/influxdb-client-java

Issue simili

Azure Sandboxes: Small and ExtraSmall tiers always fail to deploy (disk request exceeds tier maximum) Aperta

area-deployment area-integrations triage:bot-seen

Difficoltà 2/5 Mezza giornata Idoneità per principianti 86/100

microsoft/aspire#20459 · 1 commento · Aperta il 24/9/2026
[Bug][api] ContextRetrievalRequestEvent accepts a non-positive max_results Aperta

Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100

apache/flink-agents#1156 · Aperta il 24/9/2026
[source-shopify] FAILED bulk operation without partialDataUrl is silently treated as successful Aperta

area/connectors autoteam community connectors/source/shopify needs-triage team/use type/bug

Difficoltà 2/5 1-3 ore Idoneità per principianti 84/100

airbytehq/airbyte#86962 · Aperta il 24/9/2026
`check_required_components()` in HDF5's CMake package configuration file doesn't function Aperta

Difficoltà 2/5 1-3 ore Idoneità per principianti 70/100

HDFGroup/hdf5#6690 · Aperta il 24/9/2026
[Bug] FE metric http_copy_into_query_err_total is registered under the upload error name Aperta

Difficoltà 1/5 Meno di un'ora Idoneità per principianti 85/100

apache/doris#68505 · 2 commenti · Aperta il 24/9/2026

Altre issue su Java