[jira] [Work logged] (BEAM-8743) Add support for flat schemas in pubsub

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

[jira] [Commented] (BEAM-8814) --no_auth flag is boolean type and is misleading

[ https://issues.apache.org/jira/browse/BEAM-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980705#comment-16980705 ] David Song commented on BEAM-8814: -- More details on sdk_worker_main: I've found this bug

[jira] [Commented] (BEAM-8733) The "KeyError: u'-47'" error from line 305 of sdk_worker.py

[ https://issues.apache.org/jira/browse/BEAM-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980674#comment-16980674 ] sunjincheng commented on BEAM-8733: --- Hi [~lcwik], thank you for explaining, then it make

[jira] [Commented] (BEAM-8812) [release 2.17.0 validation] org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate failure

[ https://issues.apache.org/jira/browse/BEAM-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980673#comment-16980673 ] Jan Lukavský commented on BEAM-8812: Hi [~Ardagan] the PR #10203 should fix that. >

[jira] [Work logged] (BEAM-8812) [release 2.17.0 validation] org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate failure

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

[jira] [Work logged] (BEAM-8743) Add support for flat schemas in pubsub

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

[jira] [Work logged] (BEAM-8814) --no_auth flag is boolean type and is misleading

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

[jira] [Resolved] (BEAM-8651) Python 3 portable pipelines sometimes fail with errors in StockUnpickler.find_class()

[ https://issues.apache.org/jira/browse/BEAM-8651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev resolved BEAM-8651. --- Resolution: Fixed > Python 3 portable pipelines sometimes fail with errors in > Stock

[jira] [Work logged] (BEAM-8814) --no_auth flag is boolean type and is misleading

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

[jira] [Closed] (BEAM-8791) [2.17.0 Release Validation] Run Python PreCommit times out

[ https://issues.apache.org/jira/browse/BEAM-8791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev closed BEAM-8791. - Resolution: Fixed > [2.17.0 Release Validation] Run Python PreCommit times out > -

[jira] [Commented] (BEAM-8791) [2.17.0 Release Validation] Run Python PreCommit times out

[ https://issues.apache.org/jira/browse/BEAM-8791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980622#comment-16980622 ] Valentyn Tymofieiev commented on BEAM-8791: --- Passes now within 1.5 hrs after dro

[jira] [Work logged] (BEAM-8651) Python 3 portable pipelines sometimes fail with errors in StockUnpickler.find_class()

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

[jira] [Work logged] (BEAM-8651) Python 3 portable pipelines sometimes fail with errors in StockUnpickler.find_class()

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Commented] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980617#comment-16980617 ] Chamikara Madhusanka Jayalath commented on BEAM-8803: - Made this a blo

[jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8803: Fix Version/s: 2.18.0 > Default behaviour for Python BQ Streaming in

[jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8803: Issue Type: Bug (was: Improvement) > Default behaviour for Python B

[jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8803: Priority: Blocker (was: Major) > Default behaviour for Python BQ St

[jira] [Updated] (BEAM-8814) --no_auth flag is boolean type and is misleading

[ https://issues.apache.org/jira/browse/BEAM-8814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Song updated BEAM-8814: - Status: Open (was: Triage Needed) > --no_auth flag is boolean type and is misleading > --

[jira] [Created] (BEAM-8814) --no_auth flag is boolean type and is misleading

David Song created BEAM-8814: Summary: --no_auth flag is boolean type and is misleading Key: BEAM-8814 URL: https://issues.apache.org/jira/browse/BEAM-8814 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

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

[jira] [Created] (BEAM-8813) Java updateOfflineRepository fails

Kyle Weaver created BEAM-8813: - Summary: Java updateOfflineRepository fails Key: BEAM-8813 URL: https://issues.apache.org/jira/browse/BEAM-8813 Project: Beam Issue Type: Improvement Com

[jira] [Updated] (BEAM-8813) Java updateOfflineRepository fails

[ https://issues.apache.org/jira/browse/BEAM-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8813: -- Issue Type: Bug (was: Improvement) > Java updateOfflineRepository fails > -

[jira] [Work logged] (BEAM-7926) Show PCollection with Interactive Beam in a data-centric user flow

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

[jira] [Assigned] (BEAM-8406) TextTable support JSON format

[ https://issues.apache.org/jira/browse/BEAM-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned BEAM-8406: --- Assignee: Jing Chen > TextTable support JSON format > - > >

[jira] [Work logged] (BEAM-8273) Improve worker script for environment_type=PROCESS

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

[jira] [Work logged] (BEAM-8273) Improve worker script for environment_type=PROCESS

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

[jira] [Work logged] (BEAM-2572) Implement an S3 filesystem for Python SDK

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

[jira] [Resolved] (BEAM-8451) Interactive Beam example failing from stack overflow

[ https://issues.apache.org/jira/browse/BEAM-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun Yang resolved BEAM-8451. - Assignee: Chun Yang (was: Igor Durovic) Resolution: Fixed This was fixed in https://github.com/apac

[jira] [Updated] (BEAM-8451) Interactive Beam example failing from stack overflow

[ https://issues.apache.org/jira/browse/BEAM-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chun Yang updated BEAM-8451: Fix Version/s: 2.18.0 > Interactive Beam example failing from stack overflow > -

[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Commented] (BEAM-6763) Publish Portability artifacts

[ https://issues.apache.org/jira/browse/BEAM-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980552#comment-16980552 ] Kyle Weaver commented on BEAM-6763: --- 2. and 3. from the description are complete, so I w

[jira] [Resolved] (BEAM-6763) Publish Portability artifacts

[ https://issues.apache.org/jira/browse/BEAM-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-6763. --- Fix Version/s: Not applicable Resolution: Fixed > Publish Portability artifacts > -

[jira] [Updated] (BEAM-8337) Add Flink job server container images to release process

[ https://issues.apache.org/jira/browse/BEAM-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8337: -- Summary: Add Flink job server container images to release process (was: Publish Flink job server contai

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Assigned] (BEAM-8337) Publish Flink job server container images

[ https://issues.apache.org/jira/browse/BEAM-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver reassigned BEAM-8337: - Assignee: Kyle Weaver > Publish Flink job server container images > -

[jira] [Updated] (BEAM-8337) Publish Flink job server container images

[ https://issues.apache.org/jira/browse/BEAM-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8337: -- Summary: Publish Flink job server container images (was: Consider publishing portable job server contai

[jira] [Updated] (BEAM-8337) Publish Flink job server container images

[ https://issues.apache.org/jira/browse/BEAM-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8337: -- Component/s: (was: runner-spark) > Publish Flink job server container images > -

[jira] [Commented] (BEAM-8337) Consider publishing portable job server container images

[ https://issues.apache.org/jira/browse/BEAM-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980549#comment-16980549 ] Kyle Weaver commented on BEAM-8337: --- As part of the effort to make the Flink runner Kube

[jira] [Created] (BEAM-8812) [release 2.17.0 validation] org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate failure

Mikhail Gryzykhin created BEAM-8812: --- Summary: [release 2.17.0 validation] org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate failure Key: BEAM-8812 URL: https://issues.apa

[jira] [Commented] (BEAM-8812) [release 2.17.0 validation] org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerOrderingWithCreate failure

[ https://issues.apache.org/jira/browse/BEAM-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980546#comment-16980546 ] Mikhail Gryzykhin commented on BEAM-8812: - I'm trying to repro locally, but target

[jira] [Resolved] (BEAM-8796) Optionally configure static job port for JavaJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8796. --- Fix Version/s: 2.18.0 Resolution: Fixed > Optionally configure static job port for JavaJarJobSe

[jira] [Resolved] (BEAM-8781) FlinkUberJarJobServer should respect --flink_job_server_jar

[ https://issues.apache.org/jira/browse/BEAM-8781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8781. --- Fix Version/s: 2.18.0 Resolution: Fixed > FlinkUberJarJobServer should respect --flink_job_serv

[jira] [Resolved] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer

[ https://issues.apache.org/jira/browse/BEAM-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8658. --- Fix Version/s: 2.18.0 Resolution: Fixed > Optionally set artifact staging port in FlinkUberJarJ

[jira] [Work logged] (BEAM-8651) Python 3 portable pipelines sometimes fail with errors in StockUnpickler.find_class()

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

[jira] [Work logged] (BEAM-8805) Remove obsolete worker_threads experiment in tests

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

[jira] [Resolved] (BEAM-8805) Remove obsolete worker_threads experiment in tests

[ https://issues.apache.org/jira/browse/BEAM-8805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-8805. - Fix Version/s: 2.18.0 Resolution: Fixed > Remove obsolete worker_threads experiment in tests >

[jira] [Closed] (BEAM-8619) Tear down the DoFns upon the control service termination in Java SDK harness

[ https://issues.apache.org/jira/browse/BEAM-8619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-8619. --- Fix Version/s: 2.18.0 Resolution: Fixed > Tear down the DoFns upon the control service termination in J

[jira] [Work logged] (BEAM-8619) Tear down the DoFns upon the control service termination in Java SDK harness

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

[jira] [Commented] (BEAM-8569) Support Hadoop 3 on Beam

[ https://issues.apache.org/jira/browse/BEAM-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980532#comment-16980532 ] Tomo Suzuki commented on BEAM-8569: --- I was trying to upgrade bigtable-client-core to the

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-8805) Remove obsolete worker_threads experiment in tests

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

[jira] [Work logged] (BEAM-8805) Remove obsolete worker_threads experiment in tests

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

[jira] [Work logged] (BEAM-8811) Upgrade Beam pipeline diagrams in docs

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8791) [2.17.0 Release Validation] Run Python PreCommit times out

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

[jira] [Commented] (BEAM-8733) The "KeyError: u'-47'" error from line 305 of sdk_worker.py

[ https://issues.apache.org/jira/browse/BEAM-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980494#comment-16980494 ] Luke Cwik commented on BEAM-8733: - Your not wrong, the java implementation is also bad and

[jira] [Work logged] (BEAM-8619) Tear down the DoFns upon the control service termination in Java SDK harness

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

[jira] [Work logged] (BEAM-8619) Tear down the DoFns upon the control service termination in Java SDK harness

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-8619) Tear down the DoFns upon the control service termination in Java SDK harness

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

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

[jira] [Work logged] (BEAM-2572) Implement an S3 filesystem for Python SDK

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-7746) Add type hints to python code

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8586) [SQL] Add a server for MongoDb Integration Test

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

[jira] [Work logged] (BEAM-8586) [SQL] Add a server for MongoDb Integration Test

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Work logged] (BEAM-8575) Add more Python validates runner tests

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

[jira] [Commented] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always

[ https://issues.apache.org/jira/browse/BEAM-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980434#comment-16980434 ] Pablo Estrada commented on BEAM-8803: - After discussing with Cham, we will change the

[jira] [Created] (BEAM-8811) Upgrade Beam pipeline diagrams in docs

Cyrus Maden created BEAM-8811: - Summary: Upgrade Beam pipeline diagrams in docs Key: BEAM-8811 URL: https://issues.apache.org/jira/browse/BEAM-8811 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-8802) Timestamp combiner not respected across bundles in streaming mode.

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

[jira] [Work logged] (BEAM-8802) Timestamp combiner not respected across bundles in streaming mode.

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Created] (BEAM-8810) Dataflow runner - Work stuck in state COMMITTING with streaming commit rpcs

Sam Whittle created BEAM-8810: - Summary: Dataflow runner - Work stuck in state COMMITTING with streaming commit rpcs Key: BEAM-8810 URL: https://issues.apache.org/jira/browse/BEAM-8810 Project: Beam

[jira] [Work logged] (BEAM-8743) Add support for flat schemas in pubsub

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

[jira] [Work logged] (BEAM-8809) AvroWriteRequest should have a public constructor

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

[jira] [Work logged] (BEAM-4776) Java PortableRunner should support metrics

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

[jira] [Work logged] (BEAM-7948) Add time-based cache threshold support in the Java data service

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

  1   2   >