[beam] branch master updated: [BEAM-10060] Upgrading Python containers to beam-master-20200521

2020-05-21 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 393f1ba [BEAM-10060] Upgrading Python containers

[beam] branch master updated (970b36f -> e7ca038)

2020-06-17 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 970b36f Merge pull request #11943 from [BEAM-10209] Add without_defaults to Mean combiner in Python new 771e018

[beam] branch master updated: [BEAM-9707] Remove hardcoded unified harness image

2020-06-23 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 8825995 [BEAM-9707] Remove hardcoded unified

[beam] branch master updated (4688bc6 -> 6c95955)

2020-06-25 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 4688bc6 Merge pull request #12078 from ibzib/BEAM-10315 add 6c95955 [BEAM-10189] Add ReadModifyWriteState user

[beam] branch master updated (7ae4648 -> eaa41cc)

2020-06-25 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 7ae4648 Merge pull request #12072 from damgad/tmp_cleanup add eaa41cc Change time granularity to seconds in

[beam] branch master updated: Bump up advanceProcessingTime duration in ParDoTest

2020-08-18 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 37e914b Bump up advanceProcessingTime duration

[beam] branch master updated (f2959c3 -> 275b7c9)

2020-08-19 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from f2959c3 Merge pull request #12586: [BEAM-8019] Don't drop coders embedded in CombinePayload add 275b7c9

[beam] branch master updated (1a89550 -> de309d2)

2020-09-11 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 1a89550 Merge pull request #12798 [BEAM-10833] Fix type inference for BUILD_MAP. add de309d2 [BEAM-10876] Fix

[beam] branch master updated (04f5e12 -> e6b3cf1)

2020-09-30 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 04f5e12 [BEAM-9681] Add textio.Read lesson to Go SDK katas (#12941) add e6b3cf1 [BEAM-10200] Respect

[beam] branch master updated (04f5e12 -> e6b3cf1)

2020-09-30 Thread goenka
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 04f5e12 [BEAM-9681] Add textio.Read lesson to Go SDK katas (#12941) add e6b3cf1 [BEAM-10200] Respect

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

2018-04-30 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459046#comment-16459046 ] Ankur Goenka commented on BEAM-4149: Is the workaround good enough or should we fi

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

2018-04-30 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459279#comment-16459279 ] Ankur Goenka commented on BEAM-4149: In reference to  [https://github.com/apache/

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

2018-05-01 Thread Ankur Goenka (JIRA)
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-4219) Make Portable ULR use workerId in GRPC channel

2018-05-01 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460003#comment-16460003 ] Ankur Goenka commented on BEAM-4219: cc: [~lcwik] > Make Portable ULR use work

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

2018-05-08 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16467864#comment-16467864 ] Ankur Goenka commented on BEAM-2594: [~jkff] [~bsidhom] Based on the current stat

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

2018-04-03 Thread Ankur Goenka (JIRA)
[ 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-3996) Invalid test util ResourceIdTester#ValidateFailureResolvingIds

2018-04-03 Thread Ankur Goenka (JIRA)
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] [Created] (BEAM-4022) beam_PreCommit_Python_MavenInstall failing with cython error

2018-04-05 Thread Ankur Goenka (JIRA)
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] [Assigned] (BEAM-4022) beam_PreCommit_Python_MavenInstall failing with cython error

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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 failing w

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

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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] [Updated] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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] [Created] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

2018-04-05 Thread Ankur Goenka (JIRA)
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

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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] [Assigned] (BEAM-4023) Log warning for missing worker id in FnApiControlClientPoolService

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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 id

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

2018-04-05 Thread Ankur Goenka (JIRA)
[ 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] [Created] (BEAM-4289) How to express "Job Update" in portable Beam

2018-05-14 Thread Ankur Goenka (JIRA)
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] [Assigned] (BEAM-3883) Python SDK stages artifacts when talking to job server

