[jira] [Created] (FLINK-3017) Broken link 'Slots' on Streaming Programming Guide

2015-11-15 Thread Suneel Marthi (JIRA)
Suneel Marthi created FLINK-3017: Summary: Broken link 'Slots' on Streaming Programming Guide Key: FLINK-3017 URL: https://issues.apache.org/jira/browse/FLINK-3017 Project: Flink Issue Type:

[jira] [Created] (FLINK-3016) Update Flink roadmap

2015-11-15 Thread Slim Baltagi (JIRA)
Slim Baltagi created FLINK-3016: --- Summary: Update Flink roadmap Key: FLINK-3016 URL: https://issues.apache.org/jira/browse/FLINK-3016 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-3015) Bring Features Web Page up to speed

2015-11-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3015: --- Summary: Bring Features Web Page up to speed Key: FLINK-3015 URL: https://issues.apache.org/jira/browse/FLINK-3015 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables

2015-11-15 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3014: - Summary: Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables Key: FLINK-3014 URL: https://issues.apache.org/jira/browse/FLINK-3014 Projec

Re: Release notes for 0.10.0

2015-11-15 Thread Alexander Alexandrov
Is it possible to link to important JIRA-s in the list of new features as you did in the 0.8.0 release notes? For example, I was wondering whether I can find more information about the "Off-heap Managed Memory" model. Regards, Alexander 2015-11-14 20:53 GMT+01:00 Ron Crocker : > Hi Fabian - > >

[jira] [Created] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala

2015-11-15 Thread Suneel Marthi (JIRA)
Suneel Marthi created FLINK-3013: Summary: Incorrect package declaration in GellyScalaAPICompletenessTest.scala Key: FLINK-3013 URL: https://issues.apache.org/jira/browse/FLINK-3013 Project: Flink

[jira] [Created] (FLINK-3012) Refactor boilerplate code of while and if statements in DataSourceTask

2015-11-15 Thread jun aoki (JIRA)
jun aoki created FLINK-3012: --- Summary: Refactor boilerplate code of while and if statements in DataSourceTask Key: FLINK-3012 URL: https://issues.apache.org/jira/browse/FLINK-3012 Project: Flink I

Re: Connection reset by peer

2015-11-15 Thread Gyula Fóra
Thanks guys, Yes I am running with the new web interface. (no hadoop) I will deploy the new jars once your PR is merged Sachin, and we'll see :) Cheers, Gyula Sachin Goel ezt írta (időpont: 2015. nov. 15., V, 13:43): > I used to get a similar exception [I do not remember if the stack > trace w

Re: Connection reset by peer

2015-11-15 Thread Sachin Goel
I used to get a similar exception [I do not remember if the stack trace was *exactly *the same but it was from the web interface, and was due to the *connection reset by peer *]. Currently, the web interface does not handle exceptionCaught events cleanly. One of my PRs has addressed this by adding

Re: Connection reset by peer

2015-11-15 Thread Ufuk Celebi
This Exception was not thrown by the data exchange component. This is confirmed by the stack trace you have shared. It shows the DefaultThreadFactory, which we don’t use for the data exchange. Any Exception thrown there will actually fail the program. My best guess is that this was thrown by t