[
https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-12147:
--------------------------------
Attachment: metric-error.log
Description: when use influxDB store metric datas, and metric kafka
performance. There has some POSITIVE_INFINITY or NEGATIVE_INFINITY data in
the values, but influxDB no support it, so it alway some error. (was:
2019-04-09 17:17:12,654 WARN
org.apache.flink.runtime.metrics.MetricRegistryImpl - Error while
reporting metrics
java.lang.RuntimeException: org.influxdb.InfluxDBException: ShardServer
Internal error: \{"error":"partial write: unable to parse
'taskmanager_job_task_operator_join_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number\nunable to parse
'taskmanager_job_task_operator_KafkaConsumer_join_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number\nunable to parse
'taskmanager_job_task_operator_KafkaConsumer_heartbeat_response_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number\nunable to parse
'taskmanager_job_task_operator_sync_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number\nunable to parse
'taskmanager_job_task_operator_KafkaConsumer_sync_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number\nunable to parse
'taskmanager_job_task_operator_heartbeat_response_time_max,host=10.242.91.189,job_id=a75d76273048556c5059262ee3981277,job_name=Flink\\
Streaming\\
Job,operator_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,operator_name=Source:\\
Custom\\
Source,subtask_index=0,task_attempt_id=f57c884bd2ce337003b5c23dcadbfdde,task_attempt_num=0,task_id=e3dfc0d7e9ecd8a43f85f0b68ebf3b80,task_name=Source:\\
Custom\\ Source\\ -\u003e\\ (Map\\,\\ Sink:\\ Print\\ to\\ Std.\\
Out),tm_id=ccaaf9cb625fbc432c169f441d9c1127 value=-∞ 1554801432592000000':
invalid number dropped=0"})
> Error for monitor kafka metrics when Use influxDB metric plugins，influxDB
> unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY
> ----------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-12147
> URL: https://issues.apache.org/jira/browse/FLINK-12147
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Metrics
> Affects Versions: 1.8.0
> Reporter: ouyangwulin
> Priority: Major
> Attachments: metric-error.log
>
>
> when use influxDB store metric datas, and metric kafka performance. There has
> some POSITIVE_INFINITY or NEGATIVE_INFINITY data in the values, but
> influxDB no support it, so it alway some error.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
