[jira] [Created] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

Shang Yuanchun (Jira)
Tzu-Li (Gordon) Tai created FLINK-6343:
------------------------------------------

             Summary: 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)