Hi Shankara, can you give us some more details, e.g. - how do you run the job? - how do you add/include the jar with the missing class? - is that jar file part of your program's jar or separate? - 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 ...
Nico On Tuesday, 7 November 2017 15:34:35 CET Shankara wrote: > Hi, > > I am using flink 2.1.0 version and protobuf-java 2.6.1 version. > I am getting below exception for protobuf generated class. I have included > jar which is having that class. > > Can you please help me to check it. > > org.apache.beam.sdk.util.UserCodeException: > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException > : Could not forward element to next operator > at > org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36) > at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1$DoFnInvoker.invo > keProcessElement(Unknown Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoF > nRunner.java:177) at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunne > r.java:141) at > org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processEle > ment(DoFnRunnerWithMetricsUpdate.java:65) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.pr > ocessElement(DoFnOperator.java:368) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.TimestampedCollector.collect(Timest > ampedCollector.java:51) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:213) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:207) at > org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(Stream > FlatMap.java:50) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermar > kContext.processAndCollectWithTimestamp(StreamSourceContexts.java:309) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkConte > xt.collectWithTimestamp(StreamSourceContexts.java:408) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.emitElement(UnboundedSourceWrapper.java:329) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.run(UnboundedSourceWrapper.java:267) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 87) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 55) at > org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTa > sk.java:95) at > org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(Stopp > ableSourceStreamTask.java:39) at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:2 > 63) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702) > at java.lang.Thread.run(Thread.java:748) > Caused by: > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException > : Could not forward element to next operator > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:530) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$Mu > ltiOutputOutputManagerFactory$1.output(DoFnOperator.java:730) at > org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFn > Runner.java:211) at > org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.ja > va:66) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:436) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:424) at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1.processElement(K > afkaIO.java:690) Caused by: org.apache.beam.sdk.util.UserCodeException: > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException > : Could not forward element to next operator > at > org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:36) > at > com.huawei.ccn.intelliom.ims.feature.extractor.KpiExtractor$FilterSamplesToA > dv$DoFnInvoker.invokeProcessElement(Unknown Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoF > nRunner.java:177) at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunne > r.java:141) at > org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processEle > ment(DoFnRunnerWithMetricsUpdate.java:65) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.pr > ocessElement(DoFnOperator.java:368) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$Mu > ltiOutputOutputManagerFactory$1.output(DoFnOperator.java:730) at > org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFn > Runner.java:211) at > org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.ja > va:66) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:436) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:424) at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1.processElement(K > afkaIO.java:690) at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1$DoFnInvoker.invo > keProcessElement(Unknown Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoF > nRunner.java:177) at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunne > r.java:141) at > org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processEle > ment(DoFnRunnerWithMetricsUpdate.java:65) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.pr > ocessElement(DoFnOperator.java:368) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.TimestampedCollector.collect(Timest > ampedCollector.java:51) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:213) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:207) at > org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(Stream > FlatMap.java:50) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermar > kContext.processAndCollectWithTimestamp(StreamSourceContexts.java:309) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkConte > xt.collectWithTimestamp(StreamSourceContexts.java:408) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.emitElement(UnboundedSourceWrapper.java:329) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.run(UnboundedSourceWrapper.java:267) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 87) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 55) at > org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTa > sk.java:95) at > org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(Stopp > ableSourceStreamTask.java:39) at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:2 > 63) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702) > at java.lang.Thread.run(Thread.java:748) > Caused by: > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException > : Could not forward element to next operator > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:530) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$Mu > ltiOutputOutputManagerFactory$1.output(DoFnOperator.java:730) at > org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFn > Runner.java:211) at > org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.ja > va:66) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:436) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:424) at > com.huawei.ccn.intelliom.ims.feature.extractor.KpiExtractor$FilterSamplesToA > dv.processElement(KpiExtractor.java:242) Caused by: > java.lang.RuntimeException: Unable to find proto buffer class at > com.google.protobuf.GeneratedMessageLite$SerializedForm.readResolve(Generate > dMessageLite.java:775) at > sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62 > ) at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl > .java:43) at java.lang.reflect.Method.invoke(Method.java:498) > at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java: 1148) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2036) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535) > at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422) > at > org.apache.beam.sdk.coders.SerializableCoder.decode(SerializableCoder.java:1 > 38) at > org.apache.beam.sdk.coders.SerializableCoder.decode(SerializableCoder.java:4 > 8) at org.apache.beam.sdk.coders.Coder.decode(Coder.java:160) > at org.apache.beam.sdk.coders.KvCoder.decode(KvCoder.java:85) > at org.apache.beam.sdk.coders.KvCoder.decode(KvCoder.java:36) > at > org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.decode(Windowe > dValue.java:667) at > org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.decode(Windowe > dValue.java:599) at > org.apache.beam.sdk.util.CoderUtils.decodeFromSafeStream(CoderUtils.java:130 > ) at > org.apache.beam.sdk.util.CoderUtils.decodeFromByteArray(CoderUtils.java:113) > at > org.apache.beam.sdk.util.CoderUtils.decodeFromByteArray(CoderUtils.java:107) > at org.apache.beam.sdk.util.CoderUtils.clone(CoderUtils.java:156) at > org.apache.beam.runners.flink.translation.types.CoderTypeSerializer.copy(Cod > erTypeSerializer.java:64) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:526) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$Mu > ltiOutputOutputManagerFactory$1.output(DoFnOperator.java:730) at > org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFn > Runner.java:211) at > org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.ja > va:66) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:436) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:424) at > com.huawei.ccn.intelliom.ims.feature.extractor.KpiExtractor$FilterSamplesToA > dv.processElement(KpiExtractor.java:242) at > com.huawei.ccn.intelliom.ims.feature.extractor.KpiExtractor$FilterSamplesToA > dv$DoFnInvoker.invokeProcessElement(Unknown Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoF > nRunner.java:177) at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunne > r.java:141) at > org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processEle > ment(DoFnRunnerWithMetricsUpdate.java:65) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.pr > ocessElement(DoFnOperator.java:368) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$Mu > ltiOutputOutputManagerFactory$1.output(DoFnOperator.java:730) at > org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFn > Runner.java:211) at > org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.ja > va:66) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:436) at > org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(Simp > leDoFnRunner.java:424) at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1.processElement(K > afkaIO.java:690) at > org.apache.beam.sdk.io.kafka.KafkaIO$TypedWithoutMetadata$1$DoFnInvoker.invo > keProcessElement(Unknown Source) > at > org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoF > nRunner.java:177) at > org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunne > r.java:141) at > org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processEle > ment(DoFnRunnerWithMetricsUpdate.java:65) at > org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.pr > ocessElement(DoFnOperator.java:368) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.TimestampedCollector.collect(Timest > ampedCollector.java:51) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:213) at > org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$StripIdsMap > .flatMap(FlinkStreamingTransformTranslators.java:207) at > org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(Stream > FlatMap.java:50) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .pushToOperator(OperatorChain.java:528) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:503) at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput > .collect(OperatorChain.java:483) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:891) at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutp > ut.collect(AbstractStreamOperator.java:869) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermar > kContext.processAndCollectWithTimestamp(StreamSourceContexts.java:309) at > org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkConte > xt.collectWithTimestamp(StreamSourceContexts.java:408) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.emitElement(UnboundedSourceWrapper.java:329) at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSou > rceWrapper.run(UnboundedSourceWrapper.java:267) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 87) at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java: > 55) at > org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTa > sk.java:95) at > org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(Stopp > ableSourceStreamTask.java:39) at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:2 > 63) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:702) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.lang.ClassNotFoundException: > com.huawei.ccn.intelliom.ims.MeasurementTable$measurementTable > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:264) > at > com.google.protobuf.GeneratedMessageLite$SerializedForm.readResolve(Generate > dMessageLite.java:768) ... 77 more > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
signature.asc
Description: This is a digitally signed message part.
