Ankur Goenka created BEAM-5194:
--
Summary: Pipeline options with multi value are not deserialized
correctly from map
Key: BEAM-5194
URL: https://issues.apache.org/jira/browse/BEAM-5194
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-5194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka reassigned BEAM-5194:
--
Assignee: Ankur Goenka (was: Ahmet Altay)
> Pipeline options with multi va
[
https://issues.apache.org/jira/browse/BEAM-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589137#comment-16589137
]
Ankur Goenka edited comment on BEAM-5156 at 8/22/18 5:17 PM:
-
Check the thread
[
https://issues.apache.org/jira/browse/BEAM-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589137#comment-16589137
]
Ankur Goenka commented on BEAM-5156:
Check the thread
[https://lists.apache.org/thread.html
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
[
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
[
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/BEAM-5308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604840#comment-16604840
]
Ankur Goenka commented on BEAM-5308:
I agree, the bug is setting the port range.
> JobBundleFact
[
https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604833#comment-16604833
]
Ankur Goenka commented on BEAM-5283:
The root cause seems to be related to permission.
:beam-sdks
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
[
https://issues.apache.org/jira/browse/BEAM-3676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16597133#comment-16597133
]
Ankur Goenka commented on BEAM-3676:
[~axelmagn] is there any thing left on this jira
[
https://issues.apache.org/jira/browse/BEAM-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607583#comment-16607583
]
Ankur Goenka commented on BEAM-5337:
Tried running the failing gradle task ./gradlew :beam-runners
[
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
[
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
[
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
[
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
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
[
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
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
[
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
[
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
[
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
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
[
https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16611413#comment-16611413
]
Ankur Goenka commented on BEAM-5288:
It will be good to expose args separately in Process Environment
[
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
[
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
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
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640350#comment-16640350
]
Ankur Goenka commented on BEAM-5467:
The test pass consistently on local jenkins setup.
> Pyt
[
https://issues.apache.org/jira/browse/BEAM-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-3904.
Resolution: Fixed
Fix Version/s: 2.8.0
> Don't use UUID when worker_id is miss
[
https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka reassigned BEAM-4176:
--
Assignee: Ankur Goenka
> Java: Portable batch runner passes all ValidatesRunner te
[
https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637390#comment-16637390
]
Ankur Goenka commented on BEAM-4176:
!81VxNWtFtke.png!
We are able to run all the test cases
[
https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka updated BEAM-4176:
---
Attachment: 81VxNWtFtke.png
> Java: Portable batch runner passes all ValidatesRunner te
[
https://issues.apache.org/jira/browse/BEAM-5683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642484#comment-16642484
]
Ankur Goenka commented on BEAM-5683:
As mentioned earlier, the test case seems to be failing because
[
https://issues.apache.org/jira/browse/BEAM-5683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642450#comment-16642450
]
Ankur Goenka commented on BEAM-5683:
Looking at it.
> [beam_PostCommit_Py_VR_Dataf
Ankur Goenka created BEAM-5697:
--
Summary: Support parsing legacy options in FnHaness
Key: BEAM-5697
URL: https://issues.apache.org/jira/browse/BEAM-5697
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636285#comment-16636285
]
Ankur Goenka commented on BEAM-5187:
This seems to be done. Shall we close it?
> Cre
[
https://issues.apache.org/jira/browse/BEAM-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-4826.
Resolution: Fixed
Fix Version/s: 2.8.0
> Flink runner sends bad flatten to
[
https://issues.apache.org/jira/browse/BEAM-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka updated BEAM-5090:
---
Labels: newbie (was: )
> Use topological sort during ProcessBundle in Java SDKHarn
[
https://issues.apache.org/jira/browse/BEAM-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5022.
Resolution: Fixed
Fix Version/s: 2.8.0
> Move beam-sdks-java-fn-execut
[
https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5288.
Resolution: Fixed
Fix Version/s: 2.8.0
> Modify Environment to support non-dockerized
[
https://issues.apache.org/jira/browse/BEAM-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-2769.
Resolution: Fixed
Fix Version/s: 2.8.0
> Java SDK support for submitting a Portable Pipel
[
https://issues.apache.org/jira/browse/BEAM-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636280#comment-16636280
]
Ankur Goenka commented on BEAM-2769:
yes. We can submit portable pipelines now.
> Java SDK supp
[
https://issues.apache.org/jira/browse/BEAM-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5190.
Resolution: Fixed
Fix Version/s: 2.8.0
> Python pipeline options are not picked correc
[
https://issues.apache.org/jira/browse/BEAM-5194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5194.
Resolution: Fixed
Fix Version/s: 2.8.0
> Pipeline options with multi va
[
https://issues.apache.org/jira/browse/BEAM-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5697.
Resolution: Fixed
Fix Version/s: 2.8.0
> Support parsing legacy options in FnHan
Ankur Goenka created BEAM-5708:
--
Summary: Support caching of SDKHarness environments in flink
Key: BEAM-5708
URL: https://issues.apache.org/jira/browse/BEAM-5708
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-5683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645718#comment-16645718
]
Ankur Goenka commented on BEAM-5683:
I agree.
Shall we expose the pip logs?
I think exposing when
[
https://issues.apache.org/jira/browse/BEAM-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka reassigned BEAM-2594:
--
Assignee: Ankur Goenka
> Python shim for submitting to a JobServ
[
https://issues.apache.org/jira/browse/BEAM-5683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645730#comment-16645730
]
Ankur Goenka commented on BEAM-5683:
check_output does that by default
[
https://issues.apache.org/jira/browse/BEAM-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-2594.
Resolution: Fixed
Fix Version/s: 2.8.0
> Python shim for submitting to a JobServ
[
https://issues.apache.org/jira/browse/BEAM-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16645738#comment-16645738
]
Ankur Goenka commented on BEAM-2594:
This PR splits the ULR and make it possible to submit jobs to any
[
https://issues.apache.org/jira/browse/BEAM-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka updated BEAM-5433:
---
Issue Type: Task (was: Test)
> Cleanup Environment.url from beam_runner_api.pr
Ankur Goenka created BEAM-5433:
--
Summary: Cleanup Environment.url from beam_runner_api.proto
Key: BEAM-5433
URL: https://issues.apache.org/jira/browse/BEAM-5433
Project: Beam
Issue Type: Test
[
https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631002#comment-16631002
]
Ankur Goenka commented on BEAM-5467:
Anecdotally, tasks are failing because of segfault with following
[
https://issues.apache.org/jira/browse/BEAM-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631049#comment-16631049
]
Ankur Goenka commented on BEAM-5467:
I verified that they get executed sequentially so that should
[
https://issues.apache.org/jira/browse/BEAM-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5219.
Resolution: Fixed
Fix Version/s: 2.8.0
> Expose OutboundMessage in PubSub cli
[
https://issues.apache.org/jira/browse/BEAM-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ankur Goenka resolved BEAM-5262.
Resolution: Fixed
Fix Version/s: 2.8.0
> JobState support for Reference Run
[
https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16618330#comment-16618330
]
Ankur Goenka commented on BEAM-5396:
Thanks for the reference link. Its very relevant.
This feature
[
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 Te
[
https://issues.apache.org/jira/browse/BEAM-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614179#comment-16614179
]
Ankur Goenka commented on BEAM-5283:
Reference bug [https://github.com/pypa/virtualenv/issues/997
[
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 Te
[
https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614240#comment-16614240
]
Ankur Goenka commented on BEAM-5288:
We are thinking of removing the args as of now to avoid any
[
https://issues.apache.org/jira/browse/BEAM-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16618442#comment-16618442
]
Ankur Goenka commented on BEAM-5396:
Makes sense. Its a runner specific functionality so its a good
301 - 380 of 380 matches
Mail list logo
