Hi Jigar,
in order to run the Sink function on the Flink cluster, it will be
serialized. Since you marked the repository as transient, it won't be
shipped to the cluster. So if Repository is Serializable, you can ship it
to the cluster. If not, then you need to reconstruct the Repository on the
cl
Hello Devs,
Here is my custom sink code.
`
public class FlinkNeptuneSink extends RichSinkFunction {
static HttpClient client = HttpClient.newHttpClient();
private static final long serialVersionUID = 1L;
NeptuneClientFactory neptuneClientFactory;
JsonLDWr
