Github user rmetzger commented on the pull request:
https://github.com/apache/incubator-flink/pull/202#issuecomment-63882316
With the fixed python call, I'm getting from the example.
```
StreamPrinter: Traceback (most recent call last):
StreamPrinter: File "/tmp/flink_plan/plan.py", line 26, in <module>
StreamPrinter: data = env.read_text(textfile)
StreamPrinter: NameError: name 'textfile' is not defined
```
Would be cool to have a) an included data set b) let the user pass the
path's from the command line.
Once I've fixed that, I'm getting another error:
```
Error: The main method caused an error.
org.apache.flink.client.program.ProgramInvocationException: The main method
caused an error.
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:445)
at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:346)
at org.apache.flink.client.program.Client.run(Client.java:244)
at
org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:347)
at org.apache.flink.client.CliFrontend.run(CliFrontend.java:334)
at
org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1001)
at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1025)
Caused by: java.io.IOException: The given HDFS file URI (hdfs:/tmp/flink)
did not describe the HDFS Namenode. The attempt to use a default HDFS
configuration, as specified in the 'fs.hdfs.hdfsdefault' or 'fs.hdfs.hdfssite'
config parameter failed due to the following problem: Either no default hdfs
configuration was registered, or the provided configuration contains no valid
hdfs namenode address (fs.default.name or fs.defaultFS) describing the hdfs
namenode host and port.
at
org.apache.flink.runtime.fs.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:281)
at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:255)
at
org.apache.flink.languagebinding.api.java.python.PythonPlanBinder.clearPath(PythonPlanBinder.java:149)
at
org.apache.flink.languagebinding.api.java.python.PythonPlanBinder.distributeFiles(PythonPlanBinder.java:142)
at
org.apache.flink.languagebinding.api.java.python.PythonPlanBinder.go(PythonPlanBinder.java:78)
at
org.apache.flink.languagebinding.api.java.python.PythonPlanBinder.main(PythonPlanBinder.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:483)
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:430)
... 6 more
```
It seems that HDFS is hardcoded. It would be better to just use the
"fs.defaultFS" parameter to let the user decide on the file system.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
