would you join a Slack workspace for Flink?

Hi all, This mailing list is for user support and questions. If you would also use slack for user support and questions, then please vote at the following ticket. If you don't have an account at that jira, you can reply to this email with a "+1". [FLINK-10217

Re: Using a ProcessFunction as a "Source"

The SourceFunction interface is rather flexible so you can do pretty much whatever you want. Exact implementation depends on whether control messages are pulled or pushed to the source; in the first case you'd simply block within "run()" on the external call, in the latter you'd have it block o