Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Note about 3rd commit: fixed failing `FlinkKafkaConsumerBaseMigrationTest`s
after the rebase.
The tests were failing due to the removal of
`AbstractFetcher#restoreOffsets(...)` method as part of the refactoring of
offset restoration in this PR. On the other hand, the previous implementation
of tests in `FlinkKafkaConsumerBaseMigrationTest` were too tightly coupled with
how the connector was implemented, i.e. it was testing how the
`AbstractFetcher` methods are called, whether `MAX_VALUE` watermark was emitted
(which will likely change as features are added to the connector) etc, even
though the actual purpose of the tests was simply to test states were restored
correctly.
The 3rd commit therefore attempts to simplify
`FlinkKafkaConsumerBaseMigrationTest` to only test legacy state restore
behaviour. The deleted parts, IMHO, are already covered in other tests.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
