Hi Igal,
I got around to toying around with your proposed solutions today.
Unfortunately I didn't get it to work. However, you asked me to share
the code and I prepared an example that provides a minimal reproduction
of my use case and the corresponding error.
Please find it here:
https://g
Hi igal,
thanks for your comprehensive reply!
As for 1. I will try and create a minimal reproduction of the case and
share the code with you. It might be a few days until I get around to do it.
As for 2. I will definitely give this a try. From the looks of it this
seems to be the solution an
Hi Jan,
Two followup questions:
1. Looking at the stack trace provided in your email, it does seem like the
function type is unavailable, and I'd like to follow up on that: can you
please share your Dockerfile, so
we have the complete picture. If you are not comfortable sharing that, then
you can
Hi Igal,
thanks for your reply. Initially I thought the same thing, but it turns
out I am able to call the remote function from an embedded "wrapper"
function using the exact same setup (Relevant Code below). So that's one
kind of solution to that Problem. But to me it seems like it's a bit of
Hi Jan,
Judging by the exception message it seems like the function type
"demo/eventCounterPython" is not known to stateful functions.
This could happen if the module.yaml (provided in your email) was
accidentally excluded from the resulting artifact (Docker image or a
jar-with-dependencies)
Can yo
Hi,
based on Gordons excellent advice on how to handle JSON messages with
remote functions
(https://www.mail-archive.com/user@flink.apache.org/msg34385.html) I was
able to:
1) Deserialize JSON Messages from a Kafka Stream
2) Route the message to an embedded StatefulFunction
3) Serialize th
