ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally

Hi, I am trying to execute a flatmapFunction for a xmlString(byte array) using plugin development. I have added the required dependencies for flink. I am using Flink-0.8.1. The stack trace of the execution is as follows: org.apache.flink.runtime.client.JobExecutionException: java.lang.Exception:

[jira] [Created] (FLINK-2120) Rename AbstractJobVertex to JobVertex

Ufuk Celebi created FLINK-2120: -- Summary: Rename AbstractJobVertex to JobVertex Key: FLINK-2120 URL: https://issues.apache.org/jira/browse/FLINK-2120 Project: Flink Issue Type: Wish Co

[jira] [Created] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

Ufuk Celebi created FLINK-2119: -- Summary: Add ExecutionGraph support for leg-wise scheduling Key: FLINK-2119 URL: https://issues.apache.org/jira/browse/FLINK-2119 Project: Flink Issue Type: Impr