in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java [68:87]
public void open() {
try {
serializationSchema.open(
new SerializationSchema.InitializationContext() {
@Override
public MetricGroup getMetricGroup() {
return new UnregisteredMetricsGroup();
}
@Override
public UserCodeClassLoader getUserCodeClassLoader() {
return SimpleUserCodeClassLoader.create(
RowElasticsearchEmitter.class.getClassLoader());
}
});
} catch (Exception e) {
throw new FlinkRuntimeException("Failed to initialize serialization schema.", e);
}
indexGenerator.open();
}