Hi Dawid,
The approach you sent indeed solved our problem.
You helped me and my colleague tremendously, great thanks.
Kind regards,
Jakub
From: Dawid Wysakowicz
Sent: Tuesday, January 5, 2021 16:57
To: Jakub N
Cc: user@flink.apache.org
Subject: Re: Flink UDF
, f0 FROM
recipes").print();
}
This leads to a `java.lang.ClassNotFoundException: StringFunc`. As mentioned in
the code, the commented line surprisingly works as intended.
Do you have any ideas on why this the case?
Kind regards,
Jakub
Von: Dawid Wysakowic
ou were proposing?
Kind regards,
Jakub
Von: Dawid Wysakowicz
Gesendet: Donnerstag, 10. Dezember 2020 09:59
Bis: Guowei Ma; Jakub N
Cc: user@flink.apache.org
Betreff: Re: Flink UDF registration from jar at runtime
Hi Jakub,
As Guowei said the UDF must be present in the user classloader. It m
(Register UDF's)
3. Create tables
4. Query on the tables
5. Execute the environment
The overall process is executed as one program.
Apologies if any of these explanations are unclear or too vague.
Kind regards,
Jakub
Von: Guowei Ma
Gesendet: Diens
path (when the project is packed).
Are there any ways to add these UDF's from outside the classpath?
Kind regards,
Jakub
____
Von: Jakub N
Gesendet: Montag, 7. Dezember 2020 12:59
An: Guowei Ma
Cc: user@flink.apache.org
Betreff: Re: Flink UDF registration from jar
Hi Guowei,
Great thanks for your help. Your suggestion indeed solved the issue. I moved
`myFunction` to the class path where execution starts.
Kind regards,
Jakub
Von: Guowei Ma
Gesendet: Montag, 7. Dezember 2020 12:16
An: Jakub N
Cc: user@flink.apache.org
ed
Let me know if any other relevant information is missing, alternatively you can
also have a look at the source code here
(https://github.com/codefeedr/kafkaquery).
Kind regards,
Jakub
Von: Guowei Ma
Gesendet: Montag, 7. Dezember 2020 02:55
An: Jakub N
Cc: user@fl
The current setup is: Data in Kafka -> Kafka Connector ->
StreamTableEnvironment -> execute Flink SQL queries
I would like to register Flink's User-defined Functions from a jar or java
class file during runtime. What I have tried so far is using Java's Classloader
getting an instance of a Scala
