flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Teena Kappen // BPRISE <teena.kap...@bprise.com>
Subject RE: Remote Debugging Flink
Date Fri, 22 Jun 2018 13:46:27 GMT
In conf.yaml file,
replace the setting ‘env.java.opts: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005"
‘ as mentioned in the link with the below setting

env.java.opts.taskmanager: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005"

Regards,
Teena

From: Tharmakulasingham Inthirakumaaran <inthira.14@cse.mrt.ac.lk>
Sent: 22 June 2018 17:10
To: user@flink.apache.org
Subject: Remote Debugging Flink


Hi,


I am new to flink and trying to remote debug flink cluster. I followed the instructions mentioned
in the link[1] but when I do that I could not run the  SocketWindowWordCount example(any example
at all). The main problem is there are no task slots or task manager initiated. Then I followed
the link[2] and set the java.opts for task manager but still don't have any task slots initiated.


I am currently running flink instance in the local machine. I checked the Dispatcher’s web
frontend to see whether slots have initiated or not.


The error I am getting at the terminal is like:

Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could
not allocate all requires slots within timeout of 300000 ms. Slots required: 2, slots allocated:
0

at org.apache.flink.runtime.executiongraph.ExecutionGraph.lambda$scheduleEager$3(ExecutionGraph.java:984)

at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)...


Can you please suggest the correct way to do this?


Best,

inthira


source links


[1]https://cwiki.apache.org/confluence/display/FLINK/Remote+Debugging+of+Flink+Clusters<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fcwiki.apache.org%2Fconfluence%2Fdisplay%2FFLINK%2FRemote%2BDebugging%2Bof%2BFlink%2BClusters&data=02%7C01%7Cteena.kappen%40bprise.com%7C5af59255cdc54f793f7608d5d834de28%7Cb7cfea21c1ff4c0a8e2ee7ccd5d8f54b%7C0%7C1%7C636652643966437522&sdata=pth2YorWq2zqBLZogCImU2XngxCUbkltveiKH9noraY%3D&reserved=0>

[2]https://stackoverflow.com/questions/50125340/remote-debugging-flink-local-cluster<https://emea01.safelinks.protection.outlook.com/?url=https%3A%2F%2Fstackoverflow.com%2Fquestions%2F50125340%2Fremote-debugging-flink-local-cluster&data=02%7C01%7Cteena.kappen%40bprise.com%7C5af59255cdc54f793f7608d5d834de28%7Cb7cfea21c1ff4c0a8e2ee7ccd5d8f54b%7C0%7C1%7C636652643966437522&sdata=IhOKECdVh537e%2BmvXu8VuovKwrofFep2N8zz6lvaQ%2Bs%3D&reserved=0>


--
Inthirakumaaran.
Undergraduate student,
Department of Computer Science and Engineering
University of Moratuwa.
ContactNo:0766598050
Mime
View raw message