All Questions
3 questions
0
votes
0
answers
28
views
How to manage delay in loading from kafka topic into table using table api in pyflink
i am loading data from two kafka topics into tables using table api in pyflink and going to do join operation what will happen if the data from one of the kafka topics loaded into the corresponding ...
0
votes
1
answer
518
views
Apache-Flink 1.11 Unable to use Python UDF through SQL Function DDL in Java Flink Streamming Job
In Flip-106 there is an example of how to call a user-defined python function in a batch job java application through SQL Function DDL...
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);...
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 ...