[jira] [Created] (BEAM-5831) Can not use Values.Create() multiple times in pipeline

Reza ardeshir rokni created BEAM-5831: - Summary: Can not use Values.Create() multiple times in pipeline Key: BEAM-5831 URL: https://issues.apache.org/jira/browse/BEAM-5831 Project: Beam

[jira] [Reopened] (BEAM-5831) Can not use Values.Create() multiple times in pipeline

[ https://issues.apache.org/jira/browse/BEAM-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reopened BEAM-5831: --- > Can not use Values.Create() multiple times in pipeline >

[jira] [Closed] (BEAM-5831) Can not use Values.Create() multiple times in pipeline

[ https://issues.apache.org/jira/browse/BEAM-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni closed BEAM-5831. - Resolution: Not A Bug Fix Version/s: 2.7.0 > Can not use Values.Create() multiple

[jira] [Closed] (BEAM-5831) Can not use Values.Create() multiple times in pipeline

[ https://issues.apache.org/jira/browse/BEAM-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni closed BEAM-5831. - Resolution: Fixed My mistake, please ignore.  > Can not use Values.Create() multiple

[jira] [Created] (BEAM-7447) Update Snippet file for new patterns.

Reza ardeshir rokni created BEAM-7447: - Summary: Update Snippet file for new patterns. Key: BEAM-7447 URL: https://issues.apache.org/jira/browse/BEAM-7447 Project: Beam Issue Type:

[jira] [Created] (BEAM-7456) Expand Link next to tables in capability matrix hard to see

Reza ardeshir rokni created BEAM-7456: - Summary: Expand Link next to tables in capability matrix hard to see Key: BEAM-7456 URL: https://issues.apache.org/jira/browse/BEAM-7456 Project: Beam

[jira] [Assigned] (BEAM-7456) Expand Link next to tables in capability matrix hard to see

[ https://issues.apache.org/jira/browse/BEAM-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-7456: - Assignee: Reza ardeshir rokni > Expand Link next to tables in capability matrix

[jira] [Resolved] (BEAM-7456) Expand Link next to tables in capability matrix hard to see

[ https://issues.apache.org/jira/browse/BEAM-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni resolved BEAM-7456. --- Resolution: Fixed Fix Version/s: 2.13.0 PR #8773 > Expand Link next to tables

[jira] [Assigned] (BEAM-7386) Add Utility BiTemporalStreamJoin

[ https://issues.apache.org/jira/browse/BEAM-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-7386: - Assignee: Reza ardeshir rokni > Add Utility BiTemporalStreamJoin >

[jira] [Assigned] (BEAM-7398) Add getTaggedKeyedPCollection to KeyedPCollectionTuple

[ https://issues.apache.org/jira/browse/BEAM-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-7398: - Assignee: Reza ardeshir rokni > Add getTaggedKeyedPCollection to

[jira] [Assigned] (BEAM-7399) Publishing a blog post about looping timers.

[ https://issues.apache.org/jira/browse/BEAM-7399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-7399: - Assignee: Reza ardeshir rokni > Publishing a blog post about looping timers. >

[jira] [Created] (BEAM-7399) Publishing a blog post about looping timers.

Reza ardeshir rokni created BEAM-7399: - Summary: Publishing a blog post about looping timers. Key: BEAM-7399 URL: https://issues.apache.org/jira/browse/BEAM-7399 Project: Beam Issue

[jira] [Created] (BEAM-7155) Provide access to within DoFn.OnTimerContext

Reza ardeshir rokni created BEAM-7155: - Summary: Provide access to within DoFn.OnTimerContext Key: BEAM-7155 URL: https://issues.apache.org/jira/browse/BEAM-7155 Project: Beam Issue

[jira] [Created] (BEAM-8031) Add Snippets for Patterns website

Reza ardeshir rokni created BEAM-8031: - Summary: Add Snippets for Patterns website Key: BEAM-8031 URL: https://issues.apache.org/jira/browse/BEAM-8031 Project: Beam Issue Type:

[jira] [Created] (BEAM-8090) Add test for Self Setting Timers close to GC TImer

Reza ardeshir rokni created BEAM-8090: - Summary: Add test for Self Setting Timers close to GC TImer Key: BEAM-8090 URL: https://issues.apache.org/jira/browse/BEAM-8090 Project: Beam

[jira] [Created] (BEAM-8323) Testing Guideline using deprecated DoFnTester

Reza ardeshir rokni created BEAM-8323: - Summary: Testing Guideline using deprecated DoFnTester Key: BEAM-8323 URL: https://issues.apache.org/jira/browse/BEAM-8323 Project: Beam Issue

[jira] [Created] (BEAM-8604) Remove depricated DoFnTester docs

Reza ardeshir rokni created BEAM-8604: - Summary: Remove depricated DoFnTester docs Key: BEAM-8604 URL: https://issues.apache.org/jira/browse/BEAM-8604 Project: Beam Issue Type: Bug

[jira] [Assigned] (BEAM-8604) Remove depricated DoFnTester docs

[ https://issues.apache.org/jira/browse/BEAM-8604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-8604: - Assignee: Rose Nguyen > Remove depricated DoFnTester docs >

[jira] [Created] (BEAM-8990) Missing required prop from BigQueryIO javadoc

Reza ardeshir rokni created BEAM-8990: - Summary: Missing required prop from BigQueryIO javadoc Key: BEAM-8990 URL: https://issues.apache.org/jira/browse/BEAM-8990 Project: Beam Issue

[jira] [Created] (BEAM-9222) Add distributed read pattern

Reza ardeshir rokni created BEAM-9222: - Summary: Add distributed read pattern Key: BEAM-9222 URL: https://issues.apache.org/jira/browse/BEAM-9222 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-6261) Dataflow runner does not refresh updated side inputs

[ https://issues.apache.org/jira/browse/BEAM-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni resolved BEAM-6261. --- Fix Version/s: 2.9.0 2.15.0 Resolution: Fixed > Dataflow

[jira] [Updated] (BEAM-6261) Dataflow runner does not refresh updated side inputs

[ https://issues.apache.org/jira/browse/BEAM-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-6261: -- Fix Version/s: (was: 2.15.0) > Dataflow runner does not refresh updated side inputs

[jira] [Created] (BEAM-9469) Provide error message access when Pipeline State is failure

Reza ardeshir rokni created BEAM-9469: - Summary: Provide error message access when Pipeline State is failure Key: BEAM-9469 URL: https://issues.apache.org/jira/browse/BEAM-9469 Project: Beam

[jira] [Created] (BEAM-9770) Add BigQuery DeadLetter pattern to Patterns Page

Reza ardeshir rokni created BEAM-9770: - Summary: Add BigQuery DeadLetter pattern to Patterns Page Key: BEAM-9770 URL: https://issues.apache.org/jira/browse/BEAM-9770 Project: Beam Issue

[jira] [Created] (BEAM-10003) Need two PR to submit snippets to website

Reza ardeshir rokni created BEAM-10003: -- Summary: Need two PR to submit snippets to website Key: BEAM-10003 URL: https://issues.apache.org/jira/browse/BEAM-10003 Project: Beam Issue

[jira] [Created] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line.

Reza ardeshir rokni created BEAM-10124: -- Summary: ContextualTextIO - An IO that is provides metadata about the line. Key: BEAM-10124 URL: https://issues.apache.org/jira/browse/BEAM-10124

[jira] [Assigned] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line.

[ https://issues.apache.org/jira/browse/BEAM-10124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni reassigned BEAM-10124: -- Assignee: Reza ardeshir rokni > ContextualTextIO - An IO that is provides

[jira] [Updated] (BEAM-10126) Pattern : Filters using Beam Schemas

[ https://issues.apache.org/jira/browse/BEAM-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10126: --- Description: Pattern : Filters using Beam Schemas   Add a pattern to show

[jira] [Created] (BEAM-10126) Pattern : Filters using Beam Schemas

Reza ardeshir rokni created BEAM-10126: -- Summary: Pattern : Filters using Beam Schemas Key: BEAM-10126 URL: https://issues.apache.org/jira/browse/BEAM-10126 Project: Beam Issue Type:

[jira] [Created] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

Reza ardeshir rokni created BEAM-10127: -- Summary: Patterns: Create a pattern showing how to do HLL++ in streams Key: BEAM-10127 URL: https://issues.apache.org/jira/browse/BEAM-10127 Project:

[jira] [Created] (BEAM-10129) Pattern: Buffered Service Call Pattern

Reza ardeshir rokni created BEAM-10129: -- Summary: Pattern: Buffered Service Call Pattern Key: BEAM-10129 URL: https://issues.apache.org/jira/browse/BEAM-10129 Project: Beam Issue Type:

[jira] [Updated] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

[ https://issues.apache.org/jira/browse/BEAM-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10127: --- Status: Open (was: Triage Needed) > Patterns: Create a pattern showing how to do

[jira] [Updated] (BEAM-10130) Pattern : Limiting the calls to an external service within a DoFn

[ https://issues.apache.org/jira/browse/BEAM-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10130: --- Status: Open (was: Triage Needed) > Pattern : Limiting the calls to an external

[jira] [Updated] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key

[ https://issues.apache.org/jira/browse/BEAM-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10131: --- Status: Open (was: Triage Needed) > Patterns: Show pattern for key redistribution

[jira] [Updated] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

[ https://issues.apache.org/jira/browse/BEAM-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10128: --- Status: Open (was: Triage Needed) > Pattern: Write FixedWindow and output

[jira] [Updated] (BEAM-10129) Pattern: Buffered Service Call Pattern

[ https://issues.apache.org/jira/browse/BEAM-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10129: --- Status: Open (was: Triage Needed) > Pattern: Buffered Service Call Pattern >

[jira] [Created] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

Reza ardeshir rokni created BEAM-10128: -- Summary: Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO Key: BEAM-10128 URL: https://issues.apache.org/jira/browse/BEAM-10128

[jira] [Created] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key

Reza ardeshir rokni created BEAM-10131: -- Summary: Patterns: Show pattern for key redistribution when there is no natural key Key: BEAM-10131 URL: https://issues.apache.org/jira/browse/BEAM-10131

[jira] [Updated] (BEAM-10126) Pattern : Filters using Beam Schemas

[ https://issues.apache.org/jira/browse/BEAM-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10126: --- Status: Open (was: Triage Needed) > Pattern : Filters using Beam Schemas >

[jira] [Updated] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line.

[ https://issues.apache.org/jira/browse/BEAM-10124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10124: --- Status: Open (was: Triage Needed) > ContextualTextIO - An IO that is provides

[jira] [Created] (BEAM-10130) Pattern : Limiting the calls to an external service within a DoFn

Reza ardeshir rokni created BEAM-10130: -- Summary: Pattern : Limiting the calls to an external service within a DoFn Key: BEAM-10130 URL: https://issues.apache.org/jira/browse/BEAM-10130 Project:

[jira] [Updated] (BEAM-10127) Patterns: Create a pattern showing how to do HLL++ in streams

[ https://issues.apache.org/jira/browse/BEAM-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10127: --- Labels: pipeline-patterns (was: ) > Patterns: Create a pattern showing how to do

[jira] [Updated] (BEAM-10128) Pattern: Write FixedWindow and output TF.SequenceExample with TFRecordIO

[ https://issues.apache.org/jira/browse/BEAM-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10128: --- Labels: pipeline-patterns (was: ) > Pattern: Write FixedWindow and output

[jira] [Updated] (BEAM-9770) Add BigQuery DeadLetter pattern to Patterns Page

[ https://issues.apache.org/jira/browse/BEAM-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-9770: -- Labels: pipeline-patterns (was: ) > Add BigQuery DeadLetter pattern to Patterns Page >

[jira] [Commented] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

[ https://issues.apache.org/jira/browse/BEAM-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126261#comment-17126261 ] Reza ardeshir rokni commented on BEAM-10199: FYI [~reuvenlax], > AutoValue Schema unable to

[jira] [Updated] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

[ https://issues.apache.org/jira/browse/BEAM-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10199: --- Status: Open (was: Triage Needed) > AutoValue Schema unable to work with

[jira] [Commented] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

[ https://issues.apache.org/jira/browse/BEAM-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126260#comment-17126260 ] Reza ardeshir rokni commented on BEAM-10199: The GSON autovalue object actually extends a

[jira] [Created] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

Reza ardeshir rokni created BEAM-10199: -- Summary: AutoValue Schema unable to work with auto-value-gson-annotations objects Key: BEAM-10199 URL: https://issues.apache.org/jira/browse/BEAM-10199

[jira] [Updated] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

[ https://issues.apache.org/jira/browse/BEAM-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10199: --- Priority: P3 (was: P2) > AutoValue Schema unable to work with

[jira] [Updated] (BEAM-10199) AutoValue Schema unable to work with auto-value-gson-annotations objects

[ https://issues.apache.org/jira/browse/BEAM-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza ardeshir rokni updated BEAM-10199: --- Issue Type: Bug (was: New Feature) > AutoValue Schema unable to work with

[jira] [Created] (BEAM-10201) Enhance JsonToRow to add Deadletter Support

Reza ardeshir rokni created BEAM-10201: -- Summary: Enhance JsonToRow to add Deadletter Support Key: BEAM-10201 URL: https://issues.apache.org/jira/browse/BEAM-10201 Project: Beam Issue