2018-04-19 Thread Ankur Goenka (JIRA)
[ 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] [Resolved] (BEAM-4290) ArtifactStagingService that stages to a distributed filesystem

2018-06-13 Thread Ankur Goenka (JIRA)
[ 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] [Assigned] (BEAM-4067) Java: FlinkPortableTestRunner: runs portably via self-started local Flink

2018-06-14 Thread Ankur Goenka (JIRA)
[ 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] [Created] (BEAM-3418) Python Fnapi - Multiprocess worker

2018-01-05 Thread Ankur Goenka (JIRA)
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] [Updated] (BEAM-3418) Python Fnapi - Multiprocess worker

2018-01-05 Thread Ankur Goenka (JIRA)
[ 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] [Commented] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

2018-01-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16314279#comment-16314279 ] Ankur Goenka commented on BEAM-3411: We missed catching a case where progress re

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

2018-01-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16314279#comment-16314279 ] Ankur Goenka edited comment on BEAM-3411 at 1/6/18 1:47 AM:

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

2018-01-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16314279#comment-16314279 ] Ankur Goenka edited comment on BEAM-3411 at 1/6/18 1:48 AM:

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

2018-01-08 Thread Ankur Goenka (JIRA)
[ 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] [Updated] (BEAM-3418) Python Fnapi - Multiprocess worker

2018-01-08 Thread Ankur Goenka (JIRA)
[ 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-3239) Enable debug server for python sdk workers

2018-01-08 Thread Ankur Goenka (JIRA)
[ 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

2018-01-08 Thread Ankur Goenka (JIRA)
[ 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 thread

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

2018-01-08 Thread Ankur Goenka (JIRA)
[ 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] [Updated] (BEAM-3486) Progress reporting for python sdk fix

2018-01-16 Thread Ankur Goenka (JIRA)
[ 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] [Created] (BEAM-3486) Progress reporting for python sdk fix

2018-01-16 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-3486: -- Summary: Progress reporting for python sdk fix Key: BEAM-3486 URL: https://issues.apache.org/jira/browse/BEAM-3486 Project: Beam Issue Type: Improvement

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

2018-01-16 Thread Ankur Goenka (JIRA)
[ 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

2018-01-16 Thread Ankur Goenka (JIRA)
[ 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-3418) Python Fnapi - Support Multiple workers on a single VM

2018-01-22 Thread Ankur Goenka (JIRA)
[ 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-3418) Python Fnapi - Support Multiple SDK workers on a single VM

2018-01-22 Thread Ankur Goenka (JIRA)
[ 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 SDK workers on a single VM

2018-01-22 Thread Ankur Goenka (JIRA)
[ 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] [Resolved] (BEAM-3486) Progress reporting for python sdk fix

2018-01-24 Thread Ankur Goenka (JIRA)
[ 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] [Resolved] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

2018-01-24 Thread Ankur Goenka (JIRA)
[ 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] [Commented] (BEAM-3411) Test apache_beam.examples.wordcount_it_test.WordCountIT times out

2018-01-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338151#comment-16338151 ] Ankur Goenka commented on BEAM-3411: [https://builds.apache.org

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

2018-05-24 Thread Ankur Goenka (JIRA)
[ 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] [Commented] (BEAM-4448) --sdk_location seems to be a required parameter now in the Apache Beam Python SDK when using the DataflowRunner

2018-06-07 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16505250#comment-16505250 ] Ankur Goenka commented on BEAM-4448: This was fixed internally. [~lcwik] Do we

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

2018-03-21 Thread Ankur Goenka (JIRA)
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:

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

2017-11-14 Thread Ankur Goenka (JIRA)
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] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

2017-11-14 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-3189: --- Priority: Minor (was: Major) > Python Fnapi - Worker spee

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

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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] [Assigned] (BEAM-3189) Python Fnapi - Worker speedup

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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

2017-11-14 Thread Ankur Goenka (JIRA)
[ 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] [Created] (BEAM-3230) beam_PerformanceTests_Python is failing

2017-11-21 Thread Ankur Goenka (JIRA)
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] [Commented] (BEAM-3230) beam_PerformanceTests_Python is failing

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261211#comment-16261211 ] Ankur Goenka commented on BEAM-3230: Initial skimming of the logs reveal unk

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261688#comment-16261688 ] Ankur Goenka commented on BEAM-3230: The default worker container image for f

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ 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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261776#comment-16261776 ] Ankur Goenka commented on BEAM-3230: The jenkins build timeout. Doubling the tim

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:5

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:5

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:5

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

2017-11-21 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16261776#comment-16261776 ] Ankur Goenka edited comment on BEAM-3230 at 11/22/17 12:5

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

2017-11-22 Thread Ankur Goenka (JIRA)
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] [Created] (BEAM-3260) Honor Python SDK log level while logging

2017-11-27 Thread Ankur Goenka (JIRA)
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] [Updated] (BEAM-3189) Python Fnapi - Worker speedup

2017-12-05 Thread Ankur Goenka (JIRA)
[ 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-3389) Clean receive queue in dataplane

2017-12-21 Thread Ankur Goenka (JIRA)
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] [Assigned] (BEAM-3389) Clean receive queue in dataplane

2017-12-21 Thread Ankur Goenka (JIRA)
[ 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] [Commented] (BEAM-3075) Document getting started for python sdk developers

2017-10-31 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16231655#comment-16231655 ] Ankur Goenka commented on BEAM-3075: Hi [~altay] I can take a shot at it. > D

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

2017-11-01 Thread Ankur Goenka (JIRA)
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] [Updated] (BEAM-3135) Adding futures dependency to beam python SDK

2017-11-01 Thread Ankur Goenka (JIRA)
[ 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-3155) Python SDKHarness does not use separate thread for progress reporting

2017-11-07 Thread Ankur Goenka (JIRA)
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] [Commented] (BEAM-5180) Broken FileResultCoder via parseSchema change

2018-08-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591973#comment-16591973 ] Ankur Goenka commented on BEAM-5180: >From the java.net.URI docs, A hierarchi

[jira] [Comment Edited] (BEAM-5180) Broken FileResultCoder via parseSchema change

2018-08-25 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591973#comment-16591973 ] Ankur Goenka edited comment on BEAM-5180 at 8/25/18 10:0

[jira] [Commented] (BEAM-5180) Broken FileResultCoder via parseSchema change

2018-08-25 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592727#comment-16592727 ] Ankur Goenka commented on BEAM-5180: That's correct. HDFS file URIs in thi

[jira] [Created] (BEAM-5218) Add the portable test name to the pipeline name for easy debugging

2018-08-25 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5218: -- Summary: Add the portable test name to the pipeline name for easy debugging Key: BEAM-5218 URL: https://issues.apache.org/jira/browse/BEAM-5218 Project: Beam

[jira] [Assigned] (BEAM-5219) Expose OutboundMessage in PubSub client

2018-08-25 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-5219: -- Assignee: Ankur Goenka (was: Chamikara Jayalath) > Expose OutboundMessage in PubSub cli

[jira] [Created] (BEAM-5219) Expose OutboundMessage in PubSub client

2018-08-25 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5219: -- Summary: Expose OutboundMessage in PubSub client Key: BEAM-5219 URL: https://issues.apache.org/jira/browse/BEAM-5219 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-5262) JobState support for Reference Runner

2018-08-29 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5262: -- Summary: JobState support for Reference Runner Key: BEAM-5262 URL: https://issues.apache.org/jira/browse/BEAM-5262 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-3676) FlinkRunner: Portable state service

2018-08-30 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16597133#comment-16597133 ] Ankur Goenka commented on BEAM-3676: [~axelmagn] is there any thing left on this

