[GitHub] [beam] lukecwik commented on a change in pull request #12617: [BEAM-10670] Update Samza to be opt-out for SplittableDoFn powering the Read transform.

2020-09-15 Thread GitBox
lukecwik commented on a change in pull request #12617: URL: https://github.com/apache/beam/pull/12617#discussion_r488825043 ## File path: runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java ## @@ -106,6 +107,7 @@ public PortablePipelineResult

[GitHub] [beam] lukecwik commented on a change in pull request #12617: [BEAM-10670] Update Samza to be opt-out for SplittableDoFn powering the Read transform.

2020-09-12 Thread GitBox
lukecwik commented on a change in pull request #12617: URL: https://github.com/apache/beam/pull/12617#discussion_r487349793 ## File path: runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java ## @@ -0,0 +1,251 @@ +/* + *

[GitHub] [beam] lukecwik commented on a change in pull request #12617: [BEAM-10670] Update Samza to be opt-out for SplittableDoFn powering the Read transform.

2020-09-12 Thread GitBox
lukecwik commented on a change in pull request #12617: URL: https://github.com/apache/beam/pull/12617#discussion_r487349793 ## File path: runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java ## @@ -0,0 +1,251 @@ +/* + *

[GitHub] [beam] lukecwik commented on a change in pull request #12617: [BEAM-10670] Update Samza to be opt-out for SplittableDoFn powering the Read transform.

2020-09-12 Thread GitBox
lukecwik commented on a change in pull request #12617: URL: https://github.com/apache/beam/pull/12617#discussion_r487349793 ## File path: runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java ## @@ -0,0 +1,251 @@ +/* + *

[GitHub] [beam] lukecwik commented on a change in pull request #12617: [BEAM-10670] Update Samza to be opt-out for SplittableDoFn powering the Read transform.

2020-09-11 Thread GitBox
lukecwik commented on a change in pull request #12617: URL: https://github.com/apache/beam/pull/12617#discussion_r487349793 ## File path: runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java ## @@ -0,0 +1,251 @@ +/* + *