Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

No problem, good luck with your learning journey! Best, Tymur Yarosh 17 квіт. 2022 р., 07:17 +0300, Marco Villalobos , писав(-ла): > You're right. I didn't notice that the ports were different. That was very > subtle. > > Thank you for pointing this out to me. I was stuck on it for quite a while

Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

You're right. I didn't notice that the ports were different. That was very subtle. Thank you for pointing this out to me. I was stuck on it for quite a while. > On Apr 16, 2022, at 6:17 PM, Marco Villalobos > wrote: > > I'm sorry, I accidentally hit send before I was finished. > > Yes, I un

Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

The example uses the playground’s ingress (https://github.com/apache/flink-statefun-playground/blob/1ff449204b367e6dd0d0818ca76a5283890ce2c5/java/greeter/module.yaml#L23) that handles HTTP calls and forwards data to Flink. Then Flink calls the function over HTTP on a different server. In the exa

Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

I'm sorry, I accidentally hit send before I was finished. Yes, I understand that Flink Stateful Functions run as part of a cluster in which state and throughput are managed by Flink. However, in StatefulFunctions, remote functions are still implemented as remote HTTP micro-services often deploye

Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

IK If what you're saying is true, then why do most of the examples in the flink-statefun-playground example use HTTP as an alternative entry point? Here is the greeter example: https://github.com/apache/flink-statefun-playground/tree/main/java/greeter

Re: Supporting different content-types such as String or JSON seems to always fail for me in Stateful Functions.

Hi Marco, The problem is that you’re trying to call the function directly via HTTP. This is not how it's supposed to work. Instead, check out how to define your statefun module  https://nightlies.apache.org/flink/flink-statefun-docs-master/docs/modules/overview/  and how to deploy Stateful Functi

Re: java.lang.Exception: Job leader for job id 0efd8681eda64b072b72baef58722bc0 lost leadership.

Hi, to unsubscribe you need to send a mail to user-unsubscr...@flink.apache.org. Best, Zhanghao Chen From: Samir Vasani Sent: Saturday, April 16, 2022 1:08:20 PM To: Jai Patel Cc: Nicolaus Weidner ; user ; Weixiang Sun

how to initialize few things at task managers

I need to download Keystore and use it while creating the source connector, currently, I am overriding the open method