[FLINK-23433] Metrics cannot be initialized in format

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.11.3
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
• Assignee: Unassigned
• Reporter: Fangliang Liu
• Created: 20/Jul/21 03:43
• Updated: 03/Sep/21 06:01

Description

 
I want to use metrics in a custom format, I wrote it like this

ProtobufRowDeserializationSchema implements DeserializationSchema<Row>{
private transient MetricGroup metrics;
@Override 
public void open(InitializationContext context) throws Exception { 
metrics = context.getMetricGroup(); 
 }
}

But, received an `metrics` NPE. it stands to reason that the metrics have already been initialized. 

 

jark, lzljs3620320 , Looking forward to your reply.