[ https://issues.apache.org/jira/browse/FLINK-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926662#comment-16926662 ]
vinoyang commented on FLINK-13619: ---------------------------------- [~till.rohrmann] yes, I temprarily copied the code snapshot: {code:java} public String getOperatorSnapshotPath(MigrationVersion version) { return "src/test/resources/kafka-0.11-migration-kafka-producer-flink-" + version + "-snapshot"; } {code} when generating the file. Then, copy it into flink universal connector module. Will submit the PR soon. > Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint > ---------------------------------------------------------------------------- > > Key: FLINK-13619 > URL: https://issues.apache.org/jira/browse/FLINK-13619 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Kafka, Tests > Affects Versions: 1.10.0 > Reporter: Till Rohrmann > Assignee: vinoyang > Priority: Blocker > Fix For: 1.10.0 > > > Update {{FlinkKafkaProducerMigrationOperatorTest}} to restore from 1.9 > savepoint. -- This message was sent by Atlassian Jira (v8.3.2#803003)