[jira] [Work logged] (BEAM-7424) Retry HTTP 429 errors from GCS w/ exponential backoff when reading data

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Updated] (BEAM-7657) sdk worker parallelism comments are misleading

[ https://issues.apache.org/jira/browse/BEAM-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7657: -- Description: The SDK worker parallelism arg is set two places, in pipeline options [1] [2]  and the job

[jira] [Created] (BEAM-7657) sdk worker parallelism comments are misleading

Kyle Weaver created BEAM-7657: - Summary: sdk worker parallelism comments are misleading Key: BEAM-7657 URL: https://issues.apache.org/jira/browse/BEAM-7657 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-7656) Add sdk-worker-parallelism arg to flink job server shadow jar

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

[jira] [Created] (BEAM-7656) Add sdk-worker-parallelism arg to flink job server shadow jar

Kyle Weaver created BEAM-7656: - Summary: Add sdk-worker-parallelism arg to flink job server shadow jar Key: BEAM-7656 URL: https://issues.apache.org/jira/browse/BEAM-7656 Project: Beam Issue

[jira] [Work logged] (BEAM-6692) Spark Translator - RESHUFFLE_URN

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

[jira] [Work logged] (BEAM-6692) Spark Translator - RESHUFFLE_URN

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

[jira] [Created] (BEAM-7655) Multiple Instances of Beam Table During Query Planning

Alireza Samadianzakaria created BEAM-7655: - Summary: Multiple Instances of Beam Table During Query Planning Key: BEAM-7655 URL: https://issues.apache.org/jira/browse/BEAM-7655 Project: Beam

[jira] [Work logged] (BEAM-6692) Spark Translator - RESHUFFLE_URN

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

[jira] [Work logged] (BEAM-6692) Spark Translator - RESHUFFLE_URN

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

[jira] [Commented] (BEAM-7589) Kinesis IO.write throws LimitExceededException

[ https://issues.apache.org/jira/browse/BEAM-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875288#comment-16875288 ] Ismaël Mejía commented on BEAM-7589: PR was merged, [~Brachi] you can try with the tomorrow's

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7424) Retry HTTP 429 errors from GCS w/ exponential backoff when reading data

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements

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

[jira] [Work logged] (BEAM-6692) Spark Translator - RESHUFFLE_URN

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

[jira] [Work logged] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Resolved] (BEAM-7326) Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user.

[ https://issues.apache.org/jira/browse/BEAM-7326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev resolved BEAM-7326. --- Resolution: Fixed Assignee: Juta Staes Fix Version/s: Not applicable

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

[ https://issues.apache.org/jira/browse/BEAM-7548?focusedWorklogId=269557=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-269557 ] ASF GitHub Bot logged work on BEAM-7548: 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=269555=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-269555 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7535) Create Jenkins jobs for BQ performance tests

[ https://issues.apache.org/jira/browse/BEAM-7535?focusedWorklogId=269552=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-269552 ] ASF GitHub Bot logged work on BEAM-7535: 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=269554=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-269554 ] ASF GitHub Bot logged work on BEAM-7389: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7326) Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user.

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

[jira] [Updated] (BEAM-7628) Retry createJob requests in Dataflow Runner for retriable errors.

[ https://issues.apache.org/jira/browse/BEAM-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7628: -- Priority: Major (was: Minor) > Retry createJob requests in Dataflow Runner for

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7547) StreamingDataflowWorker can observe inconsistent cache for stale work items

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-6740) Combine.Globally translation is never called

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

[jira] [Work logged] (BEAM-7649) Match Python 3 warning messages in setup.py and __init.py__

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

[jira] [Work logged] (BEAM-7590) Convert PipelineOptionsMap to PipelineOption

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-6675) The JdbcIO sink should accept schemas

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

[jira] [Work logged] (BEAM-7424) Retry HTTP 429 errors from GCS w/ exponential backoff when reading data

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

[jira] [Work logged] (BEAM-7586) Add Integration Test for MongoDbIO in python sdk

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

[jira] [Work logged] (BEAM-7586) Add Integration Test for MongoDbIO in python sdk

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7326) Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user.

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

[jira] [Work logged] (BEAM-7326) Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user.

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

[jira] [Created] (BEAM-7654) Enable skipped tests with ApproximateUnique when hash() is improved.

Hannah Jiang created BEAM-7654: -- Summary: Enable skipped tests with ApproximateUnique when hash() is improved. Key: BEAM-7654 URL: https://issues.apache.org/jira/browse/BEAM-7654 Project: Beam

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7547) StreamingDataflowWorker can observe inconsistent cache for stale work items

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

