of course, sorry.
command: ./bin/flink run
./examples/flink-java-examples-0.7-incubating-SNAPSHOT-WordCount.jar
hdfs:/input.xml hdfs:/result
org.apache.flink.client.program.ProgramInvocationException: The program
execution failed: java.io.IOException: The given HDFS file URI
(hdfs:/input.xml)
thanks, but i tried all that versions before I posted here. and exactly the
same conf-file works in 0.6.
@fabian
with full hostname and port I get this error:
org.apache.flink.client.program.ProgramInvocationException: The program
execution failed: java.io.IOException: The given file URI
okay, i thought that is only in yarn-mode necessary.
i did it but the next error follows.
java.io.IOException: Error opening the Input Split
hdfs://MASTER:9000/input.xml [46573551616,134217728]:
i want to use the above mentioned scala-rework-branch
https://github.com/aljoscha/incubator-flink/tree/scala-rework.
the apache hadoop-version is 2.4.0 and I build Flink with:
mvn clean package -DskipTests -Dhadoop.profile=2 -Dhadoop.version=2.4.0
--
View this message in context:
