Hello Roman, Well, if that's the way to do it, I can manage to maintain a fork of the statefun repo with these tiny changes. But first my question is if that is the way it should be done? Or if there is another way to activate these connectors.
Best, Christian -----Ursprüngliche Nachricht----- Von: Roman Khachatryan <ro...@apache.org> Gesendet: Dienstag, 28. September 2021 00:31 An: Christian Krudewig (Corporate Development) <christian.krude...@dpdhl.com>; Igal Shilman <i...@ververica.com> Cc: user@flink.apache.org Betreff: Re: How to add Flink a Flink connector to stateful functions Hi, > Does that mean that I need to build the stateful functions java application > and afterwards the docker image? Yes, you have to rebuild the application after updating the pom, as well as its docker image. Is your concern related to synchronizing local docker images with the official repo? If so, wouldn't using a specific statefun image version solve this issue? Regards, Roman On Mon, Sep 27, 2021 at 9:29 PM Christian Krudewig (Corporate Development) <christian.krude...@dpdhl.com> wrote: > > Hello everyone, > > > > Currently I’m busy setting up a pipeline with Stateful Functions using a > deployment of the standard docker image “apache/flink-statefun” to > kubernetes. It has been going smoothly so far and I love the whole toolset. > But now I want to add Egress modules for both Opensearch (= ElasticSearch > protocol) and ScyllaDB (= Cassandra protocol). The documentation at > https://ci.apache.org/projects/flink/flink-statefun-docs-master/docs/io-module/flink-connectors/ > indicates that I can somehow simply plug in the standard Flink datastream > connectors for ElasticSearch and Cassandra. But I didn’t get how exactly. > > It says “include the dependency in your pom”. Does that mean that I need to > build the stateful functions java application and afterwards the docker > image? That would be a bit unfortunate in terms of long-term maintenance > effort, because I would need to keep my local checkout in sync with the > official repositories and rebuild every now and then. Maybe this can also be > added on top of the existing docker image by adding some jar file to some > magic plugin folder? > > > > Sorry, I hope this doesn’t sound captious. I just want to understand and do > it the right way. Maybe there is also some minimal example? I didn’t find any > in the playground nor on stackoverflow or the mailing lists. > > > > Thanks, > > > > Christian Krudewig > > > >
smime.p7s
Description: S/MIME cryptographic signature