[jira] [Closed] (BEAM-7643) Nearly all PostCommits failing due to Google Cloud issues

[ https://issues.apache.org/jira/browse/BEAM-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-7643. -- Resolution: Resolved Fix Version/s: Not applicable > Nearly all PostCommits failing due to Google Cloud

[jira] [Commented] (BEAM-7643) Nearly all PostCommits failing due to Google Cloud issues

[ https://issues.apache.org/jira/browse/BEAM-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875083#comment-16875083 ] Mark Liu commented on BEAM-7643: Dataflow service is back to normal and we saw builds are passing on

[jira] [Work logged] (BEAM-3645) Support multi-process execution on the FnApiRunner

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

[jira] [Work logged] (BEAM-3645) Support multi-process execution on the FnApiRunner

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

[jira] [Work logged] (BEAM-7548) test_approximate_unique_global_by_error is flaky

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

[jira] [Work logged] (BEAM-7547) StreamingDataflowWorker can observe inconsistent cache for stale work items

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

[jira] [Work logged] (BEAM-7590) Convert PipelineOptionsMap to PipelineOption

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

[jira] [Work logged] (BEAM-7590) Convert PipelineOptionsMap to PipelineOption

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

[jira] [Work logged] (BEAM-6740) Combine.Globally translation is never called

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

[jira] [Work logged] (BEAM-6740) Combine.Globally translation is never called

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

[jira] [Work logged] (BEAM-6740) Combine.Globally translation is never called

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Updated] (BEAM-7653) Combine.GroupedValues translation is never called

[ https://issues.apache.org/jira/browse/BEAM-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7653: --- Labels: portability (was: ) > Combine.GroupedValues translation is never called >

[jira] [Updated] (BEAM-7653) Combine.GroupedValues translation is never called

[ https://issues.apache.org/jira/browse/BEAM-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7653: --- Description: This issue is similar to BEAM-6740. When a runner overrides the translation of

[jira] [Updated] (BEAM-6740) Combine.Globally translation is never called

[ https://issues.apache.org/jira/browse/BEAM-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6740: --- Summary: Combine.Globally translation is never called (was: Combine.globally translation is never

[jira] [Updated] (BEAM-7653) Combine.GroupedValues translation is never called

[ https://issues.apache.org/jira/browse/BEAM-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7653: --- Summary: Combine.GroupedValues translation is never called (was: Combine.Values translation is never

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Created] (BEAM-7653) Combine.Values translation is never called

Ismaël Mejía created BEAM-7653: -- Summary: Combine.Values translation is never called Key: BEAM-7653 URL: https://issues.apache.org/jira/browse/BEAM-7653 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-7653) Combine.Values translation is never called

[ https://issues.apache.org/jira/browse/BEAM-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7653: --- Status: Open (was: Triage Needed) > Combine.Values translation is never called >

[jira] [Updated] (BEAM-6740) Combine.globally translation is never called

[ https://issues.apache.org/jira/browse/BEAM-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-6740: --- Labels: portability (was: ) > Combine.globally translation is never called >

[jira] [Assigned] (BEAM-7637) Migrate S3FileSystem to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-7637: -- Assignee: Ismaël Mejía > Migrate S3FileSystem to AWS SDK for Java 2 >

[jira] [Created] (BEAM-7652) Allow to parametrize the ClientConfiguration and ApacheHttpClient for AWS operations

Ismaël Mejía created BEAM-7652: -- Summary: Allow to parametrize the ClientConfiguration and ApacheHttpClient for AWS operations Key: BEAM-7652 URL: https://issues.apache.org/jira/browse/BEAM-7652

[jira] [Updated] (BEAM-7652) Allow to parametrize the ClientConfiguration and ApacheHttpClient for AWS operations

[ https://issues.apache.org/jira/browse/BEAM-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7652: --- Status: Open (was: Triage Needed) > Allow to parametrize the ClientConfiguration and

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7640) Create amazon-web-services2 module and AwsOptions

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

[jira] [Work logged] (BEAM-7414) RabbitMqMessage can't be serialized due to LongString in headers

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

[jira] [Work logged] (BEAM-7414) RabbitMqMessage can't be serialized due to LongString in headers

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

[jira] [Work logged] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming

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

[jira] [Work logged] (BEAM-7437) Integration Test for BQ streaming inserts for streaming pipelines

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

[jira] [Work logged] (BEAM-7414) RabbitMqMessage can't be serialized due to LongString in headers

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

[jira] [Work logged] (BEAM-6675) The JdbcIO sink should accept schemas

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

[jira] [Work logged] (BEAM-7589) Kinesis IO.write throws LimitExceededException

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

  1   2   >