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 ...
> >
>
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
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-
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
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/>
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
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
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
