SourceReaderBase seems to be in flink-connector-base. On Fri, Jul 24, 2020 at 5:59 PM Yuval Itzchakov <yuva...@gmail.com> wrote:
> Hi, > I'm implementing a custom SourceReader and want to base it on > SourceReaderBase. However, it seems like while SourceReader and Source are > part of `flink-core:1.11.1`, SourceReaderBase is not? > > Do I need an external package for it? > > -- > Best Regards, > Yuval Itzchakov. >
