Re: The implementation of the RichSinkFunction is not serializable.

2017-08-28 Thread Federico D'Ambrosio
Hello everyone, I solved my issue by using an Array[Byte] as a parameter, instead of the explicit HTableDescriptor parameter. This way I can instantiate the TableDescriptor inside the open method of OutputFormat using the static method HTableDescriptor.parseFrom. In the end, marking conf, table an

Re: The implementation of the RichSinkFunction is not serializable.

2017-08-27 Thread Federico D'Ambrosio
Hi, could you elaborate, please? Marking conf, connection and table as transient wouldn't help because of the presence of the HTableDescriptor reference? 2017-08-27 12:44 GMT+02:00 Jörn Franke : > It looks like that in your case everything should be serializable. An > alternative would be to mar

Re: The implementation of the RichSinkFunction is not serializable.

2017-08-27 Thread Jörn Franke
It looks like that in your case everything should be serializable. An alternative would be to mark certain non-serializable things as transient, but as far as I see this is not possible in your case. > On 27. Aug 2017, at 11:02, Federico D'Ambrosio > wrote: > > Hi, > > I'm trying to write on