I have a UDF that uses an annotation to the loop variable inside a for loop. I 
noticed that this annotation gets dropped at some point when the UDF is shipped 
to the TaskManager. I was told that this happens in the Optimizer but I would 
like to know where this happens exactly and if there is an easy way to 
influence this behavior. The annotation is needed by another tool that 
interoperates with Flink.

Any pointer to the source code would be appreciated.


Attachment: signature.asc
Description: Message signed with OpenPGP

Reply via email to