0 AM, Ufuk Celebi wrote:
>
>> There was an issue for this:
>> https://issues.apache.org/jira/browse/FLINK-1634
>>
>> Can we close it then?
>>
>> On Sat, Mar 14, 2015 at 9:16 PM, Dulaj Viduranga
>> wrote:
>>
>>> Hay Stephan,
>>>
ck=true" and see
>> if that helps it?
>>
>> Stephan
>>
>>
>> On Sat, Mar 14, 2015 at 4:29 AM, Dulaj Viduranga
>> wrote:
>>
>>> Hi,
>>> Still this is no luck. I’ll upload the logs with configuration
>>> “localhost&q
If it fails, could you please send
> me all log files (client, jobmanager and taskmanager). Once we figured out
> why the JobCilent does not connect, we can try to tackle the BlobServer
> issue.
>
> Cheers,
>
> Till
>
> [1] https://github.com/tillrohrmann/flink/tree/fixJobClie
> On Fri, Mar 6, 2015 at 11:44 AM, Dulaj Viduranga
> wrote:
>
>> Thank you all. IntelliJ shows "Unregister task with execution ID
>> (something)” couple of times in the output. But I guess it’s normal?
>>
>>> On Mar 6, 2015, at 4:08 PM, Stephan Ewen wrot
e a bit more time the first time because IntelliJ will
>> compile all required classes:
>> https://www.youtube.com/watch?v=JIV_rX-OIQM&feature=youtu.be
>> Let us know if you need more help.
>>
>> Robert
>>
>> On Fri, Mar 6, 2015 at 5:58 AM, Dulaj Viduranga
>> wrote:
>>
>>> Hello,
>>> Can someone help me with the steps on how to compile and run an example
>> on
>>> IntelliJ
>>
utube.com/watch?v=JIV_rX-OIQM&feature=youtu.be
> Let us know if you need more help.
>
> Robert
>
> On Fri, Mar 6, 2015 at 5:58 AM, Dulaj Viduranga
> wrote:
>
>> Hello,
>> Can someone help me with the steps on how to compile and run an example on
>> IntelliJ
Hello,
Can someone help me with the steps on how to compile and run an example on
IntelliJ
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
not explain why your fix solves the problem. It does not touch any of
> the JobClient/JobManager logic.
>
> I updated my local branch [1] with a fix for the BlobServer. Could you try
> it out again and send us the logs? Thanks a lot for your help Dulaj.
>
> On Thu, Mar 5, 2015 at
Rohrmann wrote:
>>>
>>> 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:
>>>
&g
ault settings with respect to
>> block-size,
>> # replication factor, etc.
>> #
>> # You can also directly specify the paths to hdfs-default.xml and
>> hdfs-site.xml
>> # via keys 'fs.hdfs.hdfsdefault' and 'fs.hdfs.hdfssite'.
>> #
>
t; With your changes, everything works, right?
>
> On Thu, Mar 5, 2015 at 8:55 AM, Dulaj Viduranga
> wrote:
>
>> 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.
>>
>
checked it out and let it run on your cluster setting. Thanks a lot
> Dulaj!
>
> [1]
> https://github.com/tillrohrmann/flink/tree/fixLocalFlinkMiniClusterJobClient
>
> On Thu, Mar 5, 2015 at 4:21 AM, Dulaj Viduranga
> wrote:
>
>> The every change in the commit b
Hello,
Not Flink related.
IntelliJ cannot open maven projects. It is stuck on “Looking for available
profiles….”. I can open the project in eclipse without any problem.
Any ideas?
No rush.
Thanks.
The every change in the commit b7da22a is not required but I thought they are
appropriate.
> On Mar 5, 2015, at 8:11 AM, Dulaj Viduranga wrote:
>
> Hi,
> I found many other places “localhost” is hard coded. I changed them in a
> better way I think. I made a pull request
gt; If I recall correctly, we only hardcode "localhost" in the local mini
> cluster - do you think it is problematic there as well?
>
> Have you found any other places?
>
> On Mon, Mar 2, 2015 at 10:26 AM, Dulaj Viduranga
> wrote:
>
>> In some places of the
Great. Thanks.
On Mar 04, 2015, at 02:48 PM, Stephan Ewen wrote:
@Till is working on bootstrapping a machine learning Library, he can
probably give you some points...
Am 04.03.2015 04:34 schrieb "Dulaj Viduranga" :
Great. So can you assign me someone to brainstorm the project ide
ap for any committer and we are looking for outside
contributors.
If that is actually what you are interested in, I think you can pick this
topic!
Stephan
On Tue, Mar 3, 2015 at 4:55 PM, Dulaj Viduranga
wrote:
Hi,
I would really like to know what are your high priority GSoC projects and
n wrote:
>
> Good to hear.
>
> Cheers,
>
> Till
>
> On Fri, Feb 20, 2015 at 5:31 PM, Dulaj Viduranga <mailto:vidura...@icloud.com>> wrote:
> Great. I have already started to go through documentation. I’ll follow your
> directions and contact you when
Dulaj Viduranga created FLINK-1634:
--
Summary: Fix "Could not build up connection to JobManager" issue
on some systems
Key: FLINK-1634
URL: https://issues.apache.org/jira/browse/FLINK-1634
Hi,
Can someone help me on how to access the flink-conf.yaml configuration values
inside the flink sources? Are these readily available as a map somewhere?
Thanks.
In some places of the code, "localhost" is hard coded. When it is resolved by
the DNS, it is posible to be directed to a different IP other than 127.0.0.1 (like
private range 10.0.0.0/8). I changed those places to 127.0.0.1 and it works like a charm.
But hard coding 127.0.0.1 is not a good opt
Hi,
I found the fix for this issue and I'll create a pull request in the following
day.
jira/browse/FLINK-1608), let's see if that
>> solves
>>> it.
>>>
>>> What seems not right is that the JobManager initially accepted the
>>> TaskManager and later the communication. Can you paste the TaskManager
>> log
>>> as well?
PSHOT-bin/flink-0.9-SNAPSHOT/count.txt’)
I’m not sure whether I’m running it wrong
> On Feb 26, 2015, at 9:03 PM, Dulaj Viduranga wrote:
>
> Hi,
> It’s great to help out. :)
>
> Setting 127.0.0.1 instead of “localhost” in jobmanager.rpc.address,
> helped to bu
ally, cloud,
> test servers, YARN, ...). Can you paste your ipconfig / ifconfig by any
> chance?
>
> Greetings,
> Stephan
>
>
>
> On Thu, Feb 26, 2015 at 4:33 PM, Dulaj Viduranga
> wrote:
>
>> Hi,
>>It’s great to help out. :)
>>
>>
y updated how the Akka URLs are build, to work around a
>> limitation in Akka. Seems that did not yet fully solve the issue.
>>
>> Thanks for helping us debug this, it is not the easiest immigration
>> experience, but the outcome is probably extremely valuable for the project
>
Hi,
Were you able to solve this? It seams the examples depend on
"flink-streaming-core”. I think you have to build it before.
> On Feb 25, 2015, at 10:04 PM, Matthias J. Sax
> wrote:
>
> Thanks!
>
> Even if I am not a building and/or maven expert, it seems to me that the
> dependencies are no
Yes. Builds fine here too..
Seems like some linking errors..
> On Feb 25, 2015, at 9:24 PM, Max Michels wrote:
>
> Hi Matthias,
>
> Did you really pull from the latest master? I just tried to compile
> flink-streaming-examples using "mvn clean compile test-compile" and it
> worked.
>
> Best re
r you? ("bin/flink run ")
>>>
>>> taskmanager.numberOfTaskSlots: -1 is also okay, this will mean that the
>>> default of '1' is used.
>>>
>>> Greetings,
>>> Stephan
>>>
>>>
>>>
>>>
The configuration values are documented here:
> http://flink.apache.org/docs/0.8/config.html
> For the webclient's port its called webclient.port
>
> On Tue, Feb 24, 2015 at 5:04 PM, Dulaj Viduranga
> wrote:
>
>> I tried to kill the job manager manually in the terminal a
nterfaceServer.(WebInterfaceServer.java:158)
at org.apache.flink.client.WebFrontend.main(WebFrontend.java:74)
****
> On Feb 24, 2015, at 9:32 PM, Dulaj Viduranga wrote:
>
> Hi,
> I still couldn’t figure out a solution. The
--.log" and
> see if there are any errors logged?
>
> Greetings,
> Stephan
> Am 24.02.2015 06:29 schrieb "Dulaj Viduranga" :
>
>> The JobManager seems to run fine. I don't know. When I tried to run
>> start-local.sh again, It shows the PID of the runn
ink--jobmanager--.log" and
> see if there are any errors logged?
>
> Greetings,
> Stephan
> Am 24.02.2015 06:29 schrieb "Dulaj Viduranga" :
>
>> The JobManager seems to run fine. I don't know. When I tried to run
>> start-local.sh again, It shows
n you also send the log of the
JobManager?
On Mon, Feb 23, 2015 at 7:28 PM, Dulaj Viduranga
wrote:
> Yes. It seams it is not a problem with the arguments. I tried two days
but
> different error occurs. It seams the web client can’t connect to the job
> manager although it is running
> Right
not for Kmeans.
> Can you copy me the commands for both examples?
> I can not really believe that there is a difference between the two jobs.
>
> Can you also send us the contents of the jobmanager log file?
>
> Best,
> Robert
>
>
> On Mon, Feb 23, 2015 at 6:04 PM, Dul
I’m getting "Could not build up connection to JobManager.” When i tried to run
the wordCount example. Can anyone help?
Dulaj
gt; On Feb 22, 2015, at 9:12 PM, Dulaj Viduranga wrote:
>
> I can’t see any problems there. Can you? Do I need hadoop libraries?
>
>
> 20:59:30,832 INFO org.apache.flink.runtime.jobmanager.JobManager
>- Starting JobManager
> 20:
-141f-4945-9e47-febbe2019f54
> On Feb 22, 2015, at 9:08 PM, Robert Metzger wrote:
>
> Hi,
>
> can you have a look at the jobmanager log file in the "log/" directory? I
> suspect there was an issue when you've started the JobManager.
>
> On Sun, Feb
I tried to run an example program to the first time in FLINK and I got this
error. I have already started FLINK with bin/start-local.sh. Can someone please
help?
21:01:19,898 WARN org.apache.hadoop.util.NativeCodeLoader
- Unable to load native-hadoop library for your plat
>
> <http://stackoverflow.com/questions/18813828/why-maven-use-jdk-1-6-but-my-java-version-is-1-7>
>
> Regards.
> Chiwan Park (Sent with iPhone)
>
>
>> On Feb 22, 2015, at 10:11 PM, Dulaj Viduranga wrote:
>>
>> Oh yes. :) It runs on 1.6. How could I fix
I haven’t set JAVA_HOME env. Java path is set in PATH env. Is this the problem?
> On Feb 22, 2015, at 6:35 PM, Dulaj Viduranga wrote:
>
> Hi,
> But I’m using Oracle java 8 (javac 1.8.0_05).
>
>> On Feb 22, 2015, at 6:32 PM, Robert Metzger wrote:
>>
>>
Oh yes. :) It runs on 1.6. How could I fix that?
> On Feb 22, 2015, at 6:37 PM, Robert Metzger wrote:
>
> Can you run "mvn -version" to verify that?
> Maybe maven is using a different java version?
>
> On Sun, Feb 22, 2015 at 2:05 PM, Dulaj Viduranga
> wrote:
&g
s compiler
> contains a bug.
>
> You can run Flink with all JREs 6+ (including Oracle JDK 6).
>
> I would recommend you to upgrade your Java version to 7 anyways, because 6
> doesn't receive any security updates anymore.
>
>
> On Sun, Feb 22, 2015 at 12:55 PM, Dul
Hi all,
I’m new here. I had some problems building flink on my mac. Could someone
please take a look and help me out..?
Dulaj Viduranga.
[INFO] Scanning for projects...
[WARNING]
[WARNING] Some problems were encountered while building the effective model for
org.apache.flink:flink-streaming
45 matches
Mail list logo
