Github user StephanEwen commented on the issue:

    https://github.com/apache/flink/pull/5120
  
    Looks good to me. This is actually two fixes in one:
    
      1. Avro should not be in `flink-dist`, because starting with 
`org.apache.flink`, it would always be loaded *"parent first"*. That causes 
problems because Avro classes exist multiple times, both in the parent and in 
the child classloader, failing equality and 'instanceof' comparisons.
    
      2. The Avro Utils were never using any code in the user code jar, only 
code in the classpath.
    
    This is good for now, but it shows that the reveres classloading has some 
subtle implication as soon as flink dependencies occur both in the user code 
jar and in `/lib`. 


---

Reply via email to