[ https://issues.apache.org/jira/browse/BEAM-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16079826#comment-16079826 ]
ASF GitHub Bot commented on BEAM-2486: -------------------------------------- Github user kennknowles closed the pull request at: https://github.com/apache/beam/pull/3519 > 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)