Return-Path: 
 <dev-return-1999-apmail-flink-dev-archive=flink.apache.org@flink.incubator.apache.org>
X-Original-To: apmail-flink-dev-archive@www.apache.org
Delivered-To: apmail-flink-dev-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id CCB9911509
	for <apmail-flink-dev-archive@www.apache.org>;
 Tue,  9 Sep 2014 14:23:48 +0000 (UTC)
Received: (qmail 59484 invoked by uid 500); 9 Sep 2014 14:23:48 -0000
Delivered-To: apmail-flink-dev-archive@flink.apache.org
Received: (qmail 59434 invoked by uid 500); 9 Sep 2014 14:23:48 -0000
Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@flink.incubator.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@flink.incubator.apache.org>
List-Post: <mailto:dev@flink.incubator.apache.org>
List-Id: <dev.flink.incubator.apache.org>
Reply-To: dev@flink.incubator.apache.org
Delivered-To: mailing list dev@flink.incubator.apache.org
Received: (qmail 59423 invoked by uid 99); 9 Sep 2014 14:23:48 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Sep 2014 14:23:48 +0000
X-ASF-Spam-Status: No, hits=2.0 required=5.0
	tests=SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Sep 2014 14:23:43 +0000
Received: from ben.nabble.com ([192.168.236.152])
	by sam.nabble.com with esmtp (Exim 4.72)
	(envelope-from <wir12kqe@studserv.uni-leipzig.de>)
	id 1XRMKJ-0007wi-7w
	for dev@flink.incubator.apache.org; Tue, 09 Sep 2014 07:23:23 -0700
Date: Tue, 9 Sep 2014 07:23:23 -0700 (PDT)
From: normanSp <wir12kqe@studserv.uni-leipzig.de>
To: dev@flink.incubator.apache.org
Message-ID: <1410272603237-1750.post@n3.nabble.com>
In-Reply-To: 
 <CAAdrtT2BYhmvmDkhvY+23cpbmxgTzCkrH-YmJCPeGN40xY377g@mail.gmail.com>
References: <540DA5B8.7070201@studserv.uni-leipzig.de>
 <CANMXwW1MVPBPF-7BGJ8RoqeVRP-sa=yC=hxo031xtULAcW=p2w@mail.gmail.com>
 <CAGr9p8C+1Pi1rYaGb8rSB_EBNsB=2qwFx59BSTm_ch0vR_3pFg@mail.gmail.com>
 <540DBBA3.4010308@studserv.uni-leipzig.de>
 <CANMXwW18_bpX4xrK7tnpHdQ98_YgjgCZQYi4N1nPL+KpEdH6NA@mail.gmail.com>
 <1410270600448-1744.post@n3.nabble.com>
 <CAGr9p8AGB9GMSZ3eemxtugYHbb9d_zWqdtdtomkpq-5SNinvKQ@mail.gmail.com>
 <1410271397456-1746.post@n3.nabble.com>
 <CAAdrtT2BYhmvmDkhvY+23cpbmxgTzCkrH-YmJCPeGN40xY377g@mail.gmail.com>
Subject: Re: flink performance
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

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
(hdfs://MASTER:9000/input.xml) described the host and port of an HDFS
Namenode, but the File System could not be initialized with that address:
Server IPC version 9 cannot communicate with client version 4
        at
org.apache.flink.runtime.fs.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:305)
        at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:248)
        at org.apache.flink.core.fs.Path.getFileSystem(Path.java:299)
        at
org.apache.flink.api.common.io.FileInputFormat.createInputSplits(FileInputFormat.java:391)
        at
org.apache.flink.api.common.io.FileInputFormat.createInputSplits(FileInputFormat.java:52)
        at
org.apache.flink.runtime.jobgraph.JobInputVertex.getInputSplits(JobInputVertex.java:101)
        at
org.apache.flink.runtime.executiongraph.ExecutionGraph.createVertex(ExecutionGraph.java:495)
        at
org.apache.flink.runtime.executiongraph.ExecutionGraph.constructExecutionGraph(ExecutionGraph.java:281)
        at
org.apache.flink.runtime.executiongraph.ExecutionGraph.<init>(ExecutionGraph.java:177)
        at
org.apache.flink.runtime.jobmanager.JobManager.submitJob(JobManager.java:477)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:422)
        at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:958)
Caused by: org.apache.hadoop.ipc.RemoteException: Server IPC version 9
cannot communicate with client version 4
        at org.apache.hadoop.ipc.Client.call(Client.java:1113)
        at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:229)
        at com.sun.proxy.$Proxy1.getProtocolVersion(Unknown Source)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at
org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:85)
        at
org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:62)
        at com.sun.proxy.$Proxy1.getProtocolVersion(Unknown Source)
        at org.apache.hadoop.ipc.RPC.checkVersion(RPC.java:422)
        at
org.apache.hadoop.hdfs.DFSClient.createNamenode(DFSClient.java:183)
        at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:281)
        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)
        ... 15 more

        at org.apache.flink.client.program.Client.run(Client.java:325)
        at org.apache.flink.client.program.Client.run(Client.java:291)
        at org.apache.flink.client.program.Client.run(Client.java:285)
        at
org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
        at
org.apache.flink.example.java.wordcount.WordCount.main(WordCount.java:82)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:389)
        at
org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:307)
        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)



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