RE: Kryo StackOverflowError

2016-04-11 Thread Lisonbee, Todd
Hi, I also got this error message when I had private inner classes: public class A { private class B { } } I was able to fix by making the inner classes public static: public class A { public static class B { } } When I was trying to debug it seemed this error message can be ca

RE: Aggregation Design Questions

2016-03-23 Thread Lisonbee, Todd
dev() summary.getField(1).maxStringLength() Thanks. -Original Message- From: Lisonbee, Todd [mailto:todd.lison...@intel.com] Sent: Wednesday, March 23, 2016 9:46 AM To: dev@flink.apache.org Subject: Aggregation Design Questions Hello, I'm working on adding Standard Devia

Aggregation Design Questions

2016-03-23 Thread Lisonbee, Todd
Hello, I'm working on adding Standard Deviation and others to the list of Aggregations, https://issues.apache.org/jira/browse/FLINK-3613 Unfortunately, I didn't get very far because the general design of Aggreation on DataSets needs to change and each solution seems to have drawbacks. For exam