[jira] [Created] (FLINK-1286) Failures and bad error message in CollectionInputFormat

["Stephan Ewen (JIRA)" <ji...@apache.org>]

Stephan Ewen created FLINK-1286:
-----------------------------------

             Summary: Failures and bad error message in CollectionInputFormat
                 Key: FLINK-1286
                 URL: https://issues.apache.org/jira/browse/FLINK-1286
             Project: Flink
          Issue Type: Bug
          Components: Java API, Scala API
    Affects Versions: 0.8-incubating
            Reporter: Stephan Ewen
            Assignee: Stephan Ewen
             Fix For: 0.8-incubating


Serialization failures occur in some cases in the CollectionInputFormat. The error message is also very non-helpful:

{code}
java.lang.IllegalStateException: unread block data
at java.io.ObjectInputStream$BlockDataInputStream.setBlockDataMode(ObjectInputStream.java:2421)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1382)
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1990)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1915)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:274)
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:236)
at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:281)
at org.apache.flink.runtime.jobgraph.InputFormatVertex.initializeOnMaster(InputFormatVertex.java:46)
at org.apache.flink.runtime.jobmanager.JobManager.submitJob(JobManager.java:380)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:420)
at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:947)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)