Phew, thanks for letting us know! 😃
And yes, there were some problems with Avro and class loading but I was hoping
that we got them all before Flink 1.4.0.
Best,
Aljoscha
> On 20. Dec 2017, at 10:54, Kien Truong wrote:
>
> It turn out that our flink branch is out-of-date. Sorry for all the no
It turn out that our flink branch is out-of-date. Sorry for all the noise. :)
Regards,
Kien
Sent from TypeApp
On Dec 20, 2017, 16:42, at 16:42, Kien Truong wrote:
>Upon further investigation, we found out that the reason:
>
>* The cluster was started on YARN with the hadoop classpath, which
Upon further investigation, we found out that the reason:
* The cluster was started on YARN with the hadoop classpath, which includes
Avro. Therefore, Avro's SpecificRecord class was loaded using
sun.misc.Launcher$AppClassLoader
* Our LteSession class was submitted with the application jar, an
Hi,
After upgrading to Flink 1.4, we encounter this exception
Caused by: java.lang.NullPointerException: in com.viettel.big4g.avro.LteSession
in long null of long in field tmsi of com.viettel.big4g.avro.LteSession
at org.apache.avro.reflect.ReflectDatumWriter.write(ReflectDatumWriter.java:161)
a
