[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Updated] (BEAM-12648) apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT failing with A Cloud KMS key cannot be used with Streaming Engine enabled

[ https://issues.apache.org/jira/browse/BEAM-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-12648: Priority: P2 (was: P1) > apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT fai

[jira] [Commented] (BEAM-12648) apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT failing with A Cloud KMS key cannot be used with Streaming Engine enabled

[ https://issues.apache.org/jira/browse/BEAM-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392775#comment-17392775 ] Ankur Goenka commented on BEAM-12648: - We have reverted the #15140 and the issue is g

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12661) GetData Windmill RPC calls Become Stuck

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12661) GetData Windmill RPC calls Become Stuck

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

[jira] [Work logged] (BEAM-12661) GetData Windmill RPC calls Become Stuck

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

[jira] [Work logged] (BEAM-12661) GetData Windmill RPC calls Become Stuck

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

[jira] [Work logged] (BEAM-12661) GetData Windmill RPC calls Become Stuck

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

[jira] [Updated] (BEAM-12676) StreamingWordCountIT is failing for Python PreCommit

[ https://issues.apache.org/jira/browse/BEAM-12676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-12676: Priority: P0 (was: P1) > StreamingWordCountIT is failing for Python PreCommit > -

[jira] [Commented] (BEAM-12676) StreamingWordCountIT is failing for Python PreCommit

[ https://issues.apache.org/jira/browse/BEAM-12676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392698#comment-17392698 ] Ankur Goenka commented on BEAM-12676: - I see the same error in logs for job [https:/

[jira] [Work logged] (BEAM-12678) beam_PreCommit_GoPortable_Phrase failing to start the local job server

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

[jira] [Work logged] (BEAM-12678) beam_PreCommit_GoPortable_Phrase failing to start the local job server

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

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

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12593) DataFrame API: Support pandas 1.3.x

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12593) DataFrame API: Support pandas 1.3.x

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

[jira] [Work logged] (BEAM-12685) Allow managed thread count in AvroIO

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

[jira] [Work logged] (BEAM-12670) python bigquery_tools.py no longer reports failed RPC on metrics properly

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

[jira] [Work logged] (BEAM-12593) DataFrame API: Support pandas 1.3.x

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

[jira] [Work logged] (BEAM-3713) Consider moving away from nose to nose2 or pytest.

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

[jira] [Work logged] (BEAM-12100) SUM should error when overflow/underflow occurs.

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

[jira] [Work logged] (BEAM-12100) SUM should error when overflow/underflow occurs.

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

[jira] [Commented] (BEAM-12647) Aggregations on empty pcoll don't return a value.

