[ https://issues.apache.org/jira/browse/BEAM-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075682#comment-16075682 ]
Kenneth Knowles commented on BEAM-2486: --------------------------------------- This is in PR and very easy, should make the agreed upon July 10th > Should throws some useful messages when statefulParDo use non-KV input > ---------------------------------------------------------------------- > > Key: BEAM-2486 > URL: https://issues.apache.org/jira/browse/BEAM-2486 > Project: Beam > Issue Type: Improvement > Components: runner-core, runner-flink > Reporter: Jingsong Lee > Assignee: Kenneth Knowles > Fix For: 2.1.0 > > > Now Flink runner will throws a ClassCastException without detail messages > when a statefulParDo use non-KV input. It is not easy for users to find > errors and causes. -- This message was sent by Atlassian JIRA (v6.4.14#64029)