Hi, I've implemented a new custom source using the new DataSource API ( https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/sources.html) and I want to connect it to the new DynamicTableSource API.
However, in ScanTableSource, the getScanRuntimeProvider method returns a ScanRuntimeProvider interface, which only has an implementation for the old SourceFunction[T], and not for the new Source[T] class: [image: image.png] Does the Table API not yet support the new Source API? or am I missing something? -- Best Regards, Yuval Itzchakov.
