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

2019-01-29 Thread Vu Ho (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755656#comment-16755656 ] Vu Ho commented on BEAM-6517: - Thanks everyone for looking into this. The problem I have is only with Spark

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

2019-01-28 Thread Vu Ho (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754591#comment-16754591 ] Vu Ho edited comment on BEAM-6517 at 1/29/19 5:45 AM: -- Updated: I tried this on Flink

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

2019-01-28 Thread Vu Ho (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754591#comment-16754591 ] Vu Ho commented on BEAM-6517: - Updated: I tried this on Flink after shading the library (by default it

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

2019-01-26 Thread Vu Ho (JIRA)
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: