This still looks like the versions aren't in sync. What's the exact version of your HDFS (incl. distribution: Hadoop, CDH, etc.) and which Stratosphere build are you using?
2014-09-09 16:57 GMT+02:00 normanSp <[email protected]>: > 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. >
