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
runPortabl
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 @@
+/*
+ * L
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 @@
+/*
+ * L
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 @@
+/*
+ * L
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 @@
+/*
+ * L