[Bug] [chunjun-connector-kafka] DynamicKafkaSerializationSchema durationCounter have two different type

[sailyfirm]

Search before asking

• [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

How to reproduce

include kafka sink and es sink in a task.

Anything else

No response

Version

master

Are you willing to submit PR?

• [ ] Yes I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct