[jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle

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

[jira] [Work logged] (BEAM-9263) Bump python sdk fnapi version to enable status reporting

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-9636) Run Dataflow ValidatesRunner (:runners:google-cloud-dataflow-java:validatesRunnerLegacyWorkerTest) failing

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

[jira] [Work logged] (BEAM-9571) Add withMongoClientProvider to MongoDbIO

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

[jira] [Commented] (BEAM-9439) KinesisReader does not report correct backlog statistics

[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071688#comment-17071688 ] Alexey Romanenko commented on BEAM-9439: [~titmus] Thanks, sounds good to me as a trade-off

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9008: --- Fix Version/s: 2.21.0 > Add readAll() method to CassandraIO > --- > >

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

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

[jira] [Work logged] (BEAM-9571) Add withMongoClientProvider to MongoDbIO

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

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

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

[jira] [Work logged] (BEAM-9571) Add withMongoClientProvider to MongoDbIO

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

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

Léopold Boudard created BEAM-9645: - Summary: Python flinkrunner cannot inspect container Key: BEAM-9645 URL: https://issues.apache.org/jira/browse/BEAM-9645 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-9571) Add withMongoClientProvider to MongoDbIO

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

[jira] [Assigned] (BEAM-9439) KinesisReader does not report correct backlog statistics

[ https://issues.apache.org/jira/browse/BEAM-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-9439: -- Assignee: Sebastian Graca > KinesisReader does not report correct backlog statistics

[jira] [Work logged] (BEAM-9633) PubsubIO performance tests

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

[jira] [Created] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality

Michał Walenia created BEAM-9646: Summary: [Java] PTransform that integrates Cloud Vision functionality Key: BEAM-9646 URL: https://issues.apache.org/jira/browse/BEAM-9646 Project: Beam

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

[ https://issues.apache.org/jira/browse/BEAM-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Léopold Boudard updated BEAM-9645: -- Description: Hi, I'm trying to submit a python pipeline job as portable runner with

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

[ https://issues.apache.org/jira/browse/BEAM-9645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Léopold Boudard updated BEAM-9645: -- Description: Hi, I'm trying to submit a python pipeline job as portable runner with

[jira] [Work logged] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried

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

[jira] [Work logged] (BEAM-9633) PubsubIO performance tests

[ https://issues.apache.org/jira/browse/BEAM-9633?focusedWorklogId=413175=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413175 ] ASF GitHub Bot logged work on BEAM-9633: 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=413108=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413108 ] 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=413107=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413107 ] 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=413113=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413113 ] ASF GitHub Bot logged work on BEAM-9550: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators

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

[jira] [Updated] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality

[ https://issues.apache.org/jira/browse/BEAM-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9646: --- Status: Open (was: Triage Needed) > [Java] PTransform that integrates Cloud Vision functionality >

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to one mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Description: The load tests fail sometimes with a mismatched sum result for example

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Updated] (BEAM-9325) UnownedOutputStream not overriding Array write method.

[ https://issues.apache.org/jira/browse/BEAM-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9325: --- Fix Version/s: (was: Not applicable) 2.21.0 > UnownedOutputStream not

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9638) False positives in worker region & zone tests

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

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Summary: beam_python_mongoio_load_test started failing due to mismatched results (was:

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

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

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

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

[jira] [Commented] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071971#comment-17071971 ] Yichi Zhang commented on BEAM-9649: --- cc: +[~chamikara] fyi Not particularly sure when it started

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Created] (BEAM-9649) beam_python_mongoio_load_test started failing due to one mismatched results

Yichi Zhang created BEAM-9649: - Summary: beam_python_mongoio_load_test started failing due to one mismatched results Key: BEAM-9649 URL: https://issues.apache.org/jira/browse/BEAM-9649 Project: Beam

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

[ https://issues.apache.org/jira/browse/BEAM-9399?focusedWorklogId=413389=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-413389 ] ASF GitHub Bot logged work on BEAM-9399: 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=17071998#comment-17071998 ] Yichi Zhang commented on BEAM-8944: --- [~mxm] the checkpoint duration is lower means that without

[jira] [Created] (BEAM-9647) No MQTT connection possible because clientId is too long

Michael Jacoby created BEAM-9647: Summary: No MQTT connection possible because clientId is too long Key: BEAM-9647 URL: https://issues.apache.org/jira/browse/BEAM-9647 Project: Beam Issue

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Work logged] (BEAM-9636) Run Dataflow ValidatesRunner (:runners:google-cloud-dataflow-java:validatesRunnerLegacyWorkerTest) failing

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

[jira] [Updated] (BEAM-9647) No MQTT connection possible because clientId is too long

[ https://issues.apache.org/jira/browse/BEAM-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9647: --- Priority: Critical (was: Blocker) > No MQTT connection possible because clientId is too long >

[jira] [Work logged] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried

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

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

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8944: - Affects Version/s: 2.20.0 > Python SDK harness performance degradation with

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

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8944: - Status: Open (was: Triage Needed) > Python SDK harness performance degradation with

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

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8944: - Priority: Critical (was: Blocker) > Python SDK harness performance degradation with

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

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened BEAM-8944: -- Assignee: (was: Yichi Zhang) Reopening because this poses quite a performance

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Created] (BEAM-9648) DirectRunner waitUntilFinish does not return null on timeout

Filipe Regadas created BEAM-9648: Summary: DirectRunner waitUntilFinish does not return null on timeout Key: BEAM-9648 URL: https://issues.apache.org/jira/browse/BEAM-9648 Project: Beam

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

[ https://issues.apache.org/jira/browse/BEAM-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8944: - Affects Version/s: (was: 2.20.0) > Python SDK harness performance degradation with

[jira] [Work logged] (BEAM-9454) Add Deduplication transform for SDF

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

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Priority: Critical (was: Minor) > beam_python_mongoio_load_test started failing due to mismatched

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Assigned] (BEAM-9325) UnownedOutputStream not overriding Array write method.

[ https://issues.apache.org/jira/browse/BEAM-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-9325: -- Assignee: Kyoungha Min > UnownedOutputStream not overriding Array write method. >

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Description: The load tests fail sometimes with a mismatched sum result for example

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Attachment: j5vwSDNmTBK.png > beam_python_mongoio_load_test started failing due to mismatched results >

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yichi Zhang updated BEAM-9649: -- Attachment: mHP2wb3rdTG.png > beam_python_mongoio_load_test started failing due to mismatched results >

[jira] [Updated] (BEAM-9622) Support for consuming tagged PCollections in Python SqlTransform

[ https://issues.apache.org/jira/browse/BEAM-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud updated BEAM-9622: - Status: Open (was: Triage Needed) > Support for consuming tagged PCollections in Python

[jira] [Updated] (BEAM-9623) Add support for TableProviders in Python SqlTransform

[ https://issues.apache.org/jira/browse/BEAM-9623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud updated BEAM-9623: - Status: Open (was: Triage Needed) > Add support for TableProviders in Python SqlTransform >

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

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

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

[jira] [Work logged] (BEAM-8280) re-enable IOTypeHints.from_callable

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

[jira] [Assigned] (BEAM-5411) Separate BeamUnnest and BeamCalc

[ https://issues.apache.org/jira/browse/BEAM-5411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-5411: Assignee: (was: Andrew Pilloud) > Separate BeamUnnest and BeamCalc >

[jira] [Commented] (BEAM-9651) StreamingDataflowWorker stuck waiting for org.apache.beam.runners.dataflow.worker.windmill.DirectStreamObserver.onNext

[ https://issues.apache.org/jira/browse/BEAM-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072114#comment-17072114 ] Sam Whittle commented on BEAM-9651: --- This looks similar to BEAM-4280 regarding the fnapi DirectObserver

[jira] [Resolved] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

[ https://issues.apache.org/jira/browse/BEAM-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-9399. - Fix Version/s: 2.21.0 Resolution: Fixed > Possible deadlock between DataflowWorkerLoggingHandler

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Work logged] (BEAM-9399) Possible deadlock between DataflowWorkerLoggingHandler and overridden System.err PrintStream

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

[jira] [Resolved] (BEAM-8401) Upgrade to ZetaSQL 2019.10.1

[ https://issues.apache.org/jira/browse/BEAM-8401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud resolved BEAM-8401. -- Fix Version/s: Not applicable Resolution: Fixed > Upgrade to ZetaSQL 2019.10.1 >

[jira] [Work started] (BEAM-9514) AssertionError type mismatch from SUM

[ https://issues.apache.org/jira/browse/BEAM-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9514 started by Andrew Pilloud. > AssertionError type mismatch from SUM > -

[jira] [Assigned] (BEAM-8362) Don't use ZetaSQL's unimplemented functions

[ https://issues.apache.org/jira/browse/BEAM-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-8362: Assignee: (was: Andrew Pilloud) > Don't use ZetaSQL's unimplemented functions >

[jira] [Assigned] (BEAM-8896) WITH query AS + SELECT query JOIN other throws invalid type

[ https://issues.apache.org/jira/browse/BEAM-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-8896: Assignee: (was: Andrew Pilloud) > WITH query AS + SELECT query JOIN other throws

[jira] [Work logged] (BEAM-7699) Remove duplicated null checks in Row.equals

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

[jira] [Work logged] (BEAM-7699) Remove duplicated null checks in Row.equals

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

[jira] [Work logged] (BEAM-8280) re-enable IOTypeHints.from_callable

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

[jira] [Created] (BEAM-9650) Add consistent slowly changing side inputs support

Mikhail Gryzykhin created BEAM-9650: --- Summary: Add consistent slowly changing side inputs support Key: BEAM-9650 URL: https://issues.apache.org/jira/browse/BEAM-9650 Project: Beam Issue

[jira] [Assigned] (BEAM-9650) Add consistent slowly changing side inputs support

[ https://issues.apache.org/jira/browse/BEAM-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Gryzykhin reassigned BEAM-9650: --- Assignee: Mikhail Gryzykhin > Add consistent slowly changing side inputs support >

[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=17072103#comment-17072103 ] Maximilian Michels commented on BEAM-8944: -- Essentially, yes. Especially, this is a concern for

[jira] [Created] (BEAM-9651) StreamingDataflowWorker stuck waiting for org.apache.beam.runners.dataflow.worker.windmill.DirectStreamObserver.onNext

Sam Whittle created BEAM-9651: - Summary: StreamingDataflowWorker stuck waiting for org.apache.beam.runners.dataflow.worker.windmill.DirectStreamObserver.onNext Key: BEAM-9651 URL:

[jira] [Work logged] (BEAM-9325) UnownedOutputStream not overriding Array write method.

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

[jira] [Resolved] (BEAM-9325) UnownedOutputStream not overriding Array write method.

[ https://issues.apache.org/jira/browse/BEAM-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-9325. - Resolution: Fixed > UnownedOutputStream not overriding Array write method. >

[jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage

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

  1   2   >