ouyangwulin created FLINK-14210:
-----------------------------------
Summary: influxdb reporter add connect timeout and write timeout
config options for decrease timeout exception
Key: FLINK-14210
URL: https://issues.apache.org/jira/browse/FLINK-14210
Project: Flink
Issue Type: Improvement
Components: Runtime / Metrics
Affects Versions: 1.9.0, 1.10.0
Reporter: ouyangwulin
Fix For: 1.10.0
When we run influxdb reporter in product env, It log timeout exception in
taskmananger log.
The execption log is :
2019-07-23 14:05:22,044 WARN
org.apache.flink.runtime.metrics.MetricRegistryImpl - Error while reporting
metrics
java.lang.RuntimeException: java.net.SocketTimeoutException: timeout
at
org.apache.flink.metrics.influxdb.shaded.org.influxdb.impl.InfluxDBImpl.lambda$new$0(InfluxDBImpl.java:197)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at
org.apache.flink.metrics.influxdb.shaded.org.influxdb.impl.BasicAuthInterceptor.intercept(BasicAuthInterceptor.java:22)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at
org.apache.flink.metrics.influxdb.shaded.org.influxdb.impl.GzipRequestInterceptor.intercept(GzipRequestInterceptor.java:42)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.logging.HttpLoggingInterceptor.intercept(HttpLoggingInterceptor.java:144)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
at
org.apache.flink.metrics.influxdb.shaded.okhttp3.RealCall.execute(RealCall.java:77)
at
org.apache.flink.metrics.influxdb.shaded.retrofit2.OkHttpCall.execute(OkHttpCall.java:180)
at
org.apache.flink.metrics.influxdb.shaded.org.influxdb.impl.InfluxDBImpl.execute(InfluxDBImpl.java:1168)
at
org.apache.flink.metrics.influxdb.shaded.org.influxdb.impl.InfluxDBImpl.write(InfluxDBImpl.java:821)
at
org.apache.flink.metrics.influxdb.InfluxdbReporter.report(InfluxdbReporter.java:97)
at
org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:430)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
