It seems an exception thrown when Flink try to deserialize the object outputed
by your udf. So is the obejct produced by your udf serializable? Does it
contain any lambda function in the object/class?
Best regards,
Yuxia
发件人: "Tom Thornton"
收件人: "User"
发送时间: 星期五, 2022年 5 月 27日 上午 6:47:0
Hi.
Could you also tell us which Flink version you are using, the schema of the
source table and some test data? With these info, we can debug in our local
environment.
Best,
Shengkai
Tom Thornton 于2022年5月27日周五 06:47写道：
> We are migrating from the legacy table planner to the Blink table planne
Hi.
I think you can use REST OPEN API to fetch the job status from the
JM periodically to detect whether something happens. Currently REST OPEN
API also supports to fetch the exception list for the specified job[2].
Best,
Shengkai
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/ops
We are migrating from the legacy table planner to the Blink table planner.
Previously we had a UDF defined like this that worked without issue:
public class ListToString extends DPScalarFunction {
public String eval(List list) {
return "foo";
}
Since moving to the Blink table plan
Hello Users!
I would like to notify an external endpoint when a streaming job has a
certain number of restarts. While I can use a service to continuously *poll*
Flink metrics and identify failing jobs, I am looking to inverse the
action and have the job notify. We have around ~50 streaming jo
Is the checkpoint work under normal execution during the period with flattened
metrics? You may need to follow the logs to find out if there are WARNs or
ERRORs in the metric reporting system.
At 2022-05-26 09:39:03, "Sahil Aulakh" wrote:
Hi Flink Community
We are using Flink version 1.13.
I think the length is also used for implicit conversion between same logical
types that are with different length or just to merge them to a bigger one when
. For example in your code, if `RowType.of("col1", new CharType())` is in a
sink table schema, the real data of which the length is more th
Hi, you can send to to unsubscribe
At 2022-05-25 23:06:21, "Beni Bilme" wrote:
Unsubscribe
