[X] I had searched in the issues and found no similar issues.
What happened
when include kafka sink and es sink
java.lang.UnsupportedOperationException: The accumulator object 'writeDuration' was created with two different types: org.apache.flink.api.common.accumulators.LongMaximum and org.apache.flink.api.common.accumulators.LongCounter
What you expected to happen
writeDuration accumulator maybe need a single type of LongCounter
Search before asking
What happened
when include kafka sink and es sink
java.lang.UnsupportedOperationException: The accumulator object 'writeDuration' was created with two different types: org.apache.flink.api.common.accumulators.LongMaximum and org.apache.flink.api.common.accumulators.LongCounter
What you expected to happen
writeDuration accumulator maybe need a single type of LongCounter
How to reproduce
include kafka sink and es sink in a task.
Anything else
No response
Version
master
Are you willing to submit PR?
Code of Conduct