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

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 >

The implementation of the RichSinkFunction is not serializable.

2017-08-27 Thread Federico D'Ambrosio
Hi, I'm trying to write on HBase using writeOutputFormat using a custom HBase format inspired from this example in flink-hbase (mind you, I'm