You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ouyangwulin (Jira)" <ji...@apache.org> on 2019/09/25 12:11:00 UTC
[jira] [Updated] (FLINK-14210) influxdb reporter support connect
timeout and write timeout config options for decrease timeout exception
[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ouyangwulin updated FLINK-14210:
--------------------------------
Summary: influxdb reporter support connect timeout and write timeout config options for decrease timeout exception (was: influxdb reporter add connect timeout and write timeout config options for decrease timeout exception)
> influxdb reporter support 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
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Original Estimate: 96h
> Remaining Estimate: 96h
>
> 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)