Hello everyone,
I am using RedisSink<IN> ext...
# troubleshootingn
Neha
07/19/2023, 9:40 AMHello everyone,
I am using RedisSink<IN> extends RichSinkFunction<IN> which is taken from Apache Bahir codebase.
Flink version : 1.16.1
flink_taskmanager_job_task_operator_numBytesIn for operator_name="Sink:_Unnamed" is always 0 but flink_taskmanager_job_task_operator_numRecordsIn for operator_name="Sink:_Unnamed" showing correct number. what can be the issue? is anything need to be implemented in my RedisSink?
m
Martijn Visser
07/19/2023, 11:34 AMThose connectors aren't guaranteed to be working with the latest versions of Flink. Definitely not with regards to metrics and everything
Martijn Visser
07/19/2023, 11:34 AMflink_taskmanager_job_task_operator_numRecordsInn
Neha
07/20/2023, 3:31 AMGot it. Thank you. can we manually publish this metric? Any sample example would help.
Any other Redis connector which is using new Sink APIs if you are aware of?
m
Martijn Visser
07/20/2023, 8:15 AMThank you. can we manually publish this metric?I don't think so, but not 100% sure
Any other Redis connector which is using new Sink APIs if you are aware of?Nope, still waiting on a volunteer for this...