[
https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048445#comment-15048445
]
ASF GitHub Bot commented on FLINK-3145:
---------------------------------------
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1441#issuecomment-163181852
Not sure about the Kryo dependency in the root pom. We already pin the Kryo
version via dependency management in the root pom. This eliminates most
conflicts in sub projects. The proposed changes are a special solution for the
flink-storm module which has conflicting transitive dependencies due to its
dependency on Storm.
Kryo version is 2.24.0. Where did you get the 3.0.3 from?
> Storm examples can't be run without flink-java as dependency
> ------------------------------------------------------------
>
> Key: FLINK-3145
> URL: https://issues.apache.org/jira/browse/FLINK-3145
> Project: Flink
> Issue Type: Bug
> Components: Build System, Java API, Storm Compatibility
> Affects Versions: 1.0.0
> Reporter: Maximilian Michels
> Assignee: Maximilian Michels
> Fix For: 1.0.0
>
>
> The following exception occurs when you run as storm WordCount example with
> {{flink-storm}} but without {{flink-java}} as Maven dependencies:
> {noformat}
> com.esotericsoftware.kryo.KryoException: Unable to find class: go
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:138)
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:115)
> at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:610)
> at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:721)
> at
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.deserialize(KryoSerializer.java:223)
> at
> org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:135)
> at
> org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:30)
> at
> org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer.deserialize(StreamRecordSerializer.java:110)
> at
> org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer.deserialize(StreamRecordSerializer.java:41)
> at
> org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate.read(NonReusingDeserializationDelegate.java:55)
> at
> org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:164)
> at
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:135)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:63)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:232)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:561)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.ClassNotFoundException: go
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> at java.lang.Class.forName0(Native Method)
> at java.lang.Class.forName(Class.java:348)
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:136)
> ... 15 more
> {noformat}
> Furthermore, tuples don't seem to be processed correctly even before the
> exception occurs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
