Hi, I'm building the connector for ElasticSearch2. One main issue for me now is that
List<TransportAddress> transports = new ArrayList<TransportAddress>(); transports.add(new InetSocketTransportAddress(new InetSocketAddress(TransportAddress, 9300))); throws java.io.NotSerializableException: org.elasticsearch.common.transport.InetSocketTransportAddress ES2 changed to this way and InetSocketAddress implements java.io.Serializable rather than Writable (is it the problem?). What would be the suggested way to handle this? should I implement a serializable InetSocketAddress? Best, Sendoh -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/InetSocketAddress-is-not-serializable-tp5296.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
