[ https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tzu-Li (Gordon) Tai updated FLINK-6343: --------------------------------------- Description: With FLINK-6324, the Java serialization shortcut for operator state is now deprecated to discourage its usage. These sources / sinks are still using this shortcut, and should be migrated to use `getListState(descriptor)` instead: - {{BucketingSink}} - {{ContinuousFileReaderOperator}} - {{GenericWriteAheadSink}} - {{MessageAcknowledgingSourceBase}} - {{RollingSink}} - {{FlinkKafkaConsumerBase}} (will be fixed along with the state migration included with FLINK-4022) To ease review, I propose to open up subtasks under this JIRA and separate PRs for the migration of each single source / sink. was: With FLINK-6324, the Java serialization shortcut for operator state is now deprecated to discourage its usage. These sources / sinks are still using this shortcut, and should be migrated to use `getListState(descriptor)` instead: - `BucketingSink` - `ContinuousFileReaderOperator` - `GenericWriteAheadSink` - `MessageAcknowledgingSourceBase` - `RollingSink` - `FlinkKafkaConsumerBase` (will be fixed along with the state migration included with FLINK-4022) To ease review, I propose to open up subtasks under this JIRA and separate PRs for the migration of each single source / sink. > Migrate from discouraged Java serialization for all sources / sinks > ------------------------------------------------------------------- > > Key: FLINK-6343 > URL: https://issues.apache.org/jira/browse/FLINK-6343 > Project: Flink > Issue Type: Improvement > Components: Streaming Connectors > Reporter: Tzu-Li (Gordon) Tai > > With FLINK-6324, the Java serialization shortcut for operator state is now > deprecated to discourage its usage. > These sources / sinks are still using this shortcut, and should be migrated > to use `getListState(descriptor)` instead: > - {{BucketingSink}} > - {{ContinuousFileReaderOperator}} > - {{GenericWriteAheadSink}} > - {{MessageAcknowledgingSourceBase}} > - {{RollingSink}} > - {{FlinkKafkaConsumerBase}} (will be fixed along with the state migration > included with FLINK-4022) > To ease review, I propose to open up subtasks under this JIRA and separate > PRs for the migration of each single source / sink. -- This message was sent by Atlassian JIRA (v6.3.15#6346)