[jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

["Sebastian Klemke (JIRA)" <ji...@apache.org>]

Sebastian Klemke created FLINK-3304:
---------------------------------------

             Summary: AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode
                 Key: FLINK-3304
                 URL: https://issues.apache.org/jira/browse/FLINK-3304
             Project: Flink
          Issue Type: Bug
    Affects Versions: 0.10.1, 1.0.0
            Reporter: Sebastian Klemke


Quoting flink cli (schema and names modified):

"The program finished with the following exception:

User-defined object org.apache.flink.api.java.io.AvroOutputFormat@5f253dfb (org.apache.flink.api.java.io.AvroOutputFormat) contains non-serializable field userDefinedSchema = {"type":"record","name":"Pojo","namespace":"com.example","fields":[{"name":"id","type":["null","string"],"default":null,"subtype":"objectid"}],"EntityVersion":"0.1.0"}
        org.apache.flink.api.common.operators.util.UserCodeObjectWrapper.<init>(UserCodeObjectWrapper.java:84)
        org.apache.flink.api.common.operators.GenericDataSinkBase.<init>(GenericDataSinkBase.java:68)
        org.apache.flink.api.java.operators.DataSink.translateToDataFlow(DataSink.java:258)
        org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:64)
        org.apache.flink.api.java.operators.OperatorTranslation.translateToPlan(OperatorTranslation.java:49)
        org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:939)
        org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:907)
        org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:57)
        com.example.Tool.main(Tool.java:86)
Shutting down YARN cluster"




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