[jira] [Updated] (BEAM-5267) Update Flink Runner to Flink 1.6.x

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5267: - Description: For the next release, the Flink version should be bumped. As changes for

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

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5284: - Component/s: runner-flink > Enable Java Portable Flink PostCommit Tests to Jenkins >

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

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602179#comment-16602179 ] Maximilian Michels edited comment on BEAM-5284 at 9/3/18 1:44 PM: -- +1 (I

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

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602179#comment-16602179 ] Maximilian Michels commented on BEAM-5284: -- +1 > Enable Java Portable Flink PostCommit Tests to

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

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5288: - Description: As of mailing discussions and BEAM-5187, it has become clear that we need to

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

2018-09-03 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5288: Summary: Modify Environment to support non-dockerized SDK harness deployments Key: BEAM-5288 URL: https://issues.apache.org/jira/browse/BEAM-5288 Project:

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

2018-09-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-5288: Assignee: (was: Kenneth Knowles) > Modify Environment to support

[jira] [Updated] (BEAM-5277) Python SDK wordcount fails due to side inputs in streaming mode

2018-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5277: - Description: After BEAM-5250 is fixed, the wordcount fails with: {noformat}

[jira] [Created] (BEAM-5277) Python SDK wordcount fails due to side inputs in streaming mode

2018-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5277: Summary: Python SDK wordcount fails due to side inputs in streaming mode Key: BEAM-5277 URL: https://issues.apache.org/jira/browse/BEAM-5277 Project: Beam

[jira] [Assigned] (BEAM-5250) Python Wordcount fails with Flink portable streaming

2018-08-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-5250: Assignee: Maximilian Michels > Python Wordcount fails with Flink portable

[jira] [Updated] (BEAM-5267) Update Flink Runner to Flink 1.6.x

2018-08-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5267: - Priority: Major (was: Minor) > Update Flink Runner to Flink 1.6.x >

[jira] [Updated] (BEAM-5267) Update Flink Runner to Flink 1.6.x

2018-08-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5267: - Fix Version/s: 2.8.0 > Update Flink Runner to Flink 1.6.x >

[jira] [Updated] (BEAM-5267) Update Flink Runner to Flink 1.6.x

2018-08-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-5267: - Affects Version/s: (was: 2.8.0) > Update Flink Runner to Flink 1.6.x >

[jira] [Created] (BEAM-5267) Update Flink Runner to Flink 1.6.x

2018-08-30 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5267: Summary: Update Flink Runner to Flink 1.6.x Key: BEAM-5267 URL: https://issues.apache.org/jira/browse/BEAM-5267 Project: Beam Issue Type:

[jira] [Resolved] (BEAM-5211) Flink Streaming ExecutableStage operator chain blocks grpc receiver threads

2018-08-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-5211. -- Resolution: Fixed Should be fixed now via https://github.com/apache/beam/pull/6271 >

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

2018-08-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16583602#comment-16583602 ] Maximilian Michels edited comment on BEAM-4130 at 8/21/18 1:02 PM: --- For

[jira] [Created] (BEAM-5187) Create an InProcessJobBundleFactory for non-dockerized SDK harness

2018-08-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5187: Summary: Create an InProcessJobBundleFactory for non-dockerized SDK harness Key: BEAM-5187 URL: https://issues.apache.org/jira/browse/BEAM-5187 Project: Beam

[jira] [Created] (BEAM-5174) Website feed is broken due to license header

2018-08-20 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5174: Summary: Website feed is broken due to license header Key: BEAM-5174 URL: https://issues.apache.org/jira/browse/BEAM-5174 Project: Beam Issue Type:

[jira] [Created] (BEAM-5162) Document Metrics API for users

2018-08-17 Thread Maximilian Michels (JIRA)
Maximilian Michels created BEAM-5162: Summary: Document Metrics API for users Key: BEAM-5162 URL: https://issues.apache.org/jira/browse/BEAM-5162 Project: Beam Issue Type: Task

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

2018-08-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16583602#comment-16583602 ] Maximilian Michels commented on BEAM-4130: -- For local runs, where Flink is bootstrapped inside

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

2018-08-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581180#comment-16581180 ] Maximilian Michels edited comment on BEAM-4130 at 8/15/18 3:13 PM: --- To

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

2018-08-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581180#comment-16581180 ] Maximilian Michels commented on BEAM-4130: -- To add to the above, shouldn't the behavior for the

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

2018-08-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581161#comment-16581161 ] Maximilian Michels commented on BEAM-4130: -- >From the design document (

[jira] [Commented] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner

2017-09-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160289#comment-16160289 ] Maximilian Michels commented on BEAM-956: - Hi! :) Thanks for clarifying. Well at least the

[jira] [Commented] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

2017-08-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138333#comment-16138333 ] Maximilian Michels commented on BEAM-1628: -- [~vectorijk] Are you still working on this issue? >

[jira] [Commented] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner

2017-08-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138331#comment-16138331 ] Maximilian Michels commented on BEAM-956: - It appears this issue has been fixed. [~aljoscha] can

[jira] [Resolved] (BEAM-1255) java.io.NotSerializableException in flink on UnboundedSource

2017-01-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-1255. -- Resolution: Fixed > java.io.NotSerializableException in flink on UnboundedSource >

<    1   2