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
{{ message }}
This repository has been archived by the owner on Nov 26, 2021. It is now read-only.
ls /Users/etsang/dev/src/github.com/apache/flink/flink-dist/target/flink-1.9-SNAPSHOT-bin/flink-1.9-SNAPSHOT/examples/data/nycTaxiRides.gz is able to find the file
at java.io.FileInputStream.open0(Native Method)
at java.io.FileInputStream.open(FileInputStream.java:195)
at java.io.FileInputStream.<init>(FileInputStream.java:138)
at java.io.FileInputStream.<init>(FileInputStream.java:93)
at com.dataartisans.flinktraining.exercises.datastream_java.sources.TaxiRideSource.run(TaxiRideSource.java:110)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
at java.lang.Thread.run(Thread.java:748)```
The text was updated successfully, but these errors were encountered:
@rmetzger I think you can close this. The reason is the file is a symbink created by the system and I jsut put the data file in it without aware it is just a link to the folder. ls and such supports link, but not the java api.
I am using the web Ui to submit a first test job
com.dataartisans.flinktraining.exercises.datastream_java.basics.RideCleansingExercise
-input /Users/etsang/dev/src/github.com/apache/flink/flink-dist/target/flink-1.9-SNAPSHOT-bin/flink-1.9-SNAPSHOT/examples/data/nycTaxiRides.gz
ls /Users/etsang/dev/src/github.com/apache/flink/flink-dist/target/flink-1.9-SNAPSHOT-bin/flink-1.9-SNAPSHOT/examples/data/nycTaxiRides.gz is able to find the file
The text was updated successfully, but these errors were encountered: