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

2016-10-08 Thread Geoffrey Mon
Hi Chesnay, Heh, I have discovered that if I do not restart Flink after running my original problematic script, then similar issues will manifest themselves in other otherwise working scripts. I haven't been able to completely narrow down the problem, but I promise this new script will have a Clas

Re: Allow TypeInfofactory regisration via ExecutionConfig

2016-10-08 Thread Alexander Alexandrov
To follow up on my on post, I think a straight-forward approach would be to make the `TypeExtractor.registerFactory` method public [1]. BTW, both the TypeInfo annotation [2] and TypeInfoFactory [3] itself refer to this method in the JavaDoc. However, besides these mentions I was not able to find

Allow TypeInfofactory regisration via ExecutionConfig

2016-10-08 Thread Alexander Alexandrov
I wanted to open this directly as a JIRA to follow-up on FLINK-3042, however my account (aalexandrov) does not seem to have the necessary privileges, so I will post this to the dev list instead. The current approach for registration of custom `TypeInformation` implementations which relies exclusiv