[jira] [Created] (BEAM-5273) Local file system does not work as expected on Portability Framework with Docker

2018-08-30 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5273: -- Summary: Local file system does not work as expected on Portability Framework with Docker Key: BEAM-5273 URL: https://issues.apache.org/jira/browse/BEAM-5273 Project

[jira] [Created] (BEAM-5283) Enable Python Portable Flink PostCommit Tests to Jenkins

2018-08-31 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5283: -- Summary: Enable Python Portable Flink PostCommit Tests to Jenkins Key: BEAM-5283 URL: https://issues.apache.org/jira/browse/BEAM-5283 Project: Beam Issue Type

[jira] [Created] (BEAM-5284) Enable Java Portable Flink PostCommit Tests to Jenkins

2018-08-31 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5284: -- Summary: Enable Java Portable Flink PostCommit Tests to Jenkins Key: BEAM-5284 URL: https://issues.apache.org/jira/browse/BEAM-5284 Project: Beam Issue Type

[jira] [Commented] (BEAM-5308) JobBundleFactory BindException with FlinkRunner and remote cluster

2018-09-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604826#comment-16604826 ] Ankur Goenka commented on BEAM-5308: The port conflict seems to be related to c

[jira] [Commented] (BEAM-5283) Enable Python Portable Flink PostCommit Tests to Jenkins

2018-09-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604833#comment-16604833 ] Ankur Goenka commented on BEAM-5283: The root cause seems to be related to permis

[jira] [Commented] (BEAM-5308) JobBundleFactory BindException with FlinkRunner and remote cluster

2018-09-05 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604840#comment-16604840 ] Ankur Goenka commented on BEAM-5308: I agree, the bug is setting the port r

[jira] [Commented] (BEAM-5337) [beam_PostCommit_Java_GradleBuild][:beam-runners-flink_2.11:test][Flake] Build times out in beam-runners-flink target

2018-09-07 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607583#comment-16607583 ] Ankur Goenka commented on BEAM-5337: Tried running the failing gradle task ./gra

[jira] [Created] (BEAM-5369) Portable wordcount java broken because of create_view usage

2018-09-11 Thread Ankur Goenka (JIRA)
Ankur Goenka created BEAM-5369: -- Summary: Portable wordcount java broken because of create_view usage Key: BEAM-5369 URL: https://issues.apache.org/jira/browse/BEAM-5369 Project: Beam Issue

[jira] [Commented] (BEAM-5288) Modify Environment to support non-dockerized SDK harness deployments

2018-09-11 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611413#comment-16611413 ] Ankur Goenka commented on BEAM-5288: It will be good to expose args separatel

[jira] [Assigned] (BEAM-5283) Enable Python Portable Flink PostCommit Tests to Jenkins

2018-09-13 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka reassigned BEAM-5283: -- Assignee: Ankur Goenka (was: Jason Kuster) > Enable Python Portable Flink PostCommit Tests

[jira] [Resolved] (BEAM-5283) Enable Python Portable Flink PostCommit Tests to Jenkins

2018-09-13 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka resolved BEAM-5283. Resolution: Fixed Fix Version/s: 2.8.0 > Enable Python Portable Flink PostCommit Tests

[jira] [Commented] (BEAM-5283) Enable Python Portable Flink PostCommit Tests to Jenkins

2018-09-13 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16614179#comment-16614179 ] Ankur Goenka commented on BEAM-5283: Reference bug [https://github.com/

[jira] [Commented] (BEAM-5288) Modify Environment to support non-dockerized SDK harness deployments

2018-09-13 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16614240#comment-16614240 ] Ankur Goenka commented on BEAM-5288: We are thinking of removing the args as of

[jira] [Commented] (BEAM-5396) Flink portable runner savepoint / upgrade support

2018-09-17 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618330#comment-16618330 ] Ankur Goenka commented on BEAM-5396: Thanks for the reference link. Its very rele

<    1   2   3   4   >