Stateful Functions: Deploying to existing Cluster

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Stateful Functions: Deploying to existing Cluster

Jan Brusch
Hi,

quick question about Deploying a Flink Stateful Functions Application to
an existing cluster: The Documentation says to integrate
"statefun-flink-distribution" as additional maven Dependency in the fat
jar.
(https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/deployment-and-operations/packaging.html#flink-jar)

But how and where do I upload my module.yml for external function
definitions in that scenario...?


Best regards

Jan

Reply | Threaded
Open this post in threaded view
|

Re: Stateful Functions: Deploying to existing Cluster

Igal Shilman
Hi Jan,

Stateful functions would look at the java class path for the module.yaml,
So one way would be including the module.yaml in your src/main/resources/ directory.

Good luck,
Igal.


On Mon, Jul 6, 2020 at 12:39 PM Jan Brusch <[hidden email]> wrote:
Hi,

quick question about Deploying a Flink Stateful Functions Application to
an existing cluster: The Documentation says to integrate
"statefun-flink-distribution" as additional maven Dependency in the fat
jar.
(https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/deployment-and-operations/packaging.html#flink-jar)

But how and where do I upload my module.yml for external function
definitions in that scenario...?


Best regards

Jan

Reply | Threaded
Open this post in threaded view
|

Re: Stateful Functions: Deploying to existing Cluster

Jan Brusch

Hi Igal,

thanks for the quick reply. That does make sense and I will give it a try.

It might probably make sense to add that to the Documentation.


Best regards and thanks!

Jan

On 06.07.20 14:02, Igal Shilman wrote:
Hi Jan,

Stateful functions would look at the java class path for the module.yaml,
So one way would be including the module.yaml in your src/main/resources/ directory.

Good luck,
Igal.


On Mon, Jul 6, 2020 at 12:39 PM Jan Brusch <[hidden email]> wrote:
Hi,

quick question about Deploying a Flink Stateful Functions Application to
an existing cluster: The Documentation says to integrate
"statefun-flink-distribution" as additional maven Dependency in the fat
jar.
(https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/deployment-and-operations/packaging.html#flink-jar)

But how and where do I upload my module.yml for external function
definitions in that scenario...?


Best regards

Jan

-- 
neuland  – Büro für Informatik GmbH
Konsul-Smidt-Str. 8g, 28217 Bremen

Telefon (0421) 380107 57
Fax (0421) 380107 99
https://www.neuland-bfi.de

https://twitter.com/neuland
https://facebook.com/neulandbfi
https://xing.com/company/neulandbfi


Geschäftsführer: Thomas Gebauer, Jan Zander
Registergericht: Amtsgericht Bremen, HRB 23395 HB
USt-ID. DE 246585501
Reply | Threaded
Open this post in threaded view
|

Re: Stateful Functions: Deploying to existing Cluster

Jan Brusch
In reply to this post by Igal Shilman

Hi Igal,

just as a feedback for you and anyone else reading this: Worked like a charm. Thanks again for your quick help!


Best regards

Jan


On 06.07.20 14:02, Igal Shilman wrote:
Hi Jan,

Stateful functions would look at the java class path for the module.yaml,
So one way would be including the module.yaml in your src/main/resources/ directory.

Good luck,
Igal.


On Mon, Jul 6, 2020 at 12:39 PM Jan Brusch <[hidden email]> wrote:
Hi,

quick question about Deploying a Flink Stateful Functions Application to
an existing cluster: The Documentation says to integrate
"statefun-flink-distribution" as additional maven Dependency in the fat
jar.
(https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/deployment-and-operations/packaging.html#flink-jar)

But how and where do I upload my module.yml for external function
definitions in that scenario...?


Best regards

Jan

-- 
neuland  – Büro für Informatik GmbH
Konsul-Smidt-Str. 8g, 28217 Bremen

Telefon (0421) 380107 57
Fax (0421) 380107 99
https://www.neuland-bfi.de

https://twitter.com/neuland
https://facebook.com/neulandbfi
https://xing.com/company/neulandbfi


Geschäftsführer: Thomas Gebauer, Jan Zander
Registergericht: Amtsgericht Bremen, HRB 23395 HB
USt-ID. DE 246585501