hi all,
bg:
create a custom metric reporter via kafka,
it works in ideaj local environment.
but failed when packaged and deployed  in k8s env (ververica by alibaba)
flink 1.12
config:
metrics.reporter.kafka.factory.class:
org.apache.flink.metrics.kafka.KafkaReporterFactory
metrics.reporter.kafka.server: xxxx
metrics.reporter.kafka.interval: xxx
log:
reporterSetup  - The reporter
factory (org.apache.flink.metrics.kafka.KafkaRepoertFactory) could not be
found for reporter kafka.

it confused. and i checed jar
:/META-INF/services/(org.apache.flink.metrics.MetricReporterFacotry
corrected.

could someone can give me some advice. thanks.

Reply via email to