pravega/flink-connectors

Multiple use of the nested FlinkSerializer

Closed this issue · 0 comments

thekingofcity commented

Problem description

The FlinkSerializer from FlinkPravegaWriter is also needed in the new unified sink API #460.

Problem location

flink-connectors/src/main/java/io/pravega/connectors/flink/FlinkPravegaWriter.java

Line 529 in b4f7ce5

static final class FlinkSerializer<T> implements Serializer<T> {

Suggestions for an improvement

Instead of nesting it in the FlinkPravegaWriter, move it to the serialization package.