Re: Custom TCP server socket source

2023-07-27 Thread Martijn Visser via user
Hi Kamal, The best starting point would be to look at how to write a custom source connector. Have a look at https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/sources/ which also includes links to the various classes that you'll need. Please let us know what else you've

Re: [DISCUSS] Status of Statefun Project

2023-06-20 Thread Martijn Visser via user
Hi Galen, Yes, I'll be more than happy to help with Statefun releases. Best regards, Martijn On Tue, Jun 20, 2023 at 2:21 PM Galen Warren wrote: > Thanks. > > Martijn, to answer your question, I'd need to do a small amount of work to > get a PR ready, but not much. Happy to do it if we're

Re: Why this example does not save anything to file?

2022-08-30 Thread Martijn Visser via user
Hi Mike, I think that's caused by you not having enabled checkpointing. If you enable that, it should be resolved I think. Best regards, Martijn On Wed, Aug 3, 2022 at 9:01 PM wrote: > > Thank you very much Martijn you dedicated your productive time to help me! > I'm new noob in this subject