[jira] [Comment Edited] (BEAM-3110) The transform Read(UnboundedKafkaSource) is currently not supported

[ https://issues.apache.org/jira/browse/BEAM-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401410#comment-16401410 ] Ivan Li edited comment on BEAM-3110 at 3/16/18 3:02 AM: I have the

[jira] [Commented] (BEAM-3110) The transform Read(UnboundedKafkaSource) is currently not supported

[ https://issues.apache.org/jira/browse/BEAM-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401410#comment-16401410 ] Ivan Li commented on BEAM-3110: --- I meat the same issue in my gradle beam project, if you are

[jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975976#comment-15975976 ] Ivan Li commented on BEAM-315: -- I'm in batch mode, I think it's something wrong with the coder

[jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15880316#comment-15880316 ] Ivan Li commented on BEAM-315: -- I'm facing similar issue when writing beam job and run in flink

[jira] [Updated] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Li updated BEAM-315: - Attachment: UniPatNumToOrigNumFn.java UniPatNumToLineFn.java PacUniPatToCiteGroupFn.j