Re: Serialization and Deserialization of Avro messages stored in Kafka

at org.apache.flink.util.InstantiationUtil.serializeObject( > InstantiationUtil.java:315) > at org.apache.flink.api.java.ClosureCleaner.clean( > ClosureCleaner.java:81) > ... 6 more > > > I can't understand why the logs refer to a FlinkKafkaConsume

Re: Share Spring Application context among operators

Thanks in advance , > > On Sun, Feb 11, 2018 at 10:09 PM, Gordon Weakliem > wrote: > >> The WHOLE Spring ApplicationContext? This sounds like a bad idea. Most of >> that stuff isn't applicable outside a Spring application. Can't you cut it >> down to a sma

Re: Share Spring Application context among operators

t; Is there any way with which I can pass my spring ApplicationContext object > as parameter to flink operators? I understand I need to serialize this > object.Is there any existing serialization mechanism that I can use? > > Thanks in advance. > > -- [image: Img] * Gordon W

System.exit() vs throwing exception from the pipeline

thods be called, file handles closed etc? -- [image: Img] * Gordon Weakliem*| Sr. Software Engineer *O *303.493.5490 * Boulder* | NYC | London<https://twitter.com/sovrnholdings> <https://www.facebook.com/sovrnholdings/> <https://www.linkedin.com/company/3594890/>

Re: How to get kafka partition ID?

gt; .fold(...) > > But, I could not find the way. > How can I get the kafka-partition ID in Flink code? > > > -- > Regards, > Yuta > > -- [image: Img] * Gordon Weakliem*| Sr. Software Engineer *O *303.493.5490 * Boulder* | NYC | London&l

Re: specify user name when connecting to hdfs

esystem.java:4355) > > I have seen in other threads on this list where people mention setting up > the impersonate user in core-site.xml, but I've been unable to determine > the > correct setting. > > > > > -- > Sent from: http://apache-flink-user-mailing-

Re: Getting java.lang.ClassNotFoundException: for protobuf generated class

at 4:25 AM, Nico Kruber wrote: > > But wouldn't a failed dependency show another ClassNotFoundException? > > On Tuesday, 21 November 2017 20:31:58 CET Gordon Weakliem wrote: > > Isn't one cause for ClassNotFoundException that the class can't load due to > failed depe

Re: Getting java.lang.ClassNotFoundException: for protobuf generated class

ar. > > > > - is the missing class, i.e. "com.huawei.ccn.intelliom.ims. > MeasurementTable > > $measurementTable" (an inner class starting in lower-case?), really in > the > > jar > > file? It might be a wrongly generated protobuf class ... > > >