[jira] [Created] (BEAM-5363) Java DirectRunner should implement retry and support @RequiresStableInput
Yueyang Qiu created BEAM-5363: - Summary: Java DirectRunner should implement retry and support @RequiresStableInput Key: BEAM-5363 URL: https://issues.apache.org/jira/browse/BEAM-5363 Project: Beam Issue Type: New Feature Components: runner-direct Reporter: Yueyang Qiu Assignee: Daniel Oliveira [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5362) Support @RequiresStableInput on Samza runner
Yueyang Qiu created BEAM-5362: - Summary: Support @RequiresStableInput on Samza runner Key: BEAM-5362 URL: https://issues.apache.org/jira/browse/BEAM-5362 Project: Beam Issue Type: New Feature Components: runner-samza Reporter: Yueyang Qiu Assignee: Xinyu Liu [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5361) Support @RequiresStableInput on Gearpump runner
Yueyang Qiu created BEAM-5361: - Summary: Support @RequiresStableInput on Gearpump runner Key: BEAM-5361 URL: https://issues.apache.org/jira/browse/BEAM-5361 Project: Beam Issue Type: New Feature Components: runner-gearpump Reporter: Yueyang Qiu Assignee: Manu Zhang [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5360) Support @RequiresStableInput on Apex runner
Yueyang Qiu created BEAM-5360: - Summary: Support @RequiresStableInput on Apex runner Key: BEAM-5360 URL: https://issues.apache.org/jira/browse/BEAM-5360 Project: Beam Issue Type: New Feature Components: runner-apex Reporter: Yueyang Qiu [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5359) Support @RequiresStableInput on Flink runner
Yueyang Qiu created BEAM-5359: - Summary: Support @RequiresStableInput on Flink runner Key: BEAM-5359 URL: https://issues.apache.org/jira/browse/BEAM-5359 Project: Beam Issue Type: New Feature Components: runner-flink Reporter: Yueyang Qiu Assignee: Aljoscha Krettek [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5358) Support @RequiresStableInput on Spark runner
Yueyang Qiu created BEAM-5358: - Summary: Support @RequiresStableInput on Spark runner Key: BEAM-5358 URL: https://issues.apache.org/jira/browse/BEAM-5358 Project: Beam Issue Type: New Feature Components: runner-spark Reporter: Yueyang Qiu Assignee: Amit Sela [https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (BEAM-3194) Support annotating that a DoFn requires stable / deterministic input for replay/retry
[ https://issues.apache.org/jira/browse/BEAM-3194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yueyang Qiu updated BEAM-3194: -- Component/s: sdk-java-core > Support annotating that a DoFn requires stable / deterministic input for > replay/retry > - > > Key: BEAM-3194 > URL: https://issues.apache.org/jira/browse/BEAM-3194 > Project: Beam > Issue Type: New Feature > Components: beam-model, sdk-java-core >Reporter: Kenneth Knowles >Assignee: Yueyang Qiu >Priority: Major > Time Spent: 2h 20m > Remaining Estimate: 0h > > See the thread: > https://lists.apache.org/thread.html/5fd81ce371aeaf642665348f8e6940e308e04275dd7072f380f9f945@%3Cdev.beam.apache.org%3E > We need this in order to have truly cross-runner end-to-end exactly once via > replay + idempotence. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (BEAM-4684) Support @RequiresStableInput on Dataflow runner in Java SDK
[ https://issues.apache.org/jira/browse/BEAM-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yueyang Qiu updated BEAM-4684: -- Component/s: (was: sdk-java-core) runner-dataflow > Support @RequiresStableInput on Dataflow runner in Java SDK > --- > > Key: BEAM-4684 > URL: https://issues.apache.org/jira/browse/BEAM-4684 > Project: Beam > Issue Type: New Feature > Components: runner-dataflow >Reporter: Yueyang Qiu >Assignee: Yueyang Qiu >Priority: Major > Time Spent: 2h 50m > Remaining Estimate: 0h > > https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (BEAM-4684) Support @RequiresStableInput on Dataflow runner in Java SDK
[ https://issues.apache.org/jira/browse/BEAM-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yueyang Qiu updated BEAM-4684: -- Issue Type: New Feature (was: Bug) > Support @RequiresStableInput on Dataflow runner in Java SDK > --- > > Key: BEAM-4684 > URL: https://issues.apache.org/jira/browse/BEAM-4684 > Project: Beam > Issue Type: New Feature > Components: sdk-java-core >Reporter: Yueyang Qiu >Assignee: Yueyang Qiu >Priority: Major > Time Spent: 2h 40m > Remaining Estimate: 0h > > https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (BEAM-4684) Support @RequiresStableInput on Dataflow runner in Java SDK
[ https://issues.apache.org/jira/browse/BEAM-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yueyang Qiu updated BEAM-4684: -- Summary: Support @RequiresStableInput on Dataflow runner in Java SDK (was: Support of @RequiresStableInput annotation in Java SDK) > Support @RequiresStableInput on Dataflow runner in Java SDK > --- > > Key: BEAM-4684 > URL: https://issues.apache.org/jira/browse/BEAM-4684 > Project: Beam > Issue Type: Bug > Components: sdk-java-core >Reporter: Yueyang Qiu >Assignee: Kenneth Knowles >Priority: Major > > https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-4684) Support of @RequiresStableInput annotation in Java SDK
Yueyang Qiu created BEAM-4684: - Summary: Support of @RequiresStableInput annotation in Java SDK Key: BEAM-4684 URL: https://issues.apache.org/jira/browse/BEAM-4684 Project: Beam Issue Type: Bug Components: sdk-java-core Reporter: Yueyang Qiu Assignee: Kenneth Knowles https://docs.google.com/document/d/117yRKbbcEdm3eIKB_26BHOJGmHSZl1YNoF0RqWGtqAM -- This message was sent by Atlassian JIRA (v7.6.3#76005)
