[jira] [Created] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-03-15 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-3617: -- Summary: NPE from CaseClassSerializer when dealing with null Option field Key: FLINK-3617 URL: https://issues.apache.org/jira/browse/FLINK-3617 Project: Flink I

Re: Association failure ClassNotFoundException

2016-03-15 Thread Greg Hogan
Hi Till, The code in question is part of FLINK-2909 which is currently running on Travis but which does not trigger this issue. I'll keep looking. Thanks, Greg On Tue, Mar 15, 2016 at 11:30 AM, Till Rohrmann wrote: > Hi Greg, > > could you share an example program with us which reproduces the

[jira] [Created] (FLINK-3616) Python API version inconsistencies

2016-03-15 Thread Omar Alvarez (JIRA)
Omar Alvarez created FLINK-3616: --- Summary: Python API version inconsistencies Key: FLINK-3616 URL: https://issues.apache.org/jira/browse/FLINK-3616 Project: Flink Issue Type: Bug Comp

Re: Association failure ClassNotFoundException

2016-03-15 Thread Till Rohrmann
Hi Greg, could you share an example program with us which reproduces the problem? I suspect that, somehow, your user code class BlockInfo is sent directly to the JobManager where it is deserialized without the user code class loader. Cheers, Till ​ On Tue, Mar 15, 2016 at 4:19 PM, Greg Hogan wr

Association failure ClassNotFoundException

2016-03-15 Thread Greg Hogan
I am seeing a failure running my code starting with commit 0f8d76c6 (ExecutionConfig to JobGraph). Logs and stack trace are below. Using default configuration so a single TaskManager. From the web UI, data port is 33245 and path is akka.tcp:// flink@192.168.14.134:41339/user/taskmanager. Placing

[jira] [Created] (FLINK-3615) Add support for non-native SQL types

2016-03-15 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3615: Summary: Add support for non-native SQL types Key: FLINK-3615 URL: https://issues.apache.org/jira/browse/FLINK-3615 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Removing Non-Keyed WindowOperator

2016-03-15 Thread Ufuk Celebi
On Tue, Mar 15, 2016 at 11:06 AM, Ufuk Celebi wrote: > Are there any performance differences to be expected? To clarify: I don't think that it would be a blocker expect for if it had a yuge impact. – Ufuk

Re: [DISCUSS] Removing Non-Keyed WindowOperator

2016-03-15 Thread Ufuk Celebi
I'm not too familiar with this part of Flink, but your arguments certainly make sense. Are there any performance differences to be expected? – Ufuk On Tue, Mar 15, 2016 at 11:02 AM, Aljoscha Krettek wrote: > Hi folks, > I opened a Jira Issue: https://issues.apache.org/jira/browse/FLINK-3614 > >

[DISCUSS] Removing Non-Keyed WindowOperator

2016-03-15 Thread Aljoscha Krettek
Hi folks, I opened a Jira Issue: https://issues.apache.org/jira/browse/FLINK-3614 This is the text of the issue: I propose to remove the special Non-Keyed Window Operator and implement non-parallel windows by using the standard WindowOperator with a dummy KeySelector. Maintaining everything for

[jira] [Created] (FLINK-3614) Remove Non-Keyed Window Operator

2016-03-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3614: --- Summary: Remove Non-Keyed Window Operator Key: FLINK-3614 URL: https://issues.apache.org/jira/browse/FLINK-3614 Project: Flink Issue Type: Improvement