Hi,
"java.io.IOException: Connection reset by peer" is usually thrown if the
remote peer terminates the connection. So the interesting bit would be
who's requesting static files from Flink. So far we serve the web frontend
and the log and stdout files via the StaticFileServerHandler. Maybe it's
DC
And We see the same too
Med venlig hilsen / Best regards
Lasse Nedergaard
> Den 8. feb. 2018 kl. 11.58 skrev Stavros Kontopoulos
> :
>
> We see the same issue here (2):
> 2018-02-08 10:55:11,447 ERROR
> org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler - Caught
> exception
>
We see the same issue here (2):
2018-02-08 10:55:11,447 ERROR
org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler - Caught
exception
java.io.IOException: Connection reset by peer
Stavros
On Sat, Jan 13, 2018 at 9:59 PM, Eron Wright wrote:
> Hello Dongwon,
>
> Flink doesn't suppor
Hello Dongwon,
Flink doesn't support a 'unique host' constraint at this time; it simply
accepts adequate offers without any such consideration. Flink does
support a 'host attributes' constraint to filter certain hosts, but that's
not applicable here.
Under the hood, Flink uses a library called
Hi Dongwon,
I am not familiar with the deployment on DC/OS. However, Eron Wright and
Jörg
Schad (cc'd), who have worked on the Mesos integration, might be able to
help
you.
Best,
Gary
On Tue, Jan 9, 2018 at 10:29 AM, Dongwon Kim wrote:
> Hi,
>
> I've launched JobManager and TaskManager on DC/O
Hi,
I've launched JobManager and TaskManager on DC/OS successfully.
Now I have two new issues:
1) All TaskManagers are scheduled on a single node.
- Is it intended to maximize data locality and minimize network communication
cost?
- Is there an option in Flink to adjust the behavior of JobManag
