[jira] [Work logged] (BEAM-8645) TimestampCombiner incorrect in beam python

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

[jira] [Work logged] (BEAM-8554) Use WorkItemCommitRequest protobuf fields to signal that a WorkItem needs to be broken up

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

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Work logged] (BEAM-8657) Not doing Combiner lifting for data-driven triggers

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

[jira] [Work logged] (BEAM-8592) DataCatalogTableProvider should not squash table components together into a string

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

[jira] [Commented] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974802#comment-16974802 ] Valentyn Tymofieiev commented on BEAM-1251: --- We are investigating an issue BEAM-8651 where

[jira] [Work logged] (BEAM-8670) Manage environment parallelism in DefaultJobBundleFactory

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

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Created] (BEAM-8670) Manage environment parallelism in DefaultJobBundleFactory

Thomas Weise created BEAM-8670: -- Summary: Manage environment parallelism in DefaultJobBundleFactory Key: BEAM-8670 URL: https://issues.apache.org/jira/browse/BEAM-8670 Project: Beam Issue Type:

[jira] [Created] (BEAM-8669) Default methods not allowed in PipelineOptions

chris stockton created BEAM-8669: Summary: Default methods not allowed in PipelineOptions Key: BEAM-8669 URL: https://issues.apache.org/jira/browse/BEAM-8669 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

