[jira] [Commented] (BEAM-9147) [Java] PTransform that integrates Video Intelligence functionality

[ https://issues.apache.org/jira/browse/BEAM-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074910#comment-17074910 ] Masud Hasan commented on BEAM-9147: --- * As I understand this, streaming version of VI cli

[jira] [Work logged] (BEAM-9640) Track PCollection watermark across bundle executions

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

[jira] [Work logged] (BEAM-8910) Use AVRO instead of JSON in BigQuery bounded source.

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

[jira] [Work logged] (BEAM-8910) Use AVRO instead of JSON in BigQuery bounded source.

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

[jira] [Updated] (BEAM-9691) Ensure Dataflow BQ Native sink are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-9691: Status: Open (was: Triage Needed) > Ensure Dataflow BQ Native sink are not used on FnApi >

[jira] [Commented] (BEAM-9691) Ensure Dataflow BQ Native sink are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074895#comment-17074895 ] Pablo Estrada commented on BEAM-9691: - Ah, in fact this is for native sink, not source

[jira] [Updated] (BEAM-9691) Ensure Dataflow BQ Native sink are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-9691: Summary: Ensure Dataflow BQ Native sink are not used on FnApi (was: Ensure Dataflow BQ Native sourc

[jira] [Work logged] (BEAM-9691) Ensure Dataflow BQ Native sources are not used on FnApi

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

[jira] [Commented] (BEAM-9691) Ensure Dataflow BQ Native sources are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074892#comment-17074892 ] Pablo Estrada commented on BEAM-9691: - I think the title of the issue is too wide. Sor

[jira] [Updated] (BEAM-9691) Ensure Dataflow BQ Native sources are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-9691: Summary: Ensure Dataflow BQ Native sources are not used on FnApi (was: Ensure Dataflow Native sourc

[jira] [Updated] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-9691: Summary: Ensure Dataflow Native sources are not used on FnApi (was: Ensure Dataflow Native sources

[jira] [Commented] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

[ https://issues.apache.org/jira/browse/BEAM-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074887#comment-17074887 ] Robert Bradshaw commented on BEAM-9691: --- Is there a pointer to why? Also, was the pr

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Created] (BEAM-9692) Clean Python DataflowRunner to use portable pipelines

Sam Rohde created BEAM-9692: --- Summary: Clean Python DataflowRunner to use portable pipelines Key: BEAM-9692 URL: https://issues.apache.org/jira/browse/BEAM-9692 Project: Beam Issue Type: Improvemen

[jira] [Resolved] (BEAM-9601) Interactive test_streaming_wordcount failing

[ https://issues.apache.org/jira/browse/BEAM-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde resolved BEAM-9601. - Fix Version/s: 2.20.0 Resolution: Fixed > Interactive test_streaming_wordcount failing > --

[jira] [Resolved] (BEAM-9548) Bad error handling with errors from TestStreamService when using Interactive Beam

[ https://issues.apache.org/jira/browse/BEAM-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde resolved BEAM-9548. - Fix Version/s: 2.20.0 Resolution: Fixed > Bad error handling with errors from TestStreamService whe

[jira] [Resolved] (BEAM-8335) Add streaming support to Interactive Beam

[ https://issues.apache.org/jira/browse/BEAM-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde resolved BEAM-8335. - Fix Version/s: 2.20.0 Resolution: Fixed > Add streaming support to Interactive Beam > -

[jira] [Resolved] (BEAM-9013) Multi-output TestStream breaks the DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Rohde resolved BEAM-9013. - Fix Version/s: 2.18.0 Resolution: Fixed > Multi-output TestStream breaks the DataflowRunner > -

[jira] [Work logged] (BEAM-9688) subprocess_server_test.py fails on Windows platform

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

[jira] [Work logged] (BEAM-9687) Names of temporary files created by interactive runner include characters invalid on some platforms.

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

[jira] [Work logged] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

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

[jira] [Work logged] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

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

[jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

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

[jira] [Work logged] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

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

[jira] [Created] (BEAM-9691) Ensure Dataflow Native sources are not used on FnApi ever

Pablo Estrada created BEAM-9691: --- Summary: Ensure Dataflow Native sources are not used on FnApi ever Key: BEAM-9691 URL: https://issues.apache.org/jira/browse/BEAM-9691 Project: Beam Issue Type

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work started] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

[ https://issues.apache.org/jira/browse/BEAM-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9685 started by Hannah Jiang. -- > Don't release Go SDK container until Go is officially supported. >

[jira] [Updated] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

[ https://issues.apache.org/jira/browse/BEAM-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hannah Jiang updated BEAM-9685: --- Status: Open (was: Triage Needed) > Don't release Go SDK container until Go is officially supported.

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work logged] (BEAM-9685) Don't release Go SDK container until Go is officially supported.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Commented] (BEAM-9313) beam_PostRelease_NightlySnapshot failure due to ClassNotFoundException: org.apache.beam.model.pipeline.v1.StandardWindowFns$SessionsPayload$Enum

[ https://issues.apache.org/jira/browse/BEAM-9313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074840#comment-17074840 ] Udi Meiri commented on BEAM-9313: - Or perhaps Gradle is prematurely cleaning up the tmpdir

[jira] [Work logged] (BEAM-9136) Add LICENSES and NOTICES to docker images

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

[jira] [Commented] (BEAM-9313) beam_PostRelease_NightlySnapshot failure due to ClassNotFoundException: org.apache.beam.model.pipeline.v1.StandardWindowFns$SessionsPayload$Enum

[ https://issues.apache.org/jira/browse/BEAM-9313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074832#comment-17074832 ] Udi Meiri commented on BEAM-9313: - Seeing something similar: {code} [INFO] Changes detecte

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9199) Make --region a required flag for DataflowRunner

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

[jira] [Commented] (BEAM-8409) docker-credential-gcloud not installed or not available in PATH

[ https://issues.apache.org/jira/browse/BEAM-8409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074818#comment-17074818 ] Udi Meiri commented on BEAM-8409: - This is now happening on multiple machines (7, 8, 11, 1

[jira] [Work logged] (BEAM-9688) subprocess_server_test.py fails on Windows platform

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

[jira] [Work logged] (BEAM-9640) Track PCollection watermark across bundle executions

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Created] (BEAM-9690) Go build failing: undefined: primitives.Reshuffle(KV)

Kyle Weaver created BEAM-9690: - Summary: Go build failing: undefined: primitives.Reshuffle(KV) Key: BEAM-9690 URL: https://issues.apache.org/jira/browse/BEAM-9690 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-9687) Names of temporary files created by interactive runner include characters invalid on some platforms.

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

[jira] [Work logged] (BEAM-9687) Names of temporary files created by interactive runner include characters invalid on some platforms.

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

[jira] [Work logged] (BEAM-9545) MVP: DataframeTransform

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

[jira] [Work logged] (BEAM-9545) MVP: DataframeTransform

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

[jira] [Work logged] (BEAM-9545) MVP: DataframeTransform

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

[jira] [Work logged] (BEAM-9545) MVP: DataframeTransform

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

[jira] [Work logged] (BEAM-9545) MVP: DataframeTransform

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

[jira] [Work logged] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware.

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

[jira] [Work logged] (BEAM-9607) _SDFBoundedSourceWrapper should expose the same display_data as Read

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

[jira] [Work logged] (BEAM-9607) _SDFBoundedSourceWrapper should expose the same display_data as Read

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

[jira] [Work logged] (BEAM-6768) Support for data-dependent destination for BQ streaming inserts in Python

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

[jira] [Work logged] (BEAM-8542) Add async write to AWS SNS IO & remove retry logic

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

[jira] [Work logged] (BEAM-9562) Remove timer from PCollection and treat timers as Elements

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

[jira] [Work logged] (BEAM-9562) Remove timer from PCollection and treat timers as Elements

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

[jira] [Resolved] (BEAM-9686) SparkCommonPipelineOptions should not depend of a child class to resolve the tmp checkpoint dir

[ https://issues.apache.org/jira/browse/BEAM-9686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-9686. Fix Version/s: 2.21.0 Resolution: Fixed > SparkCommonPipelineOptions should not depen

[jira] [Work logged] (BEAM-9686) SparkCommonPipelineOptions should not depend of a child class to resolve the tmp checkpoint dir

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

[jira] [Commented] (BEAM-9423) Re-Add the stop button to the Flink web interface for pipelines

[ https://issues.apache.org/jira/browse/BEAM-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074678#comment-17074678 ] Maximilian Michels commented on BEAM-9423: -- If you don't make structural changes

[jira] [Work logged] (BEAM-9660) StreamingDataflowWorker has confusing exception on commits over 2GB

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

[jira] [Work logged] (BEAM-9562) Remove timer from PCollection and treat timers as Elements

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

[jira] [Work logged] (BEAM-8191) Multiple Flatten.pCollections() transforms generate an overwhelming number of tasks

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

[jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods

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

[jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods

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

[jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods

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

[jira] [Assigned] (BEAM-9645) Python flinkrunner cannot inspect container

[ https://issues.apache.org/jira/browse/BEAM-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-9645: Assignee: Maximilian Michels > Python flinkrunner cannot inspect container > --

[jira] [Commented] (BEAM-9645) Python flinkrunner cannot inspect container

[ https://issues.apache.org/jira/browse/BEAM-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074672#comment-17074672 ] Maximilian Michels commented on BEAM-9645: -- Thanks for reporting. This is indeed

[jira] [Work logged] (BEAM-8201) clean up the current container API

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

[jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074641#comment-17074641 ] Maximilian Michels commented on BEAM-8944: -- Thank you for your thoughts Luke. I a

[jira] [Created] (BEAM-9689) Update wordcount webpage with Spark/Flink + Go

Kyle Weaver created BEAM-9689: - Summary: Update wordcount webpage with Spark/Flink + Go Key: BEAM-9689 URL: https://issues.apache.org/jira/browse/BEAM-9689 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-9550) beam_PostCommit_Python_Chicago_Taxi_Flink OOM

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

[jira] [Work logged] (BEAM-9550) beam_PostCommit_Python_Chicago_Taxi_Flink OOM

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

[jira] [Work logged] (BEAM-8206) Fix syntax errors in Java doc for PipelineRunner

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

[jira] [Work logged] (BEAM-9686) SparkCommonPipelineOptions should not depend of a child class to resolve the tmp checkpoint dir

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

[jira] [Work logged] (BEAM-9686) SparkCommonPipelineOptions should not depend of a child class to resolve the tmp checkpoint dir

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

[jira] [Work logged] (BEAM-9199) Make --region a required flag for DataflowRunner

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

[jira] [Resolved] (BEAM-8015) Get logs for SDK worker Docker containers

[ https://issues.apache.org/jira/browse/BEAM-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8015. --- Fix Version/s: 2.21.0 Resolution: Fixed > Get logs for SDK worker Docker containers > -

[jira] [Resolved] (BEAM-9645) Python flinkrunner cannot inspect container

[ https://issues.apache.org/jira/browse/BEAM-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-9645. --- Fix Version/s: 2.21.0 Resolution: Fixed > Python flinkrunner cannot inspect container > ---

[jira] [Work logged] (BEAM-8201) clean up the current container API

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

[jira] [Work logged] (BEAM-9645) Python flinkrunner cannot inspect container

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

[jira] [Work logged] (BEAM-9645) Python flinkrunner cannot inspect container

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

[jira] [Closed] (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 ] Alexey Romanenko closed BEAM-8121. -- Fix Version/s: Not applicable Resolution: Not A Problem I close it since the problem was

[jira] [Assigned] (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 ] Alexey Romanenko reassigned BEAM-8121: -- Assignee: Alexey Romanenko > Messages are not distributed per machines when consuming f

[jira] [Work logged] (BEAM-7505) Create SideInput Python Load Test Jenkins Job

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

[jira] [Resolved] (BEAM-9604) BIP-1: Remove schema metadata usage for Protobuf extension

[ https://issues.apache.org/jira/browse/BEAM-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Van Boxel resolved BEAM-9604. -- Fix Version/s: 2.21.0 Resolution: Fixed This was part of https://github.com/apache/beam/p

[jira] [Closed] (BEAM-9605) BIP-1: Rename setRowOption to setOption on Option builder

[ https://issues.apache.org/jira/browse/BEAM-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Van Boxel closed BEAM-9605. > BIP-1: Rename setRowOption to setOption on Option builder > -

[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&focusedCommentId=17074532#comment-17074532 ] TJ commented on BEAM-8121: -- [~aromanenko] sorry for late response. Yes issue can be closed. > Me

[jira] [Closed] (BEAM-9604) BIP-1: Remove schema metadata usage for Protobuf extension

[ https://issues.apache.org/jira/browse/BEAM-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Van Boxel closed BEAM-9604. > BIP-1: Remove schema metadata usage for Protobuf extension > -

<    1   2   3   >