Hello Pedroh!
I am adding the jar under /opt/flink/plugins/s3-fs-hadoop inside a docker
image. It's definitely not happening under the task manager and I don't
believe it's happening under Job manager either. The error is coming from
FlinkSessionJob under the Kubernetes' Custom Resource Definition
Hello there Bryan!
It looks like Flink cannot find the s3 schema in your packages. How are you
adding the jars? Is the error happening on TM or on JM?
Att,
Pedro Mázala
Be awesome
On Thu, 22 May 2025 at 19:45, Bryan Cantos wrote:
> Hello,
>
> I have deployed the Flink Operator via helm chart
Hello
Actually I evaluate my WindowFunction with a trigger alert, having
something like below code (testing with 2 different windows), expecting 5K
elements per second arriving
SingleOutputStreamOperator windowedElem = element
.keyBy("id")
.timeWindow(Time.seconds(120))
// .window(EventTi
Hi antonio,
I think it worth a try to test the performance in your scenario, since job
performance can be affected by a number of factors(say your WindowFunction).
Best, Hequn
On Sat, Jul 21, 2018 at 2:59 AM, antonio saldivar
wrote:
> Hello
>
> I am building an app but for this UC I want to te
