Thanks Lasse, I think you can create an issue and update the document if there is any wrong
Best, Shammon FY On Wed, Mar 29, 2023 at 3:48 AM Lasse Nedergaard < lassenedergaardfl...@gmail.com> wrote: > Hi. > I have figured it out. The documentation are wrong in both places. > > Med venlig hilsen / Best regards > Lasse Nedergaard > > > Den 28. mar. 2023 kl. 14.21 skrev Lasse Nedergaard < > lassenedergaardfl...@gmail.com>: > > Hi > > I have added the code to my test project and using flink 1.16.1 > > I have two compile problems I don’t understand. > > 1. In ChangelogCsvFormat the cast to producedTypeInfo come with this > exception. Inconvertible types; cannot cast …. Object to typeinfo > > 2 In socketSourceFunction open method I get “multiple non-overlapping > abstract methods found in interface org.Apache.Flink…… > DeserializationSchema.InitializationContext > > > Any idea what I’m doing wrong? > Med venlig hilsen / Best regards > Lasse Nedergaard > > > Den 28. mar. 2023 kl. 06.07 skrev Lasse Nedergaard < > lassenedergaardfl...@gmail.com>: > > Thanks Shammon > > A perfect example to look at. Do you also know a example of a data stream > source? > > Med venlig hilsen / Best regards > Lasse Nedergaard > > > Den 28. mar. 2023 kl. 02.43 skrev Shammon FY <zjur...@gmail.com>: > > > Hi Lasse > > Does your job table/sql or datastream? Here's the doc [1] for customized > source in table and there is an example of socket source. > > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/ > > Best, > Shammon FY > > On Mon, Mar 27, 2023 at 8:02 PM Lasse Nedergaard < > lassenedergaardfl...@gmail.com> wrote: > >> Hi. >> >> I have to use data from a Rest API, very slow changing. Instead of doing >> an async i/o request I would like to create a source function that read >> from Rest Api so I can connect and enrich another stream without a lookup >> for each incoming row. >> Flink doc provide an explanation of how to do it but I find it pretty >> hard get all the concepts to work together and I haven’t been able to find >> a “simple” app example. >> Is there anyone out there knowing a good example or give a simple >> explanation of best practice for implementing your own source >> >> Med venlig hilsen / Best regards >> Lasse Nedergaard >> >>
