[FLINK-36832] Remove Deprecated classes and relevant tests. #139
Conversation
|
Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) |
|
Hi, @PatrickRen @AHeise. Could you please help to review this? |
|
Hi @lvyanquan , thank you very much for tackling the release. Unfortunately, I don't have time to review it this year and per prior agreement, I expected @PatrickRen and @leonardBang to pick this up. I will ping them again on slack. |
| import java.util.UUID; | ||
|
|
||
| /** IT cases for Kafka. */ | ||
| public class KafkaITCase extends KafkaConsumerTestBase { |
There was a problem hiding this comment.
Do we have new test/ITCase which bases on new API that covers these cases ?
There was a problem hiding this comment.
We have independent test for new Source/SInk API in KafkaSinkITCase and KafkaSourceITCase, but I don't see they are equivalent to the previous testing scenarios, these new tests are designed separately.
Remove Deprecated classes and relevant tests, and annotated some classes from Deprecated to Internal.