[GitHub] [beam] annaqin418 commented on pull request #12157: [BEAM-7587] Spark portable streaming

2020-08-21 Thread GitBox
annaqin418 commented on pull request #12157: URL: https://github.com/apache/beam/pull/12157#issuecomment-678534421 Run Java Spark PortableValidatesRunner Streaming This is an automated message from the Apache Git Service. To

[GitHub] [beam] annaqin418 commented on pull request #12157: [BEAM-7587] Spark portable streaming

2020-08-20 Thread GitBox
annaqin418 commented on pull request #12157: URL: https://github.com/apache/beam/pull/12157#issuecomment-677947945 run seed job This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [beam] annaqin418 commented on pull request #12157: [BEAM-7587] Spark portable streaming

2020-08-14 Thread GitBox
annaqin418 commented on pull request #12157: URL: https://github.com/apache/beam/pull/12157#issuecomment-674267670 R: @ibzib @robertwb I still need to document all of the limitations (e.g. side inputs, state/timers), but this code is ready for review

[GitHub] [beam] annaqin418 commented on pull request #12157: [BEAM-7587] Spark portable streaming

2020-07-07 Thread GitBox
annaqin418 commented on pull request #12157: URL: https://github.com/apache/beam/pull/12157#issuecomment-655169602 R: @robertwb This PR is still a while from being ready, but just wanted to tag you as well in my progress.

[GitHub] [beam] annaqin418 commented on pull request #12157: [BEAM-7587] Spark portable streaming

2020-07-01 Thread GitBox
annaqin418 commented on pull request #12157: URL: https://github.com/apache/beam/pull/12157#issuecomment-652678870 R: @ibzib Creating this PR for now to track changes as I go. I set up some of the new interfaces, could you check if they look reasonable? I currently have streaming