[jira] [Created] (FLINK-5948) Error in Python zip_with_index documentation

2017-03-01 Thread Geoffrey Mon (JIRA)
Geoffrey Mon created FLINK-5948: --- Summary: Error in Python zip_with_index documentation Key: FLINK-5948 URL: https://issues.apache.org/jira/browse/FLINK-5948 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5183) [py] Support multiple jobs per Python plan file

2016-11-28 Thread Geoffrey Mon (JIRA)
Geoffrey Mon created FLINK-5183: --- Summary: [py] Support multiple jobs per Python plan file Key: FLINK-5183 URL: https://issues.apache.org/jira/browse/FLINK-5183 Project: Flink Issue Type

Re: Python API iteration issues

2016-10-25 Thread Geoffrey Mon
> So, if this is indeed the problem then the fix is trivial: Within > PythonStreamer#startPython() the > file names are generated, and all we have to do is introduce a random > component. > > Regards, > Chesnay > > On 23.10.2016 04:58, Geoffrey Mon wrote: > > Hello

Python API iteration issues

2016-10-22 Thread Geoffrey Mon
Hello all, Thanks to Chesnay for the assistance with my other issues. I have one final issue that I can't figure out how to solve that should hopefully be the last one. I have been working on implementing bulk iterations in the Python API and using said iterations in a research project. At the mo

Re: Exception from in-progress implementation of Python API bulk iterations

2016-10-17 Thread Geoffrey Mon
pretty clear > idea how to fix it. > > The odd thing is that the Java API doesn't catch this type mismatch; > the date types are > known when the plan is generated. This kind of error shouldn't even > happen. > > On 13.10.2016 21:15, Geoffrey Mon wrote: >> Thank

Re: Exception from in-progress implementation of Python API bulk iterations

2016-10-13 Thread Geoffrey Mon
r and will look into it in more detail > > tomorrow. > > > > Regards, > > Chesnay > > > > On 12.10.2016 23:09, Geoffrey Mon wrote: > >> Hello, > >> > >> Has anyone had a chance to look into this? I am currently working on the > >

Re: Exception from in-progress implementation of Python API bulk iterations

2016-10-12 Thread Geoffrey Mon
Hello, Has anyone had a chance to look into this? I am currently working on the problem but I have minimal understanding of how the internal Flink Python API works; any expertise would be greatly appreciated. Thank you very much! Geoffrey On Sat, Oct 8, 2016 at 1:27 PM Geoffrey Mon wrote

Re: Exception from in-progress implementation of Python API bulk iterations

2016-10-08 Thread Geoffrey Mon
> > On 28.09.2016 05:38, Geoffrey Mon wrote: > > Hello Chesnay, > > > > Thank you for your help. After receiving your message I recompiled my > > version of Flink completely, and both the NullPointerException listed in > > the TODO and the ClassCastException with th

Re: Exception from in-progress implementation of Python API bulk iterations

2016-09-27 Thread Geoffrey Mon
7;ll try to take a look this week. > > > > Regards, > > Chesnay > > > > On 20.09.2016 02:38, Geoffrey Mon wrote: > >> Hello all, > >> > >> I have recently been working on adding bulk iterations to the Python > >> API of > >

Exception from in-progress implementation of Python API bulk iterations

2016-09-19 Thread Geoffrey Mon
4a I have been working on this issue but I don't have any ideas on what might be the problem. Perhaps someone more knowledgeable about the interior of the Python API could kindly help? Thank you very much. Geoffrey Mon

[jira] [Created] (FLINK-4098) Iteration support in Python API

2016-06-21 Thread Geoffrey Mon (JIRA)
Geoffrey Mon created FLINK-4098: --- Summary: Iteration support in Python API Key: FLINK-4098 URL: https://issues.apache.org/jira/browse/FLINK-4098 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API

2016-06-03 Thread Geoffrey Mon (JIRA)
Geoffrey Mon created FLINK-4017: --- Summary: [py] Add Aggregation support to Python API Key: FLINK-4017 URL: https://issues.apache.org/jira/browse/FLINK-4017 Project: Flink Issue Type