[jira] [Commented] (BEAM-6517) Pipeline fails with deserializing lambda function on Spark (MapElements)

[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755656#comment-16755656 ] Vu Ho commented on BEAM-6517: - Thanks everyone for looking into this. The problem I have is on

[jira] [Comment Edited] (BEAM-6517) Pipeline fails with deserializing lambda function on Spark (MapElements)

[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754591#comment-16754591 ] Vu Ho edited comment on BEAM-6517 at 1/29/19 5:45 AM: -- Updated: I tri

[jira] [Commented] (BEAM-6517) Pipeline fails with deserializing lambda function on Spark (MapElements)

[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754591#comment-16754591 ] Vu Ho commented on BEAM-6517: - Updated: I tried this on Flink after shading the library (by de

[jira] [Updated] (BEAM-6517) ParquetIO fails with lambda function on Spark

[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vu Ho updated BEAM-6517: Description: I'm trying to read from Parquet using Spark runner. Initial attempt failed because of version mismatch

[jira] [Created] (BEAM-6517) ParquetIO fails with lambda function on Spark

Vu Ho created BEAM-6517: --- Summary: ParquetIO fails with lambda function on Spark Key: BEAM-6517 URL: https://issues.apache.org/jira/browse/BEAM-6517 Project: Beam Issue Type: Bug Components: