Hi,
We are running into some trouble with
StreamExecutionEnvironment.registerCachedFile (works perfectly fine in
1.4.2).
- We register some CSV files in HDFS with
executionEnvironment.registerCachedFile("hdfs:///myPath/myCsv", myCSV.csv)
- In a UDF (ScalarFunction), in the open function, we do a
FunctionContext.getCachedFile("myCSV) to load the CSV in a singleton.
We are running into a
java.lang.IllegalArgumentException: File with name 'myCSV.csv' is not
available. Did you forget to register the file?
Sincerely,
--
<http://smart.salesforce.com/sig/ssuresh//us_mb/default/link.html>
