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>

Reply via email to