Re: Could not build up connection to JobManager

Hi Till, I’m sorry. It doesn’t seem to solve the problem. The taskmanager still tries a 10.0.0.0/8 IP. Best regards. > On Mar 5, 2015, at 1:00 PM, Till Rohrmann wrote: > > Hi Dulaj, > > I looked through your commit and noticed that the JobClient might not be > listening on the right network i

Re: Could not build up connection to JobManager

How did you start the flink cluster? Using the start-local.sh, the start-cluster.sh or starting the job manager and task managers individually using taskmanager.sh/jobmanager.sh. Could you maybe post the flink-conf.yaml file, you're using? With your changes, everything works, right? On Thu, Mar 5

Re: Could not build up connection to JobManager

Using start-locat.sh. I’m using the original config yaml. I also tried changing jobmanager address in config to “127.0.0.1 but no luck. With my changes it works ok. The conf file follows. # Licensed to the Apache So

Re: Could not build up connection to JobManager

What does the jobmanager log says? I think Stephan added some more logging output which helps us to debug this problem. On Thu, Mar 5, 2015 at 9:36 AM, Dulaj Viduranga wrote: > Using start-locat.sh. > I’m using the original config yaml. I also tried changing jobmanager > address in config to “12

Re: Could not build up connection to JobManager

Hi, This is the log with setting “localhost” flink-Vidura-jobmanager-localhost.log And this is the log with setting “127.0.0.1” flink-Vidura-jobmanager-localhost.log

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

Thanks for reporting. Even if it runs on your Ubuntu box, it might still be a problem. It's actually nice to hear that it is reproducible. Can you do the following after it stalls: jps And then a jstack for each process with a name like "surefirebooter425130371299859". Then we can see, whic

Re: Could not build up connection to JobManager

Hi Dulaj! Okay, the logs give us some insight. Both setups seem to look good in terms of TaskManager and JobManager startup. In one of the logs (127.0.0.1) you submit a job. The job fails because the TaskManager cannot grab the JAR file from the JobManager. I think the problem is that the BLOB se

Re: Could not build up connection to JobManager

But can you explain why did my fix solved it? > On Mar 5, 2015, at 5:50 PM, Stephan Ewen wrote: > > Hi Dulaj! > > Okay, the logs give us some insight. Both setups seem to look good in terms > of TaskManager and JobManager startup. > > In one of the logs (127.0.0.1) you submit a job. The job fa

Re: Could not build up connection to JobManager

Could you submit a job when you set the job manager address to "localhost"? I did not see any logging statements of received jobs. If you did, could you also send the logs of the client? The 0.0.0.0 to which the BlobServer binds works for me on my machine. I cannot remember that we had problems wi

Re: Could not build up connection to JobManager

Glad I could help any way. :) When the address is set to “localhost” I cannot submit a job. It immediately fails. But the address is “127.0.0.1”, it is stuck a little whyle on DEPLOYING and the fails. Correct me if I’m wrong but I think since using the address, hardcoded in config file, won’t ha

Re: Could not build up connection to JobManager

What was the error when you tried to submit the job with "localhost"? The client log would be very helpful to understand the problem. Actually, the "localhost" in the code is only the fallback strategy if the job manager address could not be retrieved differently. On Thu, Mar 5, 2015 at 3:25 PM,

Re: Not Flink related: IntelliJ cannot open maven projects

The same happened to me (for a different project). Re-importing the project to IntelliJ solved it On Thu, Mar 5, 2015 at 8:10 AM, Till Rohrmann wrote: > That is odd. Most of the committers are using the IntelliJ to develop > Flink. Have you tried to delete the Flink directory and checking it out

Re: Could not build up connection to JobManager

Hi, The error message is, 21:06:01,521 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable org.apache.flink.client.program.ProgramInvocationException: Could not build up conne

Re: [jira] [Created] (FLINK-1651) Running mvn test got stuck

Thanks guys, will try it out. On Thu, Mar 5, 2015 at 2:12 AM, Ufuk Celebi wrote: > Thanks for reporting. Even if it runs on your Ubuntu box, it might still be > a problem. It's actually nice to hear that it is reproducible. > > Can you do the following after it stalls: > > jps > > And then a jsta

[jira] [Created] (FLINK-1655) Rename StreamInvokable to StreamOperator

Gyula Fora created FLINK-1655: - Summary: Rename StreamInvokable to StreamOperator Key: FLINK-1655 URL: https://issues.apache.org/jira/browse/FLINK-1655 Project: Flink Issue Type: Improvement

Running example in IntelliJ

Hello, Can someone help me with the steps on how to compile and run an example on IntelliJ