Hi! The (De)serializationSchema is only a helper for changing the data object to another format. What's your use case? If you're creating a (De)serializationSchema for a source / sink you might want to open and close the resources in the open / close methods of the source / sink, not in the (De)serializationSchema.
Sergio Morales <sdmorale...@gmail.com> 于2021年9月1日周三 下午6:44写道： > Hi, > > I’m currently working to close some resources while using the > SerializationSchema and DeserializationSchema (Flink-core v1.12.1), however, > after revising the document outlining the API the methods > (https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148645988) > the close() operations are missing, and in the master branch I could not find > any new version including them: > > * > https://github.com/apache/flink/blob/99c2a415e9eeefafacf70762b6f54070f7911ceb/flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializationSchema.java > > * > https://github.com/apache/flink/blob/99c2a415e9eeefafacf70762b6f54070f7911ceb/flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java > > Thank you for any help. > > > Regards, > > Sergio. > > >
