SourceReaderBase not part of flink-core 1.11.1

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

SourceReaderBase not part of flink-core 1.11.1

Yuval Itzchakov
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.
Reply | Threaded
Open this post in threaded view
|

Re: SourceReaderBase not part of flink-core 1.11.1

rmetzger0
SourceReaderBase seems to be in flink-connector-base.

On Fri, Jul 24, 2020 at 5:59 PM Yuval Itzchakov <[hidden email]> 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.