[jira] [Created] (BEAM-5464) Portable beam hangs while running TFX preprocessing step on a distributed cluster

Axel Magnuson created BEAM-5464: --- Summary: Portable beam hangs while running TFX preprocessing step on a distributed cluster Key: BEAM-5464 URL: https://issues.apache.org/jira/browse/BEAM-5464 Project:

[jira] [Created] (BEAM-5463) Artifact staging service cannot write to HDFS

Axel Magnuson created BEAM-5463: --- Summary: Artifact staging service cannot write to HDFS Key: BEAM-5463 URL: https://issues.apache.org/jira/browse/BEAM-5463 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-5454) Improve Beam Fn API Artifact Staging Service Error Handling

Axel Magnuson created BEAM-5454: --- Summary: Improve Beam Fn API Artifact Staging Service Error Handling Key: BEAM-5454 URL: https://issues.apache.org/jira/browse/BEAM-5454 Project: Beam Issue

[jira] [Closed] (BEAM-3673) FlinkRunner: Harness manager for connecting operators to SDK Harnesses

[ https://issues.apache.org/jira/browse/BEAM-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson closed BEAM-3673. --- Resolution: Fixed Fix Version/s: 2.6.0 This was fixed a long time ago but never got closed. 

[jira] [Commented] (BEAM-3672) FlinkRunner: Implement an Artifact service using the Flink DistributedCache

[ https://issues.apache.org/jira/browse/BEAM-3672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588320#comment-16588320 ] Axel Magnuson commented on BEAM-3672: - Deprioritizing and unassigning this since there exists a viable

[jira] [Assigned] (BEAM-3672) FlinkRunner: Implement an Artifact service using the Flink DistributedCache

[ https://issues.apache.org/jira/browse/BEAM-3672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson reassigned BEAM-3672: --- Assignee: Aljoscha Krettek (was: Axel Magnuson) > FlinkRunner: Implement an Artifact

[jira] [Updated] (BEAM-3672) FlinkRunner: Implement an Artifact service using the Flink DistributedCache

[ https://issues.apache.org/jira/browse/BEAM-3672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson updated BEAM-3672: Priority: Minor (was: Major) > FlinkRunner: Implement an Artifact service using the Flink

[jira] [Created] (BEAM-4519) Artifact Retrieval Service Protocol should be able to serve multiple Manifests.

Axel Magnuson created BEAM-4519: --- Summary: Artifact Retrieval Service Protocol should be able to serve multiple Manifests. Key: BEAM-4519 URL: https://issues.apache.org/jira/browse/BEAM-4519 Project:

[jira] [Created] (BEAM-4491) DockerJobBundleFactory's ProvisionInfo is empty.

Axel Magnuson created BEAM-4491: --- Summary: DockerJobBundleFactory's ProvisionInfo is empty. Key: BEAM-4491 URL: https://issues.apache.org/jira/browse/BEAM-4491 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

Axel Magnuson created BEAM-4267: --- Summary: Implement a reusable library that can run an ExecutableStage with a given Environment Key: BEAM-4267 URL: https://issues.apache.org/jira/browse/BEAM-4267

[jira] [Comment Edited] (BEAM-3327) Add abstractions to manage Environment Instance lifecycles.

[ https://issues.apache.org/jira/browse/BEAM-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466495#comment-16466495 ] Axel Magnuson edited comment on BEAM-3327 at 5/7/18 9:32 PM: - Fixed by: 

[jira] [Resolved] (BEAM-3327) Add abstractions to manage Environment Instance lifecycles.

[ https://issues.apache.org/jira/browse/BEAM-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson resolved BEAM-3327. - Resolution: Fixed Fix Version/s: Not applicable Fixed by: [[BEAM-3327] Harness Manager

[jira] [Created] (BEAM-4095) Add abstractions for runners to provide artifacts to ArtifactRetrievalService

Axel Magnuson created BEAM-4095: --- Summary: Add abstractions for runners to provide artifacts to ArtifactRetrievalService Key: BEAM-4095 URL: https://issues.apache.org/jira/browse/BEAM-4095 Project:

[jira] [Created] (BEAM-3977) Member classes of SdkHarnessClient should have their own files.

Axel Magnuson created BEAM-3977: --- Summary: Member classes of SdkHarnessClient should have their own files. Key: BEAM-3977 URL: https://issues.apache.org/jira/browse/BEAM-3977 Project: Beam

[jira] [Resolved] (BEAM-3976) SdkHarnessClient is thread-safe

[ https://issues.apache.org/jira/browse/BEAM-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson resolved BEAM-3976. - Resolution: Not A Problem Fix Version/s: Not applicable > SdkHarnessClient is thread-safe >

[jira] [Commented] (BEAM-3976) SdkHarnessClient is thread-safe

[ https://issues.apache.org/jira/browse/BEAM-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16420943#comment-16420943 ] Axel Magnuson commented on BEAM-3976: - After investigating and discussing with Thomas Groh, this has

[jira] [Created] (BEAM-3882) Make StateRequestHandler::accept interface idiomatic.

Axel Magnuson created BEAM-3882: --- Summary: Make StateRequestHandler::accept interface idiomatic. Key: BEAM-3882 URL: https://issues.apache.org/jira/browse/BEAM-3882 Project: Beam Issue Type:

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

[ https://issues.apache.org/jira/browse/BEAM-3676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Magnuson reassigned BEAM-3676: --- Assignee: Axel Magnuson (was: Aljoscha Krettek) > FlinkRunner: Portable state service >

[jira] [Created] (BEAM-3805) Python ULR Harness submits null pipeline_options field in PrepareJobRequest

Axel Magnuson created BEAM-3805: --- Summary: Python ULR Harness submits null pipeline_options field in PrepareJobRequest Key: BEAM-3805 URL: https://issues.apache.org/jira/browse/BEAM-3805 Project: Beam

[jira] [Commented] (BEAM-3672) FlinkRunner: Implement an Artifact service using the Flink DistributedCache

[ https://issues.apache.org/jira/browse/BEAM-3672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386828#comment-16386828 ] Axel Magnuson commented on BEAM-3672: - Although this is mostly implemented, the current artifact