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]:
org.apache.hadoop.ipc.RPC.getProxy(Ljava/lang/Class;JLjava/net/InetSocketAddress;Lorg/apache/hadoop/security/UserGroupInformation;Lorg/apache/hadoop/conf/Configuration;Ljavax/net/SocketFactory;ILorg/apache/hadoop/io/retry/RetryPolicy;Z)Lorg/apache/hadoop/ipc/VersionedProtocol;
        at
org.apache.flink.api.common.io.FileInputFormat.open(FileInputFormat.java:598)
        at
org.apache.flink.api.common.io.DelimitedInputFormat.open(DelimitedInputFormat.java:446)
        at
org.apache.flink.api.common.io.DelimitedInputFormat.open(DelimitedInputFormat.java:49)
        at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:140)
        at
org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
        at java.lang.Thread.run(Thread.java:744)
Caused by: java.lang.NoSuchMethodError:
org.apache.hadoop.ipc.RPC.getProxy(Ljava/lang/Class;JLjava/net/InetSocketAddress;Lorg/apache/hadoop/security/UserGroupInformation;Lorg/apache/hadoop/conf/Configuration;Ljavax/net/SocketFactory;ILorg/apache/hadoop/io/retry/RetryPolicy;Z)Lorg/apache/hadoop/ipc/VersionedProtocol;
        at
org.apache.hadoop.hdfs.DFSClient.createRPCNamenode(DFSClient.java:135)
        at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:280)
        at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:245)
        at
org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:100)
        at
org.apache.flink.runtime.fs.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:302)
        at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:248)
        at
org.apache.flink.api.common.io.FileInputFormat$InputSplitOpenThread.run(FileInputFormat.java:737)



--
View this message in context: 
http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/flink-performance-tp1726p1753.html
Sent from the Apache Flink (Incubator) Mailing List archive. mailing list 
archive at Nabble.com.

Reply via email to