RE: Socket output stream

void close() { closeConnection(); } //@Override public void cancel() { close(); } } Date: Thu, 12 Mar 2015 01:36:09 +0100 Subject: Re: Socket output stream From: fhue...@gmail.com To: user@flink.apache.org It is in AbstractRichFunction [1]. RichSinkFuncti

Re: Socket output stream

-- > Date: Thu, 12 Mar 2015 01:17:34 +0100 > Subject: Re: Socket output stream > From: fhue...@gmail.com > To: user@flink.apache.org > > > Hi Emmanuel, > > the open() method should the right place for setting up the socket > connection. It is called on the

RE: Socket output stream

I don't see an 'open()' function to override in the RichSinkFunction or the SinkFunction... so where is this open() function supposed to be? Date: Thu, 12 Mar 2015 01:17:34 +0100 Subject: Re: Socket output stream From: fhue...@gmail.com To: user@flink.apache.org Hi Emmanuel, th

Re: Socket output stream

Hi Emmanuel, the open() method should the right place for setting up the socket connection. It is called on the worker node before the first input arrives. Best, Fabian 2015-03-12 1:05 GMT+01:00 Emmanuel : > Hi Marton, > > Thanks for the info. > > I've been trying to implement a socket sink but