[jira] [Work logged] (BEAM-12824) Beam Connector for Reading Data from Delta Lake

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

[jira] [Work logged] (BEAM-12795) KVs should not be needed when using schemas

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12869) Upgrade tensorflow to 2.6.x

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12802) Implement readLater prefetch support in Java SDK harness

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

[jira] [Work logged] (BEAM-12802) Implement readLater prefetch support in Java SDK harness

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12869) Upgrade tensorflow to 2.6.x

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Updated] (BEAM-12846) In transform catalog overview page, GroupBy transform row is missing

[ https://issues.apache.org/jira/browse/BEAM-12846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Winson Tanputraman updated BEAM-12846: -- Resolution: Fixed Status: Resolved (was: Triage Needed) Resolved in [GitHub Pu

[jira] [Assigned] (BEAM-12846) In transform catalog overview page, GroupBy transform row is missing

[ https://issues.apache.org/jira/browse/BEAM-12846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Winson Tanputraman reassigned BEAM-12846: - Assignee: Winson Tanputraman > In transform catalog overview page, GroupBy trans

[jira] [Work logged] (BEAM-12869) Upgrade tensorflow to 2.6.x

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-5097) Increment counter for "small words" in go SDK example

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

[jira] [Work logged] (BEAM-11097) [Go SDK] Windowed Side Input Caching (Cross Bundle)

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

[jira] [Commented] (BEAM-12805) Multiple XVR suites failing due to Java test ValidateRunnerXlangTest.combinePerKeyTest

[ https://issues.apache.org/jira/browse/BEAM-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412887#comment-17412887 ] Udi Meiri commented on BEAM-12805: -- Thank you for the workaround (https://github.com/apa

[jira] [Work logged] (BEAM-11985) Python Bigtable - Implement IO Request Count metrics

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

[jira] [Updated] (BEAM-12870) Upgrade protobuf version

[ https://issues.apache.org/jira/browse/BEAM-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12870: - Fix Version/s: 2.34.0 > Upgrade protobuf version > > > Key: BEAM

[jira] [Updated] (BEAM-12869) Upgrade tensorflow to 2.6.x

[ https://issues.apache.org/jira/browse/BEAM-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12869: - Status: Open (was: Triage Needed) > Upgrade tensorflow to 2.6.x > --- > >

[jira] [Updated] (BEAM-12870) Upgrade protobuf version

[ https://issues.apache.org/jira/browse/BEAM-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12870: - Status: Open (was: Triage Needed) > Upgrade protobuf version > > >

[jira] [Created] (BEAM-12870) Upgrade protobuf version

Udi Meiri created BEAM-12870: Summary: Upgrade protobuf version Key: BEAM-12870 URL: https://issues.apache.org/jira/browse/BEAM-12870 Project: Beam Issue Type: Bug Components: dependenc

[jira] [Updated] (BEAM-12870) Upgrade protobuf version

[ https://issues.apache.org/jira/browse/BEAM-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12870: - Description: Version is set here: https://github.com/apache/beam/blob/master/sdks/python/container/base_

[jira] [Updated] (BEAM-12869) Upgrade tensorflow to 2.6.x

[ https://issues.apache.org/jira/browse/BEAM-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12869: - Component/s: dependencies > Upgrade tensorflow to 2.6.x > --- > >

[jira] [Updated] (BEAM-12869) Upgrade tensorflow to 2.6.x

[ https://issues.apache.org/jira/browse/BEAM-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12869: - Description: Version is set here: https://github.com/apache/beam/blob/master/sdks/python/container/base_i

[jira] [Created] (BEAM-12869) Upgrade tensorflow to 2.6.x

Udi Meiri created BEAM-12869: Summary: Upgrade tensorflow to 2.6.x Key: BEAM-12869 URL: https://issues.apache.org/jira/browse/BEAM-12869 Project: Beam Issue Type: Bug Components: sdk-py

[jira] [Work logged] (BEAM-12855) Infer result type when the composite type has Any

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

[jira] [Work logged] (BEAM-12798) Configurable combiner packing limit

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

[jira] [Work logged] (BEAM-11928) Go SDK should use the combine_globally urn for global combines.

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

[jira] [Work logged] (BEAM-12662) AttributeError: 'FlinkUberJarJobServer' object has no attribute '_flink_version'

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

[jira] [Commented] (BEAM-12842) StreamingDataflowWorkerTest.testHotKeyLogging tests are flaky

[ https://issues.apache.org/jira/browse/BEAM-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412883#comment-17412883 ] Ahmet Altay commented on BEAM-12842: Is the other test (testBasic) also flaky? /cc [

[jira] [Work logged] (BEAM-3304) Go triggering support

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

[jira] [Work logged] (BEAM-12000) Support Python 3.9 in Apache Beam

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

[jira] [Work logged] (BEAM-11956) 504 Deadline Exceeded code for very large datasets in Python

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

[jira] [Work logged] (BEAM-11956) 504 Deadline Exceeded code for very large datasets in Python

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

[jira] [Work logged] (BEAM-12832) Add Go SDK to "Using Cross-language Transforms" in programming guide

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

[jira] [Work logged] (BEAM-12832) Add Go SDK to "Using Cross-language Transforms" in programming guide

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

[jira] [Work logged] (BEAM-12845) Spark JobServer should bundle AWS IO libraries to support staging on S3

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

[jira] [Work logged] (BEAM-12824) Beam Connector for Reading Data from Delta Lake

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

[jira] [Work logged] (BEAM-12845) Spark JobServer should bundle AWS IO libraries to support staging on S3

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

[jira] [Work logged] (BEAM-11217) Implement metrics filtering

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

[jira] [Work logged] (BEAM-12846) In transform catalog overview page, GroupBy transform row is missing

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

[jira] [Work logged] (BEAM-12846) In transform catalog overview page, GroupBy transform row is missing

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

[jira] [Work logged] (BEAM-12634) JmsIO autoscaling ability

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

[jira] [Work logged] (BEAM-11217) Implement metrics filtering

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

[jira] [Work logged] (BEAM-12865) Allow customising batch duration when streaming with WriteToBigQuery

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

[jira] [Work logged] (BEAM-12865) Allow customising batch duration when streaming with WriteToBigQuery

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

[jira] [Updated] (BEAM-12868) Insert into Table resulting in unable to serialize DoFnWithExecutionInformation

[ https://issues.apache.org/jira/browse/BEAM-12868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Murthy Antyakula updated BEAM-12868: Description: //No issues was able to read the file successfully PCollection revisionPColle

[jira] [Updated] (BEAM-12868) Insert into Table resulting in unable to serialize DoFnWithExecutionInformation

[ https://issues.apache.org/jira/browse/BEAM-12868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Murthy Antyakula updated BEAM-12868: Description: //No issues was able to read the file successfully PCollection revisionPColle

[jira] [Created] (BEAM-12868) Insert into Table resulting in unable to serialize DoFnWithExecutionInformation

Murthy Antyakula created BEAM-12868: --- Summary: Insert into Table resulting in unable to serialize DoFnWithExecutionInformation Key: BEAM-12868 URL: https://issues.apache.org/jira/browse/BEAM-12868 P

[jira] [Work logged] (BEAM-12802) Implement readLater prefetch support in Java SDK harness

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-8376) Add FirestoreIO connector to Java SDK

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

[jira] [Work logged] (BEAM-8376) Add FirestoreIO connector to Java SDK

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

[jira] [Work logged] (BEAM-3304) Go triggering support

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

[jira] [Commented] (BEAM-1438) The default behavior for the Write transform doesn't work well with the Dataflow streaming runner

[ https://issues.apache.org/jira/browse/BEAM-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412862#comment-17412862 ] Kevin commented on BEAM-1438: - Hello, is there any updates on this bug? We have a project whic

[jira] [Work logged] (BEAM-9008) Add readAll() method to CassandraIO

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-12855) Infer result type when the composite type has Any

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

[jira] [Commented] (BEAM-12726) Release_Build failing with :sdks:go:test:load:resolveBuildDependencies failure

[ https://issues.apache.org/jira/browse/BEAM-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412860#comment-17412860 ] Robert Burke commented on BEAM-12726: - Done. As predicted, largely obsolete with the

[jira] [Updated] (BEAM-12726) Release_Build failing with :sdks:go:test:load:resolveBuildDependencies failure

[ https://issues.apache.org/jira/browse/BEAM-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Burke updated BEAM-12726: Resolution: Fixed Status: Resolved (was: Open) > Release_Build failing with :sdks:go:test:

[jira] [Commented] (BEAM-12766) Already Exists: Dataset apache-beam-testing:python_bq_file_loads_NNN

[ https://issues.apache.org/jira/browse/BEAM-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412852#comment-17412852 ] Udi Meiri commented on BEAM-12766: -- This doesn't look like a release blocker, unless I r

[jira] [Commented] (BEAM-12726) Release_Build failing with :sdks:go:test:load:resolveBuildDependencies failure

[ https://issues.apache.org/jira/browse/BEAM-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412850#comment-17412850 ] Udi Meiri commented on BEAM-12726: -- beam_Release_Gradle_Build is passing for 2.33: http

[jira] [Updated] (BEAM-12845) Spark JobServer should bundle AWS IO libraries to support staging on S3

[ https://issues.apache.org/jira/browse/BEAM-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12845: - Fix Version/s: (was: 2.33.0) > Spark JobServer should bundle AWS IO libraries to support staging on S

[jira] [Commented] (BEAM-12845) Spark JobServer should bundle AWS IO libraries to support staging on S3

[ https://issues.apache.org/jira/browse/BEAM-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412846#comment-17412846 ] Udi Meiri commented on BEAM-12845: -- This doesn't look a release blocker, removing the fi

[jira] [Work logged] (BEAM-10917) Implement a BigQuery bounded source using the BigQuery storage API

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Commented] (BEAM-5492) Python Dataflow integration tests should export the pipeline console output to Jenkins Test Result section

[ https://issues.apache.org/jira/browse/BEAM-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412840#comment-17412840 ] Kiley Sok commented on BEAM-5492: - Thanks Valentyn, this would be helpful for Java as well

[jira] [Updated] (BEAM-12867) Either Create or DirectRunner fails to produce all elements to the following transform

[ https://issues.apache.org/jira/browse/BEAM-12867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Collins updated BEAM-12867: -- Issue Type: Bug (was: Improvement) > Either Create or DirectRunner fails to produce all elemen

[jira] [Created] (BEAM-12867) Either Create or DirectRunner fails to produce all elements to the following transform

Daniel Collins created BEAM-12867: - Summary: Either Create or DirectRunner fails to produce all elements to the following transform Key: BEAM-12867 URL: https://issues.apache.org/jira/browse/BEAM-12867

[jira] [Work logged] (BEAM-10708) InteractiveRunner cannot execute pipeline with cross-language transform

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

[jira] [Work logged] (BEAM-12588) Support multimapstate over fnapi

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

[jira] [Work logged] (BEAM-10708) InteractiveRunner cannot execute pipeline with cross-language transform

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

[jira] [Work logged] (BEAM-12740) Reduce and backoff GCS metadata operations when writing to GCS files

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

[jira] [Work logged] (BEAM-12740) Reduce and backoff GCS metadata operations when writing to GCS files

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

[jira] [Work logged] (BEAM-10708) InteractiveRunner cannot execute pipeline with cross-language transform

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

[jira] [Updated] (BEAM-12733) [beam_PostCommit_Java] org.apache.beam.sdk.extensions.ml.RecommendationAIPredictIT.predict failing

[ https://issues.apache.org/jira/browse/BEAM-12733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12733: --- Labels: sickbay (was: ) > [beam_PostCommit_Java] > org.apache.beam.sdk.extensions.ml.Recommendation

[jira] [Updated] (BEAM-12320) PubsubTableProviderIT.testSQLSelectsArrayAttributes[0] failing in SQL PostCommit

[ https://issues.apache.org/jira/browse/BEAM-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12320: --- Labels: flake sickbay (was: flake) > PubsubTableProviderIT.testSQLSelectsArrayAttributes[0] failing

[jira] [Updated] (BEAM-12683) PythonPostCommits RecommendationAIIT.test_create_catalog_item failing

[ https://issues.apache.org/jira/browse/BEAM-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12683: --- Labels: sickbay (was: ) > PythonPostCommits RecommendationAIIT.test_create_catalog_item failing > --

[jira] [Updated] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated"

[ https://issues.apache.org/jira/browse/BEAM-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-9482: -- Labels: sickbay (was: currently-failing) > beam_PerformanceTests_Kafka_IO failing due to " provided por

[jira] [Updated] (BEAM-5172) org.apache.beam.sdk.io.elasticsearch/ElasticsearchIOTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-5172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-5172: -- Labels: flake sickbay (was: flake) > org.apache.beam.sdk.io.elasticsearch/ElasticsearchIOTest is flaky

[jira] [Updated] (BEAM-12866) TestStream should only emit bytes

[ https://issues.apache.org/jira/browse/BEAM-12866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-12866: --- Status: Open (was: Triage Needed) > TestStream should only emit bytes >

[jira] [Comment Edited] (BEAM-12479) UnsupportedOperationException when reading from BigQuery tables and converting TableRows to Beam Rows

[ https://issues.apache.org/jira/browse/BEAM-12479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412818#comment-17412818 ] Udi Meiri edited comment on BEAM-12479 at 9/9/21, 8:23 PM: --- Thi

[jira] [Updated] (BEAM-12479) UnsupportedOperationException when reading from BigQuery tables and converting TableRows to Beam Rows

[ https://issues.apache.org/jira/browse/BEAM-12479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12479: - Resolution: Fixed Status: Resolved (was: Open) > UnsupportedOperationException when reading from

[jira] [Commented] (BEAM-12479) UnsupportedOperationException when reading from BigQuery tables and converting TableRows to Beam Rows

[ https://issues.apache.org/jira/browse/BEAM-12479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412818#comment-17412818 ] Udi Meiri commented on BEAM-12479: -- This seems to have been resolved (PR above merge), c

[jira] [Created] (BEAM-12866) TestStream should only emit bytes

Robert Bradshaw created BEAM-12866: -- Summary: TestStream should only emit bytes Key: BEAM-12866 URL: https://issues.apache.org/jira/browse/BEAM-12866 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-12802) Implement readLater prefetch support in Java SDK harness

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

[jira] [Work logged] (BEAM-12855) Infer result type when the composite type has Any

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

[jira] [Work logged] (BEAM-12855) Infer result type when the composite type has Any

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

[jira] [Work logged] (BEAM-12691) Annotate field access in SQL DoFns.

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

[jira] [Work logged] (BEAM-5172) org.apache.beam.sdk.io.elasticsearch/ElasticsearchIOTest is flaky

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

[jira] [Commented] (BEAM-12805) Multiple XVR suites failing due to Java test ValidateRunnerXlangTest.combinePerKeyTest

[ https://issues.apache.org/jira/browse/BEAM-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412793#comment-17412793 ] Heejong Lee commented on BEAM-12805: If you think the PR above is not safe enough to

[jira] [Work logged] (BEAM-12855) Infer result type when the composite type has Any

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

[jira] [Commented] (BEAM-12603) Flaky: apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers

[ https://issues.apache.org/jira/browse/BEAM-12603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412780#comment-17412780 ] Kyle Weaver commented on BEAM-12603: It looks like the error handling code is running

[jira] [Updated] (BEAM-12603) Flaky: apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers

[ https://issues.apache.org/jira/browse/BEAM-12603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12603: --- Status: Open (was: Triage Needed) > Flaky: > apache_beam.runners.portability.fn_api_runner.fn_runne

[jira] [Updated] (BEAM-12805) Multiple XVR suites failing due to Java test ValidateRunnerXlangTest.combinePerKeyTest

[ https://issues.apache.org/jira/browse/BEAM-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-12805: - Priority: P0 (was: P1) > Multiple XVR suites failing due to Java test > ValidateRunnerXlangTest.combine

[jira] [Commented] (BEAM-12374) Spark postcommit failing ResumeFromCheckpointStreamingTest

[ https://issues.apache.org/jira/browse/BEAM-12374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412774#comment-17412774 ] Kyle Weaver commented on BEAM-12374: I believe this was resolved. > Spark postcommit

[jira] [Updated] (BEAM-12374) Spark postcommit failing ResumeFromCheckpointStreamingTest

[ https://issues.apache.org/jira/browse/BEAM-12374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12374: --- Fix Version/s: Not applicable Resolution: Fixed Status: Resolved (was: Open) > Spa

  1   2   >