Re: Kryo StackOverflowError

2016-04-12 Thread Andrew Palumbo
Hi, Great! Do you think that this is something that you'll be enabling in your upcoming 1.0.2 release? We plan on putting out a maintenance Mahout Release relatively soon and this would allow us to speed up Matrix Multiplication greatly. Thanks, Andy __

[jira] [Created] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently

2016-04-12 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3746: Summary: WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently Key: FLINK-3746 URL: https://issues.apache.org/jira/browse/FLINK-3746 Project: Flink

[jira] [Created] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently

2016-04-12 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3745: Summary: TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently Key: FLINK-3745 URL: https://issues.apache.org/jira/browse/FLINK-3745 P

[jira] [Created] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally

2016-04-12 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3744: Summary: LocalFlinkMiniClusterITCase times out occasionally when building locally Key: FLINK-3744 URL: https://issues.apache.org/jira/browse/FLINK-3744 Project: Flink

[jira] [Created] (FLINK-3743) Upgrate breeze from 0.11.2 to 0.12

2016-04-12 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3743: Summary: Upgrate breeze from 0.11.2 to 0.12 Key: FLINK-3743 URL: https://issues.apache.org/jira/browse/FLINK-3743 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-3742) Add Multi Layer Perceptron Predictor

2016-04-12 Thread Trevor Grant (JIRA)
Trevor Grant created FLINK-3742: --- Summary: Add Multi Layer Perceptron Predictor Key: FLINK-3742 URL: https://issues.apache.org/jira/browse/FLINK-3742 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

2016-04-12 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3741: Summary: Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. Key: FLINK-3741 URL: https://issues.apache.org/jira/browse/FLINK-3741

Re: Kryo StackOverflowError

2016-04-12 Thread Till Rohrmann
+1 On Tue, Apr 12, 2016 at 1:13 PM, Robert Metzger wrote: > Good catch Till! > > I just checked it with the Mahout source code and the issues is gone with > reference tracking enabled. > > I would just re-enable it again in Flink. > > On Tue, Apr 12, 2016 at 10:20 AM, Till Rohrmann > wrote: > >

Flink Interpreter w/ yarn-session

2016-04-12 Thread Andrea Sella
Hi, I am working to allow Zeppelin's flink interpreter to connect an existing yarn cluster. Yarn cluster has started via yarn-session and flink's version is 1.0.0. My approach is to read host and port from .yarn-properties and pass them to IFlinkLoop. Now I am facing an issue with Session ID when

[jira] [Created] (FLINK-3740) Session Window State is Not Checkpointed

2016-04-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3740: --- Summary: Session Window State is Not Checkpointed Key: FLINK-3740 URL: https://issues.apache.org/jira/browse/FLINK-3740 Project: Flink Issue Type: Bug

Re: Kryo StackOverflowError

2016-04-12 Thread Robert Metzger
Good catch Till! I just checked it with the Mahout source code and the issues is gone with reference tracking enabled. I would just re-enable it again in Flink. On Tue, Apr 12, 2016 at 10:20 AM, Till Rohrmann wrote: > Hey guys, > > I have a suspicion which could be the culprit: Could change th

[jira] [Created] (FLINK-3739) Add a null literal to Table API

2016-04-12 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3739: --- Summary: Add a null literal to Table API Key: FLINK-3739 URL: https://issues.apache.org/jira/browse/FLINK-3739 Project: Flink Issue Type: Improvement

Re: Kryo StackOverflowError

2016-04-12 Thread Till Rohrmann
Hey guys, I have a suspicion which could be the culprit: Could change the line KryoSerializer.java:328 to kryo.setReferences(true) and try if the error still remains? We deactivated the reference tracking and now Kryo shouldn’t be able to resolve cyclic references properly. Cheers, Till ​ On Mon