All Questions
4 questions
0
votes
1
answer
416
views
Flink Table API program does not compile when assigning watermark using a field converted with UDF
Since TO_TIMESTAMP(value, format) method in Flink Table API does not support custom formats like yyyyMMddHHmmssSSS, we needed to create a UDF(User Defined Function) for custom conversion.
However, ...
0
votes
1
answer
886
views
Flink fails to load class from JAR added via PipelineOptions
I am developing a Java application which uses UDFs on Flink 1.14. I am using PipelineOptions.JARS config to add jar files containing UDF classes dynamically in the application code, However ...
- 155
3
votes
2
answers
1k
views
Apache Flink 1.14.0 - Unable to use python UDF through SQL DDL in Java
I'm trying to execute the python UDF function in SQL DDL(1.14.0)
Python file here：
from pyflink.table import DataTypes
from pyflink.table.udf import udf
@udf(input_types=[DataTypes.INT()], result_type=...
- 206
2
votes
1
answer
1k
views
Apache-Flink 1.11 Unable to use Python UDF in SQL Function DDL
According to this confluence page:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
python udf are in Flink 1.11 available to be used with in SQL ...
