You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
The text was updated successfully, but these errors were encountered: