Re: Socket stream source in Python?

e some more information on this if you'd like. > > Kind regards, > Francis > > On Sat, 29 Jan 2022 at 01:20, Philippe Rigaux <mailto:philippe.rig...@lecnam.net>> wrote: > Hi there > > I would like to use a socket stream as input for my Flink workflow in P

MAP data type (PyFlink)

Hello I want to send and receive dict Python values. According to the PyFlink doc, this is specified with Types.MAP(). Unfortunately I found no example of the required arguments, and I am stuck with the following error: TypeError: MAP() missing 2 required positional arguments: 'key_type_info'

Socket stream source in Python?

Hi there I would like to use a socket stream as input for my Flink workflow in Python. This works in scala with the socketTextStream() method, for instance val stream = senv.socketTextStream("localhost", 9000, '\n') I cannot find an equivalent in PyFlink, although it is briefly mentioned in the