Hi everyone,
i'm new to flink and tried some queries with flink sql.
Currently I have a problem with the LAG function. I want to emit a new record
when the ORDERS_ID changes. To do this, I use the LAG function to detect
whether this has changed.
However, I noticed that every now and then I canno
Hi all, I am deploying a FlinkDeployment CR in an Operator watched
namespace. I have passed these configs in the flinkConfiguration:
blob.server.address: "jobmanager"
blob.server.port: "6128"
blob.storage.directory: "/tmp/jars/"
There are a couple of jars that I don't want to make part of the ima
Hi, community
I encountered a scala.matchError when trying to obtain the table plan for
the following query in Flink 1.18.1.
The input data is read from Kafka, and the query is intended to perform a
typical WordCount operation. The query is as follows. SPLIT_STRING is a
Table Function UDF that sp
Hi Team,
I have a few session jobs for running jars.
After creating jobs, the job goes from a running state to a reconciling
state or upgrading state.
How can I resolve this issue?
[image: image.png]
Thanks & Regards
Nida Shaikh