[ https://issues.apache.org/jira/browse/BEAM-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392599#comment-17392599 ] Benjamin Gonzalez commented on BEAM-12647: -- I've made some progress on this issu

[jira] [Work logged] (BEAM-12100) SUM should error when overflow/underflow occurs.

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

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

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

[jira] [Commented] (BEAM-12713) beam_PostCommit_NightlySnapshot runMobileGamingJavaDataflow failing

[ https://issues.apache.org/jira/browse/BEAM-12713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392594#comment-17392594 ] Kiley Sok commented on BEAM-12713: -- Seeing this in the logs: {code:java} "Unable to nego

[jira] [Work logged] (BEAM-7386) Add Utility BiTemporalStreamJoin

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

[jira] [Work logged] (BEAM-12670) python bigquery_tools.py no longer reports failed RPC on metrics properly

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

[jira] [Work logged] (BEAM-2791) DirectRunner shuts down when there are pending event time timers

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

[jira] [Work logged] (BEAM-2791) DirectRunner shuts down when there are pending event time timers

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

[jira] [Work logged] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

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

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

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

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

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

[jira] [Updated] (BEAM-12403) Support user states in Samza portable runner

[ https://issues.apache.org/jira/browse/BEAM-12403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu updated BEAM-12403: - Resolution: Duplicate Status: Resolved (was: In Progress) Duplicate as BEAM-12348 > Support user states

[jira] [Work started] (BEAM-12403) Support user states in Samza portable runner

[ https://issues.apache.org/jira/browse/BEAM-12403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-12403 started by Ke Wu. > Support user states in Samza portable runner > >

[jira] [Updated] (BEAM-12403) Support user states in Samza portable runner

[ https://issues.apache.org/jira/browse/BEAM-12403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu updated BEAM-12403: - Status: Open (was: Triage Needed) > Support user states in Samza portable runner > -

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Work logged] (BEAM-12670) python bigquery_tools.py no longer reports failed RPC on metrics properly

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

[jira] [Work logged] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop

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

[jira] [Work logged] (BEAM-2791) DirectRunner shuts down when there are pending event time timers

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

[jira] [Created] (BEAM-12720) GroupIntoBatches override incorrectly modifies variables after outputting them

Reuven Lax created BEAM-12720: - Summary: GroupIntoBatches override incorrectly modifies variables after outputting them Key: BEAM-12720 URL: https://issues.apache.org/jira/browse/BEAM-12720 Project: Beam

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

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

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

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

[jira] [Work logged] (BEAM-11983) Java Datastore - Implement IO Request Count metrics

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

[jira] [Created] (BEAM-12719) ZetaSQL overview support table is outdated

Kyle Weaver created BEAM-12719: -- Summary: ZetaSQL overview support table is outdated Key: BEAM-12719 URL: https://issues.apache.org/jira/browse/BEAM-12719 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-12719) ZetaSQL overview support table is outdated

[ https://issues.apache.org/jira/browse/BEAM-12719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-12719: --- Status: Open (was: Triage Needed) > ZetaSQL overview support table is outdated > ---

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

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

[jira] [Updated] (BEAM-12718) Dataflow runner throws unclear exception when credential is not set properly

[ https://issues.apache.org/jira/browse/BEAM-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-12718: --- Status: Open (was: Triage Needed) > Dataflow runner throws unclear exception when credential is not

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

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

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

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

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

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

[jira] [Work logged] (BEAM-12378) GroupIntoBatches should support byte-size batches

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

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

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

[jira] [Created] (BEAM-12718) Dataflow runner throws unclear exception when credential is not set properly

Yichi Zhang created BEAM-12718: -- Summary: Dataflow runner throws unclear exception when credential is not set properly Key: BEAM-12718 URL: https://issues.apache.org/jira/browse/BEAM-12718 Project: Beam

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

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

[jira] [Work logged] (BEAM-12670) python bigquery_tools.py no longer reports failed RPC on metrics properly

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

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

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

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

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

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

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

[jira] [Work logged] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop

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

[jira] [Work logged] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop

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

[jira] [Work logged] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop

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

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

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

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

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

[jira] [Assigned] (BEAM-12347) Enable UseSideInputs ValidatesPortableRunner tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu reassigned BEAM-12347: Assignee: Xinyu Liu > Enable UseSideInputs ValidatesPortableRunner tests in Samza Runner > ---

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Assigned] (BEAM-12403) Support user states in Samza portable runner

[ https://issues.apache.org/jira/browse/BEAM-12403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu reassigned BEAM-12403: Assignee: Ke Wu > Support user states in Samza portable runner > -

[jira] [Work logged] (BEAM-11088) [Go SDK] Implement TestStream primitive

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

[jira] [Updated] (BEAM-12347) Enable UseSideInputs ValidatesPortableRunner tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu updated BEAM-12347: - Resolution: Fixed Status: Resolved (was: In Progress) Resolved in BEAM-12370 > Enable UseSideInputs Val

[jira] [Work started] (BEAM-12347) Enable UseSideInputs ValidatesPortableRunner tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-12347 started by Xinyu Liu. > Enable UseSideInputs ValidatesPortableRunner tests in Samza Runner > -

[jira] [Assigned] (BEAM-12346) Enable basic ValidatesPortableRunner tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu reassigned BEAM-12346: Assignee: Xinyu Liu > Enable basic ValidatesPortableRunner tests in Samza Runner > ---

[jira] [Updated] (BEAM-12346) Enable basic ValidatesPortableRunner tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu updated BEAM-12346: - Resolution: Fixed Status: Resolved (was: Open) > Enable basic ValidatesPortableRunner tests in Samza Run

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Work logged] (BEAM-11088) [Go SDK] Implement TestStream primitive

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17392479#comment-17392479 ] Tyson Hamilton commented on BEAM-9482: -- I checked the jenkins nodes, the ports were n

[jira] [Work logged] (BEAM-12593) DataFrame API: Support pandas 1.3.x

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Work logged] (BEAM-12716) Update XLang Kafka taxi example to use BigQuery sink

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

[jira] [Assigned] (BEAM-12348) Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only tests in Samza Runner

[ https://issues.apache.org/jira/browse/BEAM-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ke Wu reassigned BEAM-12348: Assignee: Ke Wu > Enable UsesStatefulParDo ValidatesPortableRunner and test_pardo_state_only > tests in S

[jira] [Work logged] (BEAM-12670) python bigquery_tools.py no longer reports failed RPC on metrics properly

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

  1   2   3   >