[jira] [Created] (BEAM-5022) Move beam-sdks-java-fn-execution#createPortableValidatesRunnerTask to BeamGradlePlugin

Ankur Goenka created BEAM-5022: -- Summary: Move beam-sdks-java-fn-execution#createPortableValidatesRunnerTask to BeamGradlePlugin Key: BEAM-5022 URL: https://issues.apache.org/jira/browse/BEAM-5022

[jira] [Assigned] (BEAM-4834) Validate cycles in org.apache.beam.runners.core.construction.graph.Network before doing topological sort

[ https://issues.apache.org/jira/browse/BEAM-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-4834: -- Assignee: Ankur Goenka (was: Kenneth Knowles) > Validate cyc

[jira] [Created] (BEAM-4834) Validate cycles in org.apache.beam.runners.core.construction.graph.Network before doing topological sort

Ankur Goenka created BEAM-4834: -- Summary: Validate cycles in org.apache.beam.runners.core.construction.graph.Network before doing topological sort Key: BEAM-4834 URL: https://issues.apache.org/jira/browse/BEAM-4834

[jira] [Created] (BEAM-4810) Flaky test BeamFileSystemArtifactServicesTest

Ankur Goenka created BEAM-4810: -- Summary: Flaky test BeamFileSystemArtifactServicesTest Key: BEAM-4810 URL: https://issues.apache.org/jira/browse/BEAM-4810 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-4787) Ignore genrated vendored files for python container

Ankur Goenka created BEAM-4787: -- Summary: Ignore genrated vendored files for python container Key: BEAM-4787 URL: https://issues.apache.org/jira/browse/BEAM-4787 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-4784) Python SDK harness container build fails

[ https://issues.apache.org/jira/browse/BEAM-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543769#comment-16543769 ] Ankur Goenka commented on BEAM-4784: I am not able to reproduce it here is a working build on master

[jira] [Commented] (BEAM-4773) Flink job fails if image pull fails.

[ https://issues.apache.org/jira/browse/BEAM-4773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542053#comment-16542053 ] Ankur Goenka commented on BEAM-4773: Fix in PR [https://github.com/apache/beam/pull/5933] > Flink

[jira] [Created] (BEAM-4773) Flink job fails if image pull fails.

Ankur Goenka created BEAM-4773: -- Summary: Flink job fails if image pull fails. Key: BEAM-4773 URL: https://issues.apache.org/jira/browse/BEAM-4773 Project: Beam Issue Type: Bug

[jira] [Assigned] (BEAM-4130) Portable Flink runner JobService entry point in a Docker container

[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-4130: -- Assignee: Ankur Goenka > Portable Flink runner JobService entry point in a Docker contai

[jira] [Resolved] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-4023. Resolution: Fixed Fix Version/s: Not applicable > Log warning for missing worker

[jira] [Resolved] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-3418. Resolution: Fixed Fix Version/s: 2.6.0 > Python Fnapi - Support Multiple SDK work

[jira] [Commented] (BEAM-2930) Flink support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526403#comment-16526403 ] Ankur Goenka commented on BEAM-2930: [~bsidhom] I think this is taken care in the portable flink

[jira] [Assigned] (BEAM-2930) Flink support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-2930: -- Assignee: Ben Sidhom > Flink support for portable side in

[jira] [Assigned] (BEAM-2930) Flink support for portable side input

[ https://issues.apache.org/jira/browse/BEAM-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-2930: -- Assignee: (was: Ben Sidhom) > Flink support for portable side in

[jira] [Assigned] (BEAM-4067) Java: FlinkPortableTestRunner: runs portably via self-started local Flink

[ https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-4067: -- Assignee: Ankur Goenka > Java: FlinkPortableTestRunner: runs portably via self-started lo

[jira] [Resolved] (BEAM-4290) ArtifactStagingService that stages to a distributed filesystem

[ https://issues.apache.org/jira/browse/BEAM-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-4290. Resolution: Fixed Fix Version/s: 2.6.0 > ArtifactStagingService that stages to a distribu

[jira] [Commented] (BEAM-4448) --sdk_location seems to be a required parameter now in the Apache Beam Python SDK when using the DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-4448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505250#comment-16505250 ] Ankur Goenka commented on BEAM-4448: This was fixed internally. [~lcwik] Do we need to keep this bug

[jira] [Resolved] (BEAM-3883) Python SDK stages artifacts when talking to job server

[ https://issues.apache.org/jira/browse/BEAM-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-3883. Resolution: Fixed Fix Version/s: 2.5.0 > Python SDK stages artifacts when talking to

[jira] [Created] (BEAM-4289) How to express "Job Update" in portable Beam

Ankur Goenka created BEAM-4289: -- Summary: How to express "Job Update" in portable Beam Key: BEAM-4289 URL: https://issues.apache.org/jira/browse/BEAM-4289 Project: Beam Issue Type: I

[jira] [Commented] (BEAM-2594) Python shim for submitting to the ULR

[ https://issues.apache.org/jira/browse/BEAM-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467864#comment-16467864 ] Ankur Goenka commented on BEAM-2594: [~jkff] [~bsidhom] Based on the current state of Python SDK

[jira] [Commented] (BEAM-4219) Make Portable ULR use workerId in GRPC channel

[ https://issues.apache.org/jira/browse/BEAM-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460003#comment-16460003 ] Ankur Goenka commented on BEAM-4219: cc: [~lcwik] > Make Portable ULR use workerId in GRPC chan

[jira] [Created] (BEAM-4219) Make Portable ULR use workerId in GRPC channel

Ankur Goenka created BEAM-4219: -- Summary: Make Portable ULR use workerId in GRPC channel Key: BEAM-4219 URL: https://issues.apache.org/jira/browse/BEAM-4219 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-4149) Java SDK Harness should populate worker id in control plane headers

[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459279#comment-16459279 ] Ankur Goenka commented on BEAM-4149: In reference to  [https://github.com/apache/beam/blob

[jira] [Commented] (BEAM-4149) Java SDK Harness should populate worker id in control plane headers

[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459046#comment-16459046 ] Ankur Goenka commented on BEAM-4149: Is the workaround good enough or should we fix it now? > Java

[jira] [Assigned] (BEAM-3883) Python SDK stages artifacts when talking to job server

[ https://issues.apache.org/jira/browse/BEAM-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-3883: -- Assignee: Ankur Goenka (was: Ahmet Altay) > Python SDK stages artifacts when talking to

[jira] [Updated] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-4023: --- Description: We should log warning for missing worker id when connecting the GRPC channel. (was: We

[jira] [Assigned] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-4023: -- Assignee: Ankur Goenka (was: Henning Rohde) > Log warning for missing worker

[jira] [Created] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

Ankur Goenka created BEAM-4023: -- Summary: Log warning for missing worker id in FnApiControlClientPoolService Key: BEAM-4023 URL: https://issues.apache.org/jira/browse/BEAM-4023 Project: Beam

[jira] [Updated] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-4023: --- Description: We should  (was: When running the maven build in a machine without the valid auth

[jira] [Updated] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

[ https://issues.apache.org/jira/browse/BEAM-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-4023: --- Priority: Major (was: Blocker) > Log warning for missing worker id in FnApiControlClientPoolServ

[jira] [Updated] (BEAM-4022) beam_PreCommit_Python_MavenInstall failing with cython error

[ https://issues.apache.org/jira/browse/BEAM-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-4022: --- Description: beam_PreCommit_Python_MavenInstall is failing with (link to failing job [https

[jira] [Assigned] (BEAM-4022) beam_PreCommit_Python_MavenInstall failing with cython error

[ https://issues.apache.org/jira/browse/BEAM-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-4022: -- Assignee: Ankur Goenka (was: Udi Meiri) > beam_PreCommit_Python_MavenInstall fail

[jira] [Created] (BEAM-4022) beam_PreCommit_Python_MavenInstall failing with cython error

Ankur Goenka created BEAM-4022: -- Summary: beam_PreCommit_Python_MavenInstall failing with cython error Key: BEAM-4022 URL: https://issues.apache.org/jira/browse/BEAM-4022 Project: Beam Issue

[jira] [Created] (BEAM-3996) Invalid test util ResourceIdTester#ValidateFailureResolvingIds

Ankur Goenka created BEAM-3996: -- Summary: Invalid test util ResourceIdTester#ValidateFailureResolvingIds Key: BEAM-3996 URL: https://issues.apache.org/jira/browse/BEAM-3996 Project: Beam Issue

[jira] [Assigned] (BEAM-3996) Invalid test util ResourceIdTester#ValidateFailureResolvingIds

[ https://issues.apache.org/jira/browse/BEAM-3996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-3996: -- Assignee: Thomas Groh (was: Kenneth Knowles) > Invalid test util ResourceIdTes

[jira] [Created] (BEAM-3904) Don't use UUID when worker_id is missing

Ankur Goenka created BEAM-3904: -- Summary: Don't use UUID when worker_id is missing Key: BEAM-3904 URL: https://issues.apache.org/jira/browse/BEAM-3904 Project: Beam Issue Type: Task

[jira] [Commented] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338151#comment-16338151 ] Ankur Goenka commented on BEAM-3411: [https://builds.apache.org/job/beam_PostCommit_Python_Verify

[jira] [Resolved] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-3411. Resolution: Fixed Fix Version/s: 2.3.0 > T

[jira] [Resolved] (BEAM-3486) Progress reporting for python sdk fix

[ https://issues.apache.org/jira/browse/BEAM-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-3486. Resolution: Fixed > Progress reporting for python sdk

[jira] [Updated] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3418: --- Description: Support multiple python SDK process on a VM to fully utilize a machine. Each SDK Process

[jira] [Updated] (BEAM-3418) Python Fnapi - Support Multiple SDK workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3418: --- Summary: Python Fnapi - Support Multiple SDK workers on a single VM (was: Python Fnapi - Support

[jira] [Updated] (BEAM-3418) Python Fnapi - Support Multiple workers on a single VM

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3418: --- Summary: Python Fnapi - Support Multiple workers on a single VM (was: Python Fnapi - Multiprocess

[jira] [Updated] (BEAM-3486) Progress reporting for python sdk fix

[ https://issues.apache.org/jira/browse/BEAM-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3486: --- Labels: (was: newbie) > Progress reporting for python sdk

[jira] [Updated] (BEAM-3486) Progress reporting for python sdk fix

[ https://issues.apache.org/jira/browse/BEAM-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3486: --- Description: Python sdk was not reporting progress correctly (was: [sdk_worker|https://github.com

[jira] [Updated] (BEAM-3486) Progress reporting for python sdk fix

[ https://issues.apache.org/jira/browse/BEAM-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3486: --- Issue Type: Bug (was: Improvement) > Progress reporting for python sdk

[jira] [Closed] (BEAM-3135) Adding futures dependency to beam python SDK

[ https://issues.apache.org/jira/browse/BEAM-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka closed BEAM-3135. -- Resolution: Fixed Fix Version/s: 2.3.0 > Adding futures dependency to beam python

[jira] [Closed] (BEAM-3239) Enable debug server for python sdk workers

[ https://issues.apache.org/jira/browse/BEAM-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka closed BEAM-3239. -- Resolution: Fixed Fix Version/s: 2.3.0 > Enable debug server for python sdk work

[jira] [Closed] (BEAM-3155) Python SDKHarness does not use separate thread for progress reporting

[ https://issues.apache.org/jira/browse/BEAM-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka closed BEAM-3155. -- Resolution: Fixed Fix Version/s: 2.3.0 > Python SDKHarness does not use separate thr

[jira] [Updated] (BEAM-3418) Python Fnapi - Multiprocess worker

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3418: --- Labels: performance portability (was: ) > Python Fnapi - Multiprocess wor

[jira] [Closed] (BEAM-3389) Clean receive queue in dataplane

[ https://issues.apache.org/jira/browse/BEAM-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka closed BEAM-3389. -- Resolution: Fixed Fix Version/s: 2.3.0 > Clean receive queue in datapl

[jira] [Comment Edited] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314279#comment-16314279 ] Ankur Goenka edited comment on BEAM-3411 at 1/6/18 1:48 AM: We missed catching

[jira] [Comment Edited] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314279#comment-16314279 ] Ankur Goenka edited comment on BEAM-3411 at 1/6/18 1:47 AM: We missed catching

[jira] [Commented] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314279#comment-16314279 ] Ankur Goenka commented on BEAM-3411: We missed catching a case where progress report

[jira] [Updated] (BEAM-3418) Python Fnapi - Multiprocess worker

[ https://issues.apache.org/jira/browse/BEAM-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3418: --- Issue Type: Improvement (was: Bug) > Python Fnapi - Multiprocess wor

[jira] [Created] (BEAM-3418) Python Fnapi - Multiprocess worker

Ankur Goenka created BEAM-3418: -- Summary: Python Fnapi - Multiprocess worker Key: BEAM-3418 URL: https://issues.apache.org/jira/browse/BEAM-3418 Project: Beam Issue Type: Bug

[jira] [Assigned] (BEAM-3389) Clean receive queue in dataplane

[ https://issues.apache.org/jira/browse/BEAM-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-3389: -- Assignee: Ankur Goenka (was: Ahmet Altay) > Clean receive queue in datapl

[jira] [Created] (BEAM-3389) Clean receive queue in dataplane

Ankur Goenka created BEAM-3389: -- Summary: Clean receive queue in dataplane Key: BEAM-3389 URL: https://issues.apache.org/jira/browse/BEAM-3389 Project: Beam Issue Type: Bug Components

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- External issue URL: https://docs.google.com/document/d/1mHFaNgHA71RVGLVNrGrHIlWHgJb4tKCJ2qQzS13REY8

[jira] [Created] (BEAM-3260) Honor Python SDK log level while logging

Ankur Goenka created BEAM-3260: -- Summary: Honor Python SDK log level while logging Key: BEAM-3260 URL: https://issues.apache.org/jira/browse/BEAM-3260 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-3239) Enable debug server for python sdk workers

Ankur Goenka created BEAM-3239: -- Summary: Enable debug server for python sdk workers Key: BEAM-3239 URL: https://issues.apache.org/jira/browse/BEAM-3239 Project: Beam Issue Type: Improvement

[jira] [Comment Edited] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:51 AM: --- The jenkins

[jira] [Comment Edited] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:50 AM: --- The jenkins

[jira] [Comment Edited] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:50 AM: --- The jenkins

[jira] [Comment Edited] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:50 AM: --- The jenkins

[jira] [Commented] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261776#comment-16261776 ] Ankur Goenka commented on BEAM-3230: The jenkins build timeout. Doubling the timeout to 20min

[jira] [Assigned] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-3230: -- Assignee: Ankur Goenka (was: Ahmet Altay) > beam_PerformanceTests_Python is fail

[jira] [Commented] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261688#comment-16261688 ] Ankur Goenka commented on BEAM-3230: The default worker container image for fnapi seems

[jira] [Commented] (BEAM-3230) beam_PerformanceTests_Python is failing

[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261211#comment-16261211 ] Ankur Goenka commented on BEAM-3230: Initial skimming of the logs reveal unknown option

[jira] [Created] (BEAM-3230) beam_PerformanceTests_Python is failing

Ankur Goenka created BEAM-3230: -- Summary: beam_PerformanceTests_Python is failing Key: BEAM-3230 URL: https://issues.apache.org/jira/browse/BEAM-3230 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Component/s: (was: sdk-java-harness) sdk-py-harness > Python Fnapi - Wor

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Description: Beam Python SDK is couple of magnitude slower than Java SDK when it comes to stream

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Issue Type: Improvement (was: Bug) > Python Fnapi - Worker spee

[jira] [Assigned] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-3189: -- Assignee: Ankur Goenka (was: Valentyn Tymofieiev) > Python Fnapi - Worker spee

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Labels: performance portability (was: portability) > Python Fnapi - Worker spee

[jira] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Affects Version/s: (was: 2.2.0) 2.3.0 > Python Fnapi - Worker spee

[jira] [Created] (BEAM-3189) Python Fnapi - Worker speedup

Ankur Goenka created BEAM-3189: -- Summary: Python Fnapi - Worker speedup Key: BEAM-3189 URL: https://issues.apache.org/jira/browse/BEAM-3189 Project: Beam Issue Type: Bug Components

[jira] [Created] (BEAM-3155) Python SDKHarness does not use separate thread for progress reporting

Ankur Goenka created BEAM-3155: -- Summary: Python SDKHarness does not use separate thread for progress reporting Key: BEAM-3155 URL: https://issues.apache.org/jira/browse/BEAM-3155 Project: Beam

[jira] [Updated] (BEAM-3135) Adding futures dependency to beam python SDK

[ https://issues.apache.org/jira/browse/BEAM-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3135: --- Description: [sdk_worker|https://github.com/apache/beam/blob/a33c717dbb9b25485218b135a78b5cdb3f8239c9

[jira] [Created] (BEAM-3135) Adding futures dependency to beam python SDK

Ankur Goenka created BEAM-3135: -- Summary: Adding futures dependency to beam python SDK Key: BEAM-3135 URL: https://issues.apache.org/jira/browse/BEAM-3135 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-3075) Document getting started for python sdk developers

[ https://issues.apache.org/jira/browse/BEAM-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16231655#comment-16231655 ] Ankur Goenka commented on BEAM-3075: Hi [~altay] I can take a shot at it. > Document getting star

<    1   2   3   4