You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
> Note: Flink [ships optional dependencies in `/opt`](https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/configuration/advanced/#anatomy-of-the-flink-distribution), so that's a good place to mount our JAR.
446
+
445
447
> Note: Don't forget the `:Z` at the end of the volume mount if using a system with SELinux! Otherwise, you will get a permission error when trying to use the JAR later.
446
448
447
449
Once we're in the Flink SQL CLI, we will first create a table for the generated international sales records:
@@ -477,7 +479,7 @@ If that worked, we can now register our UDF as a [temporary catalog function](ht
477
479
```sql
478
480
CREATE TEMPORARY FUNCTION currency_convert
479
481
AS 'com.github.example.CurrencyConverter'
480
-
USING JAR '/opt/flink/opt/currency-converter-1.0-SNAPSHOT.jar';
482
+
USING JAR '/opt/currency-converter-1.0-SNAPSHOT.jar';
481
483
```
482
484
483
485
> Note: Temporary catalog functions [only live as long as the current session](https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/table/functions/overview/#types-of-functions). You can omit the `TEMPORARY` keyword to create a catalog function that persists across sessions.
0 commit comments