[ https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974778#comment-16974778 ] Kyle Weaver commented on BEAM-8372: --- Should this be marked as completed, or do we consider BEAM-8512 a

[jira] [Created] (BEAM-8668) TypeError: _create_function() takes from 2 to 6 positional arguments but 7 were given

Kyle Weaver created BEAM-8668: - Summary: TypeError: _create_function() takes from 2 to 6 positional arguments but 7 were given Key: BEAM-8668 URL: https://issues.apache.org/jira/browse/BEAM-8668 Project:

[jira] [Updated] (BEAM-8668) TypeError: _create_function() takes from 2 to 6 positional arguments but 7 were given

[ https://issues.apache.org/jira/browse/BEAM-8668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8668: -- Status: Open (was: Triage Needed) > TypeError: _create_function() takes from 2 to 6 positional

[jira] [Resolved] (BEAM-4615) Flink job server driver wrapper

[ https://issues.apache.org/jira/browse/BEAM-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-4615. --- Fix Version/s: Not applicable Resolution: Fixed > Flink job server driver wrapper >

[jira] [Commented] (BEAM-4615) Flink job server driver wrapper

[ https://issues.apache.org/jira/browse/BEAM-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974769#comment-16974769 ] Kyle Weaver commented on BEAM-4615: --- Just stumbled across this issue in a search. The second part sounds

[jira] [Comment Edited] (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:comment-tabpanel=16974742#comment-16974742 ] Valentyn Tymofieiev edited comment on BEAM-8651 at 11/15/19 2:25 AM: -

[jira] [Commented] (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:comment-tabpanel=16974742#comment-16974742 ] Valentyn Tymofieiev commented on BEAM-8651: --- > On Beam we've been only running into this issue

[jira] [Commented] (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:comment-tabpanel=16974740#comment-16974740 ] Valentyn Tymofieiev commented on BEAM-8651: --- Thanks a lot, [~gstarnberger]! > Python 3 portable

[jira] [Commented] (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:comment-tabpanel=16974735#comment-16974735 ] Guenther Starnberger commented on BEAM-8651: I've attached a script to reproduce that issue.

[jira] [Updated] (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 ] Guenther Starnberger updated BEAM-8651: --- Attachment: beam8651.py > Python 3 portable pipelines sometimes fail with errors in

[jira] [Commented] (BEAM-8652) test_streaming_pipeline_returns_expected_user_metrics_fnapi_it test flaky

[ https://issues.apache.org/jira/browse/BEAM-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974733#comment-16974733 ] Valentyn Tymofieiev commented on BEAM-8652: --- I am investigating

[jira] [Assigned] (BEAM-8652) test_streaming_pipeline_returns_expected_user_metrics_fnapi_it test flaky

[ https://issues.apache.org/jira/browse/BEAM-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-8652: - Assignee: Valentyn Tymofieiev (was: Yichi Zhang) >

[jira] [Work logged] (BEAM-8442) Unify bundle register in Python SDK harness

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

[jira] [Work logged] (BEAM-8442) Unify bundle register in Python SDK harness

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

[jira] [Commented] (BEAM-8591) Exception is thrown while running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974729#comment-16974729 ] Kyle Weaver commented on BEAM-8591: --- Hi Mingliang, as Thomas indicated, this behavior is expected for

[jira] [Updated] (BEAM-8591) Exception is thrown while running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-8591: -- Status: Open (was: Triage Needed) > Exception is thrown while running Beam Pipeline on Kubernetes

[jira] [Assigned] (BEAM-8591) Exception is thrown while running Beam Pipeline on Kubernetes Flink Cluster.

[ https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver reassigned BEAM-8591: - Assignee: Kyle Weaver > Exception is thrown while running Beam Pipeline on Kubernetes Flink

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

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

[jira] [Work logged] (BEAM-8554) Use WorkItemCommitRequest protobuf fields to signal that a WorkItem needs to be broken up

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

[jira] [Work logged] (BEAM-8657) Not doing Combiner lifting for data-driven triggers

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

[jira] [Closed] (BEAM-8663) BundleBasedRunner Stacked Bundles don't respect PaneInfo

[ https://issues.apache.org/jira/browse/BEAM-8663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw closed BEAM-8663. - Fix Version/s: 2.18.0 Resolution: Fixed > BundleBasedRunner Stacked Bundles don't respect

[jira] [Work logged] (BEAM-8663) BundleBasedRunner Stacked Bundles don't respect PaneInfo

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

[jira] [Work logged] (BEAM-8657) Not doing Combiner lifting for data-driven triggers

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

[jira] [Work logged] (BEAM-8657) Not doing Combiner lifting for data-driven triggers

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

[jira] [Work logged] (BEAM-8624) Implement FnService for status api in Dataflow runner

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

[jira] [Work logged] (BEAM-8624) Implement FnService for status api in Dataflow runner

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

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

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

[jira] [Work logged] (BEAM-8442) Unify bundle register in Python SDK harness

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

[jira] [Work logged] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK

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

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Commented] (BEAM-8481) Python 3.7 Postcommit test -- frequent timeouts

[ https://issues.apache.org/jira/browse/BEAM-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974689#comment-16974689 ] Kyle Weaver commented on BEAM-8481: --- Dataflow workers. > Python 3.7 Postcommit test -- frequent

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Work logged] (BEAM-8660) Override returned artifact staging endpoint

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Commented] (BEAM-8481) Python 3.7 Postcommit test -- frequent timeouts

[ https://issues.apache.org/jira/browse/BEAM-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974682#comment-16974682 ] Valentyn Tymofieiev commented on BEAM-8481: --- Thanks for looking into this. In your last message,

[jira] [Work logged] (BEAM-8655) Strengthen trigger transcript tests

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

[jira] [Work logged] (BEAM-8655) Strengthen trigger transcript tests

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

[jira] [Commented] (BEAM-8481) Python 3.7 Postcommit test -- frequent timeouts

[ https://issues.apache.org/jira/browse/BEAM-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974668#comment-16974668 ] Kyle Weaver commented on BEAM-8481: --- I looked at a couple of the aborted jobs and saw that workers are

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Work logged] (BEAM-8151) Allow the Python SDK to use many many threads

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

[jira] [Work logged] (BEAM-8666) Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811

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

[jira] [Commented] (BEAM-8652) test_streaming_pipeline_returns_expected_user_metrics_fnapi_it test flaky

[ https://issues.apache.org/jira/browse/BEAM-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974657#comment-16974657 ] Yichi Zhang commented on BEAM-8652: --- CC: [~tvalentyn] >

[jira] [Work logged] (BEAM-8457) Instrument Dataflow jobs that are launched from Notebooks

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

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

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

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

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

[jira] [Work logged] (BEAM-8655) Strengthen trigger transcript tests

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

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

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

[jira] [Commented] (BEAM-8654) [Java] beam_Dependency_Check's not getting correct report from Gradle dependencyUpdates

[ https://issues.apache.org/jira/browse/BEAM-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974641#comment-16974641 ] Tomo Suzuki commented on BEAM-8654: --- Excluding configuration with {code:java}

[jira] [Commented] (BEAM-8650) org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert fails

[ https://issues.apache.org/jira/browse/BEAM-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974640#comment-16974640 ] Gleb Kanterov commented on BEAM-8650: - [~suztomo] it's possible to debug by adding breakpoint at

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

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

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

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

[jira] [Work logged] (BEAM-8664) [SQL] MongoDb should use project push-down

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

[jira] [Work logged] (BEAM-8664) [SQL] MongoDb should use project push-down

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

[jira] [Commented] (BEAM-8650) org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert fails

[ https://issues.apache.org/jira/browse/BEAM-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974627#comment-16974627 ] Tomo Suzuki commented on BEAM-8650: --- I attached two log files from the container. [~kanterov], I

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

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

[jira] [Updated] (BEAM-8650) org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert fails

[ https://issues.apache.org/jira/browse/BEAM-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomo Suzuki updated BEAM-8650: -- Attachment: clickhouse-server.log clickhouse-server.err.log >

[jira] [Resolved] (BEAM-8649) Eat stderr from subprocess in _get_default_gcp_region

[ https://issues.apache.org/jira/browse/BEAM-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-8649. --- Fix Version/s: Not applicable Resolution: Fixed > Eat stderr from subprocess in

[jira] [Commented] (BEAM-8650) org.apache.beam.sdk.io.clickhouse.AtomicInsertTest.testIdempotentInsert fails

[ https://issues.apache.org/jira/browse/BEAM-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974618#comment-16974618 ] Gleb Kanterov commented on BEAM-8650: - [~suztomo] network object in testcontainers is used to

[jira] [Comment Edited] (BEAM-8654) [Java] beam_Dependency_Check's not getting correct report from Gradle dependencyUpdates

[ https://issues.apache.org/jira/browse/BEAM-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974590#comment-16974590 ] Tomo Suzuki edited comment on BEAM-8654 at 11/14/19 9:26 PM: - It's

[jira] [Work logged] (BEAM-8666) Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811

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

[jira] [Work logged] (BEAM-8624) Implement FnService for status api in Dataflow runner

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

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Commented] (BEAM-8654) [Java] beam_Dependency_Check's not getting correct report from Gradle dependencyUpdates

[ https://issues.apache.org/jira/browse/BEAM-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974590#comment-16974590 ] Tomo Suzuki commented on BEAM-8654: --- It's BeamModulePlugin's {noformat}

[jira] [Work logged] (BEAM-8661) Move the Python codebase to have a logger hierarchy to ease debugging, and customize logging

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

[jira] [Work logged] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK

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

[jira] [Created] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK

Robert Bradshaw created BEAM-8667: - Summary: Data channel should to avoid unlimited buffering in Python SDK Key: BEAM-8667 URL: https://issues.apache.org/jira/browse/BEAM-8667 Project: Beam

[jira] [Work logged] (BEAM-8666) Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811

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

[jira] [Work logged] (BEAM-8402) Create a class hierarchy to represent environments

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

[jira] [Work logged] (BEAM-8666) Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811

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

[jira] [Work logged] (BEAM-8666) Remove dependency between DataflowRunner and PortableRunner introduced by PR#9811

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

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

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

[jira] [Work logged] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization

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

[jira] [Work logged] (BEAM-8598) TestStream broken across multiple stages in Flink

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

  1   2   >