[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305549=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305549 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305493=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305493 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305511=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305511 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305510=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305510 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305512=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305512 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305517=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305517 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305520=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305520 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7980) External environment with containerized worker pool

[ https://issues.apache.org/jira/browse/BEAM-7980?focusedWorklogId=305487=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305487 ] ASF GitHub Bot logged work on BEAM-7980: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305495=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305495 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305496=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305496 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921342#comment-16921342 ] TJ commented on BEAM-8121: -- I've added cleaned code. I needed to remove ± all business logic, to meet companies

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

[ https://issues.apache.org/jira/browse/BEAM-5428?focusedWorklogId=305546=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305546 ] ASF GitHub Bot logged work on BEAM-5428: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8131) Provide Kubernetes setup with Prometheus

Kamil Wasilewski created BEAM-8131: -- Summary: Provide Kubernetes setup with Prometheus Key: BEAM-8131 URL: https://issues.apache.org/jira/browse/BEAM-8131 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305513=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305513 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8133) Create metrics publisher in Java SDK

Kamil Wasilewski created BEAM-8133: -- Summary: Create metrics publisher in Java SDK Key: BEAM-8133 URL: https://issues.apache.org/jira/browse/BEAM-8133 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-8132) Create metrics publisher in Python SDK

Kamil Wasilewski created BEAM-8132: -- Summary: Create metrics publisher in Python SDK Key: BEAM-8132 URL: https://issues.apache.org/jira/browse/BEAM-8132 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305486=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305486 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305483=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305483 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305485=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305485 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305484=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305484 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-7355) CassandraIOTest failing in presubmit

[ https://issues.apache.org/jira/browse/BEAM-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-7355: -- Assignee: Jean-Baptiste Onofré > CassandraIOTest failing in presubmit >

[jira] [Updated] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8129: --- Status: Open (was: Triage Needed) > Update Spark runner to use spark version 2.4.4 >

[jira] [Updated] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8129: --- Fix Version/s: 2.16.0 > Update Spark runner to use spark version 2.4.4 >

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305489=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305489 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305490=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305490 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-8129. Resolution: Fixed > Update Spark runner to use spark version 2.4.4 >

[jira] [Work logged] (BEAM-7274) Protobuf Beam Schema support

[ https://issues.apache.org/jira/browse/BEAM-7274?focusedWorklogId=305542=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305542 ] ASF GitHub Bot logged work on BEAM-7274: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305491=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305491 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TJ updated BEAM-8121: - Attachment: datalake-dataflow-cleaned.zip > Messages are not distributed per machines when consuming from Kafka topic >

[jira] [Created] (BEAM-8130) Storing, displaying and detecting anomalies in test results using Prometheus and Grafana

Kamil Wasilewski created BEAM-8130: -- Summary: Storing, displaying and detecting anomalies in test results using Prometheus and Grafana Key: BEAM-8130 URL: https://issues.apache.org/jira/browse/BEAM-8130

[jira] [Updated] (BEAM-8130) Storing, displaying and detecting anomalies in test results

[ https://issues.apache.org/jira/browse/BEAM-8130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8130: --- Summary: Storing, displaying and detecting anomalies in test results (was: Storing,

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305463=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305463 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305437=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305437 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8129) Update Spark runner to use spark version 2.4.4

Ismaël Mejía created BEAM-8129: -- Summary: Update Spark runner to use spark version 2.4.4 Key: BEAM-8129 URL: https://issues.apache.org/jira/browse/BEAM-8129 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305458=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305458 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305459=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305459 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

[ https://issues.apache.org/jira/browse/BEAM-8114?focusedWorklogId=305426=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305426 ] ASF GitHub Bot logged work on BEAM-8114: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305439=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305439 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8129) Update Spark runner to use spark version 2.4.4

[ https://issues.apache.org/jira/browse/BEAM-8129?focusedWorklogId=305438=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305438 ] ASF GitHub Bot logged work on BEAM-8129: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-8136) Configure alert notification channels

[ https://issues.apache.org/jira/browse/BEAM-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8136: --- Status: Open (was: Triage Needed) > Configure alert notification channels >

[jira] [Created] (BEAM-8136) Configure alert notification channels

Kamil Wasilewski created BEAM-8136: -- Summary: Configure alert notification channels Key: BEAM-8136 URL: https://issues.apache.org/jira/browse/BEAM-8136 Project: Beam Issue Type: Sub-task

[jira] [Updated] (BEAM-8134) Provide Grafana dashboards for all existing tests

[ https://issues.apache.org/jira/browse/BEAM-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8134: --- Description: Dashboards should be exported to .json files and added to the Beam git

[jira] [Updated] (BEAM-8134) Provide Grafana dashboards for all existing tests

[ https://issues.apache.org/jira/browse/BEAM-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8134: --- Description: Dashboards should be exported to .json files and added to the Beam git

[jira] [Created] (BEAM-8134) Provide Grafana dashboards for all existing tests

Kamil Wasilewski created BEAM-8134: -- Summary: Provide Grafana dashboards for all existing tests Key: BEAM-8134 URL: https://issues.apache.org/jira/browse/BEAM-8134 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305610=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305610 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305611=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305611 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-8133) Create metrics publisher in Java SDK

[ https://issues.apache.org/jira/browse/BEAM-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8133: --- Status: Open (was: Triage Needed) > Create metrics publisher in Java SDK >

[jira] [Updated] (BEAM-8130) Storing, displaying and detecting anomalies in test results

[ https://issues.apache.org/jira/browse/BEAM-8130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8130: --- Status: Open (was: Triage Needed) > Storing, displaying and detecting anomalies in test

[jira] [Updated] (BEAM-8132) Create metrics publisher in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8132: --- Status: Open (was: Triage Needed) > Create metrics publisher in Python SDK >

[jira] [Updated] (BEAM-8135) Remove obsolete BigQuery publishers

[ https://issues.apache.org/jira/browse/BEAM-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8135: --- Status: Open (was: Triage Needed) > Remove obsolete BigQuery publishers >

[jira] [Updated] (BEAM-8131) Provide Kubernetes setup with Prometheus

[ https://issues.apache.org/jira/browse/BEAM-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8131: --- Status: Open (was: Triage Needed) > Provide Kubernetes setup with Prometheus >

[jira] [Work started] (BEAM-8131) Provide Kubernetes setup with Prometheus

[ https://issues.apache.org/jira/browse/BEAM-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-8131 started by Kamil Wasilewski. -- > Provide Kubernetes setup with Prometheus >

[jira] [Updated] (BEAM-8134) Provide Grafana dashboards for all existing tests

[ https://issues.apache.org/jira/browse/BEAM-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8134: --- Status: Open (was: Triage Needed) > Provide Grafana dashboards for all existing tests >

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

[ https://issues.apache.org/jira/browse/BEAM-5428?focusedWorklogId=305597=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305597 ] ASF GitHub Bot logged work on BEAM-5428: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921443#comment-16921443 ] Alexey Romanenko commented on BEAM-8121: Thank you for adding the files, I don't see something

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305609=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305609 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-8134) Provide Grafana dashboards for all existing tests

[ https://issues.apache.org/jira/browse/BEAM-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski reassigned BEAM-8134: -- Assignee: (was: Kamil Wasilewski) > Provide Grafana dashboards for all existing

[jira] [Assigned] (BEAM-8133) Create metrics publisher in Java SDK

[ https://issues.apache.org/jira/browse/BEAM-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski reassigned BEAM-8133: -- Assignee: (was: Kamil Wasilewski) > Create metrics publisher in Java SDK >

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305608=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305608 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

[ https://issues.apache.org/jira/browse/BEAM-8113?focusedWorklogId=305607=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305607 ] ASF GitHub Bot logged work on BEAM-8113: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8135) Remove obsolete BigQuery publishers

Kamil Wasilewski created BEAM-8135: -- Summary: Remove obsolete BigQuery publishers Key: BEAM-8135 URL: https://issues.apache.org/jira/browse/BEAM-8135 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-7945) Allow runner to configure "semi_persist_dir" which is used in the SDK harness

[ https://issues.apache.org/jira/browse/BEAM-7945?focusedWorklogId=305641=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305641 ] ASF GitHub Bot logged work on BEAM-7945: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-8111) SchemaCoder broken on DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Hulette resolved BEAM-8111. - Fix Version/s: 2.16.0 Resolution: Fixed > SchemaCoder broken on DataflowRunner >

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

[ https://issues.apache.org/jira/browse/BEAM-8114?focusedWorklogId=305673=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305673 ] ASF GitHub Bot logged work on BEAM-8114: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921535#comment-16921535 ] sridhar Reddy commented on BEAM-7049: - Hope you had a nice vacation! I will be on vacation myself from

[jira] [Assigned] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang reassigned BEAM-7049: -- Assignee: sridhar Reddy > Merge multiple input to one BeamUnionRel >

[jira] [Assigned] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang reassigned BEAM-7049: -- Assignee: Rui Wang (was: sridhar Reddy) > Merge multiple input to one BeamUnionRel >

[jira] [Assigned] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang reassigned BEAM-7049: -- Assignee: (was: Rui Wang) > Merge multiple input to one BeamUnionRel >

[jira] [Work logged] (BEAM-6114) SQL join selection should be done in planner, not in expansion to PTransform

[ https://issues.apache.org/jira/browse/BEAM-6114?focusedWorklogId=305667=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305667 ] ASF GitHub Bot logged work on BEAM-6114: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?focusedWorklogId=305675=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305675 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?focusedWorklogId=305674=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305674 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7389?focusedWorklogId=305682=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305682 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8137) Worker pool option for Java SDK container

Thomas Weise created BEAM-8137: -- Summary: Worker pool option for Java SDK container Key: BEAM-8137 URL: https://issues.apache.org/jira/browse/BEAM-8137 Project: Beam Issue Type: Improvement

[jira] [Comment Edited] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921535#comment-16921535 ] sridhar Reddy edited comment on BEAM-7049 at 9/3/19 4:21 PM: - Hope you had a

[jira] [Work logged] (BEAM-7995) IllegalStateException: TimestampCombiner moved element from to earlier time in Python

[ https://issues.apache.org/jira/browse/BEAM-7995?focusedWorklogId=305659=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305659 ] ASF GitHub Bot logged work on BEAM-7995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7995) IllegalStateException: TimestampCombiner moved element from to earlier time in Python

[ https://issues.apache.org/jira/browse/BEAM-7995?focusedWorklogId=305658=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305658 ] ASF GitHub Bot logged work on BEAM-7995: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7980) External environment with containerized worker pool

[ https://issues.apache.org/jira/browse/BEAM-7980?focusedWorklogId=305666=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305666 ] ASF GitHub Bot logged work on BEAM-7980: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6114) SQL join selection should be done in planner, not in expansion to PTransform

[ https://issues.apache.org/jira/browse/BEAM-6114?focusedWorklogId=305662=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305662 ] ASF GitHub Bot logged work on BEAM-6114: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7049) Merge multiple input to one BeamUnionRel

[ https://issues.apache.org/jira/browse/BEAM-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921523#comment-16921523 ] Rui Wang commented on BEAM-7049: Hello, I was on a vocation and I am catching up pending emails, etc. Will

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?focusedWorklogId=305677=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305677 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?focusedWorklogId=305676=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305676 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921555#comment-16921555 ] Raghu Angadi commented on BEAM-8121: Thanks for filing this [~TauJan].  {quote}With single machine it

[jira] [Work logged] (BEAM-7616) urlopen calls could get stuck without a timeout

[ https://issues.apache.org/jira/browse/BEAM-7616?focusedWorklogId=305725=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305725 ] ASF GitHub Bot logged work on BEAM-7616: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7455) Improve Avro IO integration test coverage on Python 3.

[ https://issues.apache.org/jira/browse/BEAM-7455?focusedWorklogId=305736=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305736 ] ASF GitHub Bot logged work on BEAM-7455: Author: ASF GitHub Bot

[jira] [Created] (BEAM-8139) Execute portable Spark application jar

Kyle Weaver created BEAM-8139: - Summary: Execute portable Spark application jar Key: BEAM-8139 URL: https://issues.apache.org/jira/browse/BEAM-8139 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-7993) portable python precommit is flaky

[ https://issues.apache.org/jira/browse/BEAM-7993?focusedWorklogId=305798=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305798 ] ASF GitHub Bot logged work on BEAM-7993: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7909) Write integration tests to test customized containers

[ https://issues.apache.org/jira/browse/BEAM-7909?focusedWorklogId=305815=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305815 ] ASF GitHub Bot logged work on BEAM-7909: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7909) Write integration tests to test customized containers

[ https://issues.apache.org/jira/browse/BEAM-7909?focusedWorklogId=305828=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305828 ] ASF GitHub Bot logged work on BEAM-7909: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7389?focusedWorklogId=305830=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305830 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7389?focusedWorklogId=305831=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305831 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8097) Update the release guide

[ https://issues.apache.org/jira/browse/BEAM-8097?focusedWorklogId=305851=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305851 ] ASF GitHub Bot logged work on BEAM-8097: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8097) Update the release guide

[ https://issues.apache.org/jira/browse/BEAM-8097?focusedWorklogId=305741=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305741 ] ASF GitHub Bot logged work on BEAM-8097: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

[ https://issues.apache.org/jira/browse/BEAM-7389?focusedWorklogId=305789=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305789 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7966) Write portable Beam application jar

[ https://issues.apache.org/jira/browse/BEAM-7966?focusedWorklogId=305793=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305793 ] ASF GitHub Bot logged work on BEAM-7966: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7993) portable python precommit is flaky

[ https://issues.apache.org/jira/browse/BEAM-7993?focusedWorklogId=305814=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305814 ] ASF GitHub Bot logged work on BEAM-7993: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7993) portable python precommit is flaky

[ https://issues.apache.org/jira/browse/BEAM-7993?focusedWorklogId=305854=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305854 ] ASF GitHub Bot logged work on BEAM-7993: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

[ https://issues.apache.org/jira/browse/BEAM-5878?focusedWorklogId=305714=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305714 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

[jira] [Comment Edited] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921555#comment-16921555 ] Raghu Angadi edited comment on BEAM-8121 at 9/3/19 5:41 PM: Thanks for filing

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable IO connector for Python

[ https://issues.apache.org/jira/browse/BEAM-3342?focusedWorklogId=305785=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-305785 ] ASF GitHub Bot logged work on BEAM-3342: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-8106) Support Java 11 container

[ https://issues.apache.org/jira/browse/BEAM-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hannah Jiang reassigned BEAM-8106: -- Assignee: (was: Hannah Jiang) > Support Java 11 container > - > >

  1   